pb

package
v0.0.0-...-2eeffc0 Latest Latest
Warning

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

 Go to latest Published: Dec 5, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_agent_proto protoreflect.FileDescriptor
View Source 
var File_executor_proto protoreflect.FileDescriptor

Functions

func RegisterAgentServer 

func RegisterAgentServer(s *grpc.Server, srv AgentServer)

func RegisterExecutorServer 

func RegisterExecutorServer(s *grpc.Server, 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://godoc.org/google.golang.org/grpc#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.

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://godoc.org/google.golang.org/grpc#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.

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 can 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 can 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)

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.