pb

package
v0.0.0-...-37de26c Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 19, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Agent_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.Agent",
	HandlerType: (*AgentServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "FindCreateGroup",
			Handler:    _Agent_FindCreateGroup_Handler,
		},
		{
			MethodName: "FindCreateGraph",
			Handler:    _Agent_FindCreateGraph_Handler,
		},
		{
			MethodName: "FindCreateMetric",
			Handler:    _Agent_FindCreateMetric_Handler,
		},
		{
			MethodName: "Histogram",
			Handler:    _Agent_Histogram_Handler,
		},
		{
			MethodName: "Counter",
			Handler:    _Agent_Counter_Handler,
		},
		{
			MethodName: "Gauge",
			Handler:    _Agent_Gauge_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pb/agent.proto",
}

Agent_ServiceDesc is the grpc.ServiceDesc for Agent service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Executor_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.Executor",
	HandlerType: (*ExecutorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Start",
			Handler:    _Executor_Start_Handler,
		},
		{
			MethodName: "Terminate",
			Handler:    _Executor_Terminate_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pb/executor.proto",
}

Executor_ServiceDesc is the grpc.ServiceDesc for Executor service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_pb_agent_proto protoreflect.FileDescriptor
View Source 
var File_pb_executor_proto protoreflect.FileDescriptor

Functions

func RegisterAgentServer 

func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)

func RegisterExecutorServer 

func RegisterExecutorServer(s grpc.ServiceRegistrar, srv ExecutorServer)

Types

type AgentClient 

type AgentClient interface {
	FindCreateGroup(ctx context.Context, in *FCGroupReq, opts ...grpc.CallOption) (*FCGroupRes, error)
	FindCreateGraph(ctx context.Context, in *FCGraphReq, opts ...grpc.CallOption) (*FCGraphRes, error)
	FindCreateMetric(ctx context.Context, in *FCMetricReq, opts ...grpc.CallOption) (*FCMetricRes, error)
	Histogram(ctx context.Context, in *HistogramReq, opts ...grpc.CallOption) (*HistogramRes, error)
	Counter(ctx context.Context, in *CounterReq, opts ...grpc.CallOption) (*CounterRes, error)
	Gauge(ctx context.Context, in *GaugeReq, opts ...grpc.CallOption) (*GaugeRes, error)
}

AgentClient is the client API for Agent service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAgentClient 

func NewAgentClient(cc grpc.ClientConnInterface) AgentClient

type AgentServer 

type AgentServer interface {
	FindCreateGroup(context.Context, *FCGroupReq) (*FCGroupRes, error)
	FindCreateGraph(context.Context, *FCGraphReq) (*FCGraphRes, error)
	FindCreateMetric(context.Context, *FCMetricReq) (*FCMetricRes, error)
	Histogram(context.Context, *HistogramReq) (*HistogramRes, error)
	Counter(context.Context, *CounterReq) (*CounterRes, error)
	Gauge(context.Context, *GaugeReq) (*GaugeRes, error)
}

AgentServer is the server API for Agent service. All implementations should embed UnimplementedAgentServer for forward compatibility

type BasedReqMetric 

type BasedReqMetric struct {
	AppID int64  `protobuf:"varint,1,opt,name=appID,proto3" json:"appID,omitempty"` // app ID
	EID   string `protobuf:"bytes,2,opt,name=eID,proto3" json:"eID,omitempty"`      // executor ID
	MID   int64  `protobuf:"varint,3,opt,name=mID,proto3" json:"mID,omitempty"`     // metric ID
	Time  int64  `protobuf:"varint,4,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

histogram, counter, gauge

func (*BasedReqMetric) Descriptor deprecated 

func (*BasedReqMetric) Descriptor() ([]byte, []int)

Deprecated: Use BasedReqMetric.ProtoReflect.Descriptor instead.

func (*BasedReqMetric) GetAppID 

func (x *BasedReqMetric) GetAppID() int64

func (*BasedReqMetric) GetEID 

func (x *BasedReqMetric) GetEID() string

func (*BasedReqMetric) GetMID 

func (x *BasedReqMetric) GetMID() int64

func (*BasedReqMetric) GetTime 

func (x *BasedReqMetric) GetTime() int64

func (*BasedReqMetric) ProtoMessage 

func (*BasedReqMetric) ProtoMessage()

func (*BasedReqMetric) ProtoReflect 

func (x *BasedReqMetric) ProtoReflect() protoreflect.Message

func (*BasedReqMetric) Reset 

func (x *BasedReqMetric) Reset()

func (*BasedReqMetric) String 

func (x *BasedReqMetric) String() string

type CounterReq 

type CounterReq struct {
	Base  *BasedReqMetric `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	Count int64           `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*CounterReq) Descriptor deprecated 

func (*CounterReq) Descriptor() ([]byte, []int)

Deprecated: Use CounterReq.ProtoReflect.Descriptor instead.

func (*CounterReq) GetBase 

func (x *CounterReq) GetBase() *BasedReqMetric

func (*CounterReq) GetCount 

func (x *CounterReq) GetCount() int64

func (*CounterReq) ProtoMessage 

func (*CounterReq) ProtoMessage()

func (*CounterReq) ProtoReflect 

func (x *CounterReq) ProtoReflect() protoreflect.Message

func (*CounterReq) Reset 

func (x *CounterReq) Reset()

func (*CounterReq) String 

func (x *CounterReq) String() string

type CounterRes 

type CounterRes struct {
	// contains filtered or unexported fields
}

func (*CounterRes) Descriptor deprecated 

func (*CounterRes) Descriptor() ([]byte, []int)

Deprecated: Use CounterRes.ProtoReflect.Descriptor instead.

func (*CounterRes) ProtoMessage 

func (*CounterRes) ProtoMessage()

func (*CounterRes) ProtoReflect 

func (x *CounterRes) ProtoReflect() protoreflect.Message

func (*CounterRes) Reset 

func (x *CounterRes) Reset()

func (*CounterRes) String 

func (x *CounterRes) String() string

type ExecutorClient 

type ExecutorClient interface {
	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResult, error)
	Terminate(ctx context.Context, in *TermRequest, opts ...grpc.CallOption) (*TermResult, error)
}

ExecutorClient is the client API for Executor service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewExecutorClient 

func NewExecutorClient(cc grpc.ClientConnInterface) ExecutorClient

type ExecutorServer 

type ExecutorServer interface {
	Start(context.Context, *StartRequest) (*StartResult, error)
	Terminate(context.Context, *TermRequest) (*TermResult, error)
}

ExecutorServer is the server API for Executor service. All implementations should embed UnimplementedExecutorServer for forward compatibility

type FCGraphReq 

type FCGraphReq struct {
	AppID   int64  `protobuf:"varint,1,opt,name=appID,proto3" json:"appID,omitempty"`
	Title   string `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	Unit    string `protobuf:"bytes,3,opt,name=unit,proto3" json:"unit,omitempty"`
	GroupID int64  `protobuf:"varint,4,opt,name=groupID,proto3" json:"groupID,omitempty"`
	// contains filtered or unexported fields
}

find or create graph

func (*FCGraphReq) Descriptor deprecated 

func (*FCGraphReq) Descriptor() ([]byte, []int)

Deprecated: Use FCGraphReq.ProtoReflect.Descriptor instead.

func (*FCGraphReq) GetAppID 

func (x *FCGraphReq) GetAppID() int64

func (*FCGraphReq) GetGroupID 

func (x *FCGraphReq) GetGroupID() int64

func (*FCGraphReq) GetTitle 

func (x *FCGraphReq) GetTitle() string

func (*FCGraphReq) GetUnit 

func (x *FCGraphReq) GetUnit() string

func (*FCGraphReq) ProtoMessage 

func (*FCGraphReq) ProtoMessage()

func (*FCGraphReq) ProtoReflect 

func (x *FCGraphReq) ProtoReflect() protoreflect.Message

func (*FCGraphReq) Reset 

func (x *FCGraphReq) Reset()

func (*FCGraphReq) String 

func (x *FCGraphReq) String() string

type FCGraphRes 

type FCGraphRes struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*FCGraphRes) Descriptor deprecated 

func (*FCGraphRes) Descriptor() ([]byte, []int)

Deprecated: Use FCGraphRes.ProtoReflect.Descriptor instead.

func (*FCGraphRes) GetId 

func (x *FCGraphRes) GetId() int64

func (*FCGraphRes) ProtoMessage 

func (*FCGraphRes) ProtoMessage()

func (*FCGraphRes) ProtoReflect 

func (x *FCGraphRes) ProtoReflect() protoreflect.Message

func (*FCGraphRes) Reset 

func (x *FCGraphRes) Reset()

func (*FCGraphRes) String 

func (x *FCGraphRes) String() string

type FCGroupReq 

type FCGroupReq struct {
	AppID int64  `protobuf:"varint,1,opt,name=appID,proto3" json:"appID,omitempty"`
	Name  string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

find or create group

func (*FCGroupReq) Descriptor deprecated 

func (*FCGroupReq) Descriptor() ([]byte, []int)

Deprecated: Use FCGroupReq.ProtoReflect.Descriptor instead.

func (*FCGroupReq) GetAppID 

func (x *FCGroupReq) GetAppID() int64

func (*FCGroupReq) GetName 

func (x *FCGroupReq) GetName() string

func (*FCGroupReq) ProtoMessage 

func (*FCGroupReq) ProtoMessage()

func (*FCGroupReq) ProtoReflect 

func (x *FCGroupReq) ProtoReflect() protoreflect.Message

func (*FCGroupReq) Reset 

func (x *FCGroupReq) Reset()

func (*FCGroupReq) String 

func (x *FCGroupReq) String() string

type FCGroupRes 

type FCGroupRes struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*FCGroupRes) Descriptor deprecated 

func (*FCGroupRes) Descriptor() ([]byte, []int)

Deprecated: Use FCGroupRes.ProtoReflect.Descriptor instead.

func (*FCGroupRes) GetId 

func (x *FCGroupRes) GetId() int64

func (*FCGroupRes) ProtoMessage 

func (*FCGroupRes) ProtoMessage()

func (*FCGroupRes) ProtoReflect 

func (x *FCGroupRes) ProtoReflect() protoreflect.Message

func (*FCGroupRes) Reset 

func (x *FCGroupRes) Reset()

func (*FCGroupRes) String 

func (x *FCGroupRes) String() string

type FCMetricReq 

type FCMetricReq struct {
	AppID   int64  `protobuf:"varint,1,opt,name=appID,proto3" json:"appID,omitempty"`
	Title   string `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	Type    string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	GraphID int64  `protobuf:"varint,4,opt,name=graphID,proto3" json:"graphID,omitempty"`
	// contains filtered or unexported fields
}

find or create metric

func (*FCMetricReq) Descriptor deprecated 

func (*FCMetricReq) Descriptor() ([]byte, []int)

Deprecated: Use FCMetricReq.ProtoReflect.Descriptor instead.

func (*FCMetricReq) GetAppID 

func (x *FCMetricReq) GetAppID() int64

func (*FCMetricReq) GetGraphID 

func (x *FCMetricReq) GetGraphID() int64

func (*FCMetricReq) GetTitle 

func (x *FCMetricReq) GetTitle() string

func (*FCMetricReq) GetType 

func (x *FCMetricReq) GetType() string

func (*FCMetricReq) ProtoMessage 

func (*FCMetricReq) ProtoMessage()

func (*FCMetricReq) ProtoReflect 

func (x *FCMetricReq) ProtoReflect() protoreflect.Message

func (*FCMetricReq) Reset 

func (x *FCMetricReq) Reset()

func (*FCMetricReq) String 

func (x *FCMetricReq) String() string

type FCMetricRes 

type FCMetricRes struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*FCMetricRes) Descriptor deprecated 

func (*FCMetricRes) Descriptor() ([]byte, []int)

Deprecated: Use FCMetricRes.ProtoReflect.Descriptor instead.

func (*FCMetricRes) GetId 

func (x *FCMetricRes) GetId() int64

func (*FCMetricRes) ProtoMessage 

func (*FCMetricRes) ProtoMessage()

func (*FCMetricRes) ProtoReflect 

func (x *FCMetricRes) ProtoReflect() protoreflect.Message

func (*FCMetricRes) Reset 

func (x *FCMetricRes) Reset()

func (*FCMetricRes) String 

func (x *FCMetricRes) String() string

type GaugeReq 

type GaugeReq struct {
	Base  *BasedReqMetric `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	Gauge int64           `protobuf:"varint,2,opt,name=gauge,proto3" json:"gauge,omitempty"`
	// contains filtered or unexported fields
}

func (*GaugeReq) Descriptor deprecated 

func (*GaugeReq) Descriptor() ([]byte, []int)

Deprecated: Use GaugeReq.ProtoReflect.Descriptor instead.

func (*GaugeReq) GetBase 

func (x *GaugeReq) GetBase() *BasedReqMetric

func (*GaugeReq) GetGauge 

func (x *GaugeReq) GetGauge() int64

func (*GaugeReq) ProtoMessage 

func (*GaugeReq) ProtoMessage()

func (*GaugeReq) ProtoReflect 

func (x *GaugeReq) ProtoReflect() protoreflect.Message

func (*GaugeReq) Reset 

func (x *GaugeReq) Reset()

func (*GaugeReq) String 

func (x *GaugeReq) String() string

type GaugeRes 

type GaugeRes struct {
	// contains filtered or unexported fields
}

func (*GaugeRes) Descriptor deprecated 

func (*GaugeRes) Descriptor() ([]byte, []int)

Deprecated: Use GaugeRes.ProtoReflect.Descriptor instead.

func (*GaugeRes) ProtoMessage 

func (*GaugeRes) ProtoMessage()

func (*GaugeRes) ProtoReflect 

func (x *GaugeRes) ProtoReflect() protoreflect.Message

func (*GaugeRes) Reset 

func (x *GaugeRes) Reset()

func (*GaugeRes) String 

func (x *GaugeRes) String() string

type HistogramReq 

type HistogramReq struct {
	Base      *BasedReqMetric  `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	Histogram *HistogramValues `protobuf:"bytes,2,opt,name=histogram,proto3" json:"histogram,omitempty"`
	// contains filtered or unexported fields
}

func (*HistogramReq) Descriptor deprecated 

func (*HistogramReq) Descriptor() ([]byte, []int)

Deprecated: Use HistogramReq.ProtoReflect.Descriptor instead.

func (*HistogramReq) GetBase 

func (x *HistogramReq) GetBase() *BasedReqMetric

func (*HistogramReq) GetHistogram 

func (x *HistogramReq) GetHistogram() *HistogramValues

func (*HistogramReq) ProtoMessage 

func (*HistogramReq) ProtoMessage()

func (*HistogramReq) ProtoReflect 

func (x *HistogramReq) ProtoReflect() protoreflect.Message

func (*HistogramReq) Reset 

func (x *HistogramReq) Reset()

func (*HistogramReq) String 

func (x *HistogramReq) String() string

type HistogramRes 

type HistogramRes struct {
	// contains filtered or unexported fields
}

func (*HistogramRes) Descriptor deprecated 

func (*HistogramRes) Descriptor() ([]byte, []int)

Deprecated: Use HistogramRes.ProtoReflect.Descriptor instead.

func (*HistogramRes) ProtoMessage 

func (*HistogramRes) ProtoMessage()

func (*HistogramRes) ProtoReflect 

func (x *HistogramRes) ProtoReflect() protoreflect.Message

func (*HistogramRes) Reset 

func (x *HistogramRes) Reset()

func (*HistogramRes) String 

func (x *HistogramRes) String() string

type HistogramValues 

type HistogramValues struct {
	Count  int64   `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Min    int64   `protobuf:"varint,2,opt,name=min,proto3" json:"min,omitempty"`
	Max    int64   `protobuf:"varint,3,opt,name=max,proto3" json:"max,omitempty"`
	Mean   float64 `protobuf:"fixed64,4,opt,name=mean,proto3" json:"mean,omitempty"`
	Stddev float64 `protobuf:"fixed64,5,opt,name=stddev,proto3" json:"stddev,omitempty"`
	Median float64 `protobuf:"fixed64,6,opt,name=median,proto3" json:"median,omitempty"`
	P75    float64 `protobuf:"fixed64,7,opt,name=p75,proto3" json:"p75,omitempty"`
	P95    float64 `protobuf:"fixed64,8,opt,name=p95,proto3" json:"p95,omitempty"`
	P99    float64 `protobuf:"fixed64,9,opt,name=p99,proto3" json:"p99,omitempty"`
	P999   float64 `protobuf:"fixed64,10,opt,name=p999,proto3" json:"p999,omitempty"`
	// contains filtered or unexported fields
}

func (*HistogramValues) Descriptor deprecated 

func (*HistogramValues) Descriptor() ([]byte, []int)

Deprecated: Use HistogramValues.ProtoReflect.Descriptor instead.

func (*HistogramValues) GetCount 

func (x *HistogramValues) GetCount() int64

func (*HistogramValues) GetMax 

func (x *HistogramValues) GetMax() int64

func (*HistogramValues) GetMean 

func (x *HistogramValues) GetMean() float64

func (*HistogramValues) GetMedian 

func (x *HistogramValues) GetMedian() float64

func (*HistogramValues) GetMin 

func (x *HistogramValues) GetMin() int64

func (*HistogramValues) GetP75 

func (x *HistogramValues) GetP75() float64

func (*HistogramValues) GetP95 

func (x *HistogramValues) GetP95() float64

func (*HistogramValues) GetP99 

func (x *HistogramValues) GetP99() float64

func (*HistogramValues) GetP999 

func (x *HistogramValues) GetP999() float64

func (*HistogramValues) GetStddev 

func (x *HistogramValues) GetStddev() float64

func (*HistogramValues) ProtoMessage 

func (*HistogramValues) ProtoMessage()

func (*HistogramValues) ProtoReflect 

func (x *HistogramValues) ProtoReflect() protoreflect.Message

func (*HistogramValues) Reset 

func (x *HistogramValues) Reset()

func (*HistogramValues) String 

func (x *HistogramValues) String() string

type StartRequest 

type StartRequest struct {
	AppID int64 `protobuf:"varint,1,opt,name=appID,proto3" json:"appID,omitempty"`
	// contains filtered or unexported fields
}

func (*StartRequest) Descriptor deprecated 

func (*StartRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartRequest.ProtoReflect.Descriptor instead.

func (*StartRequest) GetAppID 

func (x *StartRequest) GetAppID() int64

func (*StartRequest) ProtoMessage 

func (*StartRequest) ProtoMessage()

func (*StartRequest) ProtoReflect 

func (x *StartRequest) ProtoReflect() protoreflect.Message

func (*StartRequest) Reset 

func (x *StartRequest) Reset()

func (*StartRequest) String 

func (x *StartRequest) String() string

type StartResult 

type StartResult struct {
	AppID   int64 `protobuf:"varint,1,opt,name=appID,proto3" json:"appID,omitempty"`
	Success bool  `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*StartResult) Descriptor deprecated 

func (*StartResult) Descriptor() ([]byte, []int)

Deprecated: Use StartResult.ProtoReflect.Descriptor instead.

func (*StartResult) GetAppID 

func (x *StartResult) GetAppID() int64

func (*StartResult) GetSuccess 

func (x *StartResult) GetSuccess() bool

func (*StartResult) ProtoMessage 

func (*StartResult) ProtoMessage()

func (*StartResult) ProtoReflect 

func (x *StartResult) ProtoReflect() protoreflect.Message

func (*StartResult) Reset 

func (x *StartResult) Reset()

func (*StartResult) String 

func (x *StartResult) String() string

type TermRequest 

type TermRequest struct {
	AppID int64 `protobuf:"varint,1,opt,name=appID,proto3" json:"appID,omitempty"`
	Code  int64 `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*TermRequest) Descriptor deprecated 

func (*TermRequest) Descriptor() ([]byte, []int)

Deprecated: Use TermRequest.ProtoReflect.Descriptor instead.

func (*TermRequest) GetAppID 

func (x *TermRequest) GetAppID() int64

func (*TermRequest) GetCode 

func (x *TermRequest) GetCode() int64

func (*TermRequest) ProtoMessage 

func (*TermRequest) ProtoMessage()

func (*TermRequest) ProtoReflect 

func (x *TermRequest) ProtoReflect() protoreflect.Message

func (*TermRequest) Reset 

func (x *TermRequest) Reset()

func (*TermRequest) String 

func (x *TermRequest) String() string

type TermResult 

type TermResult struct {
	AppID   int64 `protobuf:"varint,1,opt,name=appID,proto3" json:"appID,omitempty"`
	Success bool  `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*TermResult) Descriptor deprecated 

func (*TermResult) Descriptor() ([]byte, []int)

Deprecated: Use TermResult.ProtoReflect.Descriptor instead.

func (*TermResult) GetAppID 

func (x *TermResult) GetAppID() int64

func (*TermResult) GetSuccess 

func (x *TermResult) GetSuccess() bool

func (*TermResult) ProtoMessage 

func (*TermResult) ProtoMessage()

func (*TermResult) ProtoReflect 

func (x *TermResult) ProtoReflect() protoreflect.Message

func (*TermResult) Reset 

func (x *TermResult) Reset()

func (*TermResult) String 

func (x *TermResult) String() string

type UnimplementedAgentServer 

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer should be embedded to have forward compatible implementations.

func (UnimplementedAgentServer) Counter 

func (UnimplementedAgentServer) Counter(context.Context, *CounterReq) (*CounterRes, error)

func (UnimplementedAgentServer) FindCreateGraph 

func (UnimplementedAgentServer) FindCreateGraph(context.Context, *FCGraphReq) (*FCGraphRes, error)

func (UnimplementedAgentServer) FindCreateGroup 

func (UnimplementedAgentServer) FindCreateGroup(context.Context, *FCGroupReq) (*FCGroupRes, error)

func (UnimplementedAgentServer) FindCreateMetric 

func (UnimplementedAgentServer) FindCreateMetric(context.Context, *FCMetricReq) (*FCMetricRes, error)

func (UnimplementedAgentServer) Gauge 

func (UnimplementedAgentServer) Gauge(context.Context, *GaugeReq) (*GaugeRes, error)

func (UnimplementedAgentServer) Histogram 

func (UnimplementedAgentServer) Histogram(context.Context, *HistogramReq) (*HistogramRes, error)

type UnimplementedExecutorServer 

type UnimplementedExecutorServer struct {
}

UnimplementedExecutorServer should be embedded to have forward compatible implementations.

func (UnimplementedExecutorServer) Start 

func (UnimplementedExecutorServer) Start(context.Context, *StartRequest) (*StartResult, error)

func (UnimplementedExecutorServer) Terminate 

func (UnimplementedExecutorServer) Terminate(context.Context, *TermRequest) (*TermResult, error)

type UnsafeAgentServer 

type UnsafeAgentServer interface {
	// contains filtered or unexported methods
}

UnsafeAgentServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AgentServer will result in compilation errors.

type UnsafeExecutorServer 

type UnsafeExecutorServer interface {
	// contains filtered or unexported methods
}

UnsafeExecutorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExecutorServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.