pluginrpc

package
v2.0.7 Latest Latest
Warning

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

 Go to latest Published: Mar 3, 2021 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterCollectorServer 

func RegisterCollectorServer(s *grpc.Server, srv CollectorServer)

func RegisterControllerServer 

func RegisterControllerServer(s *grpc.Server, srv ControllerServer)

func RegisterHandlerCollector 

func RegisterHandlerCollector(reg grpchan.ServiceRegistry, srv CollectorServer)

func RegisterHandlerController 

func RegisterHandlerController(reg grpchan.ServiceRegistry, srv ControllerServer)

func RegisterHandlerPublisher 

func RegisterHandlerPublisher(reg grpchan.ServiceRegistry, srv PublisherServer)

func RegisterPublisherServer 

func RegisterPublisherServer(s *grpc.Server, srv PublisherServer)

Types

type CollectRequest 

type CollectRequest struct {
	TaskId               string   `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CollectRequest) Descriptor 

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

func (*CollectRequest) GetTaskId 

func (m *CollectRequest) GetTaskId() string

func (*CollectRequest) ProtoMessage 

func (*CollectRequest) ProtoMessage()

func (*CollectRequest) Reset 

func (m *CollectRequest) Reset()

func (*CollectRequest) String 

func (m *CollectRequest) String() string

func (*CollectRequest) XXX_DiscardUnknown 

func (m *CollectRequest) XXX_DiscardUnknown()

func (*CollectRequest) XXX_Marshal 

func (m *CollectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CollectRequest) XXX_Merge 

func (dst *CollectRequest) XXX_Merge(src proto.Message)

func (*CollectRequest) XXX_Size 

func (m *CollectRequest) XXX_Size() int

func (*CollectRequest) XXX_Unmarshal 

func (m *CollectRequest) XXX_Unmarshal(b []byte) error

type CollectResponse 

type CollectResponse struct {
	MetricSet            []*Metric  `protobuf:"bytes,1,rep,name=metric_set,json=metricSet,proto3" json:"metric_set,omitempty"`
	Warnings             []*Warning `protobuf:"bytes,2,rep,name=warnings,proto3" json:"warnings,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*CollectResponse) Descriptor 

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

func (*CollectResponse) GetMetricSet 

func (m *CollectResponse) GetMetricSet() []*Metric

func (*CollectResponse) GetWarnings 

func (m *CollectResponse) GetWarnings() []*Warning

func (*CollectResponse) ProtoMessage 

func (*CollectResponse) ProtoMessage()

func (*CollectResponse) Reset 

func (m *CollectResponse) Reset()

func (*CollectResponse) String 

func (m *CollectResponse) String() string

func (*CollectResponse) XXX_DiscardUnknown 

func (m *CollectResponse) XXX_DiscardUnknown()

func (*CollectResponse) XXX_Marshal 

func (m *CollectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CollectResponse) XXX_Merge 

func (dst *CollectResponse) XXX_Merge(src proto.Message)

func (*CollectResponse) XXX_Size 

func (m *CollectResponse) XXX_Size() int

func (*CollectResponse) XXX_Unmarshal 

func (m *CollectResponse) XXX_Unmarshal(b []byte) error

type CollectorClient 

type CollectorClient interface {
	Collect(ctx context.Context, in *CollectRequest, opts ...grpc.CallOption) (Collector_CollectClient, error)
	Load(ctx context.Context, in *LoadCollectorRequest, opts ...grpc.CallOption) (*LoadCollectorResponse, error)
	Unload(ctx context.Context, in *UnloadCollectorRequest, opts ...grpc.CallOption) (*UnloadCollectorResponse, error)
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)
}

CollectorClient is the client API for Collector service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCollectorChannelClient 

func NewCollectorChannelClient(ch grpchan.Channel) CollectorClient

func NewCollectorClient 

func NewCollectorClient(cc *grpc.ClientConn) CollectorClient

type CollectorServer 

type CollectorServer interface {
	Collect(*CollectRequest, Collector_CollectServer) error
	Load(context.Context, *LoadCollectorRequest) (*LoadCollectorResponse, error)
	Unload(context.Context, *UnloadCollectorRequest) (*UnloadCollectorResponse, error)
	Info(context.Context, *InfoRequest) (*InfoResponse, error)
}

CollectorServer is the server API for Collector service.

type Collector_CollectClient 

type Collector_CollectClient interface {
	Recv() (*CollectResponse, error)
	grpc.ClientStream
}

type Collector_CollectServer 

type Collector_CollectServer interface {
	Send(*CollectResponse) error
	grpc.ServerStream
}

type ControllerClient 

type ControllerClient interface {
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	Kill(ctx context.Context, in *KillRequest, opts ...grpc.CallOption) (*KillResponse, error)
}

ControllerClient is the client API for Controller service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewControllerChannelClient 

func NewControllerChannelClient(ch grpchan.Channel) ControllerClient

func NewControllerClient 

func NewControllerClient(cc *grpc.ClientConn) ControllerClient

type ControllerServer 

type ControllerServer interface {
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	Kill(context.Context, *KillRequest) (*KillResponse, error)
}

ControllerServer is the server API for Controller service.

type InfoRequest 

type InfoRequest struct {
	TaskId               string   `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InfoRequest) Descriptor 

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

func (*InfoRequest) GetTaskId 

func (m *InfoRequest) GetTaskId() string

func (*InfoRequest) ProtoMessage 

func (*InfoRequest) ProtoMessage()

func (*InfoRequest) Reset 

func (m *InfoRequest) Reset()

func (*InfoRequest) String 

func (m *InfoRequest) String() string

func (*InfoRequest) XXX_DiscardUnknown 

func (m *InfoRequest) XXX_DiscardUnknown()

func (*InfoRequest) XXX_Marshal 

func (m *InfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InfoRequest) XXX_Merge 

func (dst *InfoRequest) XXX_Merge(src proto.Message)

func (*InfoRequest) XXX_Size 

func (m *InfoRequest) XXX_Size() int

func (*InfoRequest) XXX_Unmarshal 

func (m *InfoRequest) XXX_Unmarshal(b []byte) error

type InfoResponse 

type InfoResponse struct {
	XLegacyInfo          *XLegacyInfo `protobuf:"bytes,1,opt,name=_legacy_info,json=LegacyInfo,proto3" json:"_legacy_info,omitempty"`
	Info                 []byte       `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*InfoResponse) Descriptor 

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

func (*InfoResponse) GetInfo 

func (m *InfoResponse) GetInfo() []byte

func (*InfoResponse) GetXLegacyInfo 

func (m *InfoResponse) GetXLegacyInfo() *XLegacyInfo

func (*InfoResponse) ProtoMessage 

func (*InfoResponse) ProtoMessage()

func (*InfoResponse) Reset 

func (m *InfoResponse) Reset()

func (*InfoResponse) String 

func (m *InfoResponse) String() string

func (*InfoResponse) XXX_DiscardUnknown 

func (m *InfoResponse) XXX_DiscardUnknown()

func (*InfoResponse) XXX_Marshal 

func (m *InfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InfoResponse) XXX_Merge 

func (dst *InfoResponse) XXX_Merge(src proto.Message)

func (*InfoResponse) XXX_Size 

func (m *InfoResponse) XXX_Size() int

func (*InfoResponse) XXX_Unmarshal 

func (m *InfoResponse) XXX_Unmarshal(b []byte) error

type KillRequest 

type KillRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KillRequest) Descriptor 

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

func (*KillRequest) ProtoMessage 

func (*KillRequest) ProtoMessage()

func (*KillRequest) Reset 

func (m *KillRequest) Reset()

func (*KillRequest) String 

func (m *KillRequest) String() string

func (*KillRequest) XXX_DiscardUnknown 

func (m *KillRequest) XXX_DiscardUnknown()

func (*KillRequest) XXX_Marshal 

func (m *KillRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KillRequest) XXX_Merge 

func (dst *KillRequest) XXX_Merge(src proto.Message)

func (*KillRequest) XXX_Size 

func (m *KillRequest) XXX_Size() int

func (*KillRequest) XXX_Unmarshal 

func (m *KillRequest) XXX_Unmarshal(b []byte) error

type KillResponse 

type KillResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KillResponse) Descriptor 

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

func (*KillResponse) ProtoMessage 

func (*KillResponse) ProtoMessage()

func (*KillResponse) Reset 

func (m *KillResponse) Reset()

func (*KillResponse) String 

func (m *KillResponse) String() string

func (*KillResponse) XXX_DiscardUnknown 

func (m *KillResponse) XXX_DiscardUnknown()

func (*KillResponse) XXX_Marshal 

func (m *KillResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KillResponse) XXX_Merge 

func (dst *KillResponse) XXX_Merge(src proto.Message)

func (*KillResponse) XXX_Size 

func (m *KillResponse) XXX_Size() int

func (*KillResponse) XXX_Unmarshal 

func (m *KillResponse) XXX_Unmarshal(b []byte) error

type LoadCollectorRequest 

type LoadCollectorRequest struct {
	TaskId               string   `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	JsonConfig           []byte   `protobuf:"bytes,2,opt,name=json_config,json=jsonConfig,proto3" json:"json_config,omitempty"`
	MetricSelectors      []string `protobuf:"bytes,3,rep,name=metric_selectors,json=metricSelectors,proto3" json:"metric_selectors,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LoadCollectorRequest) Descriptor 

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

func (*LoadCollectorRequest) GetJsonConfig 

func (m *LoadCollectorRequest) GetJsonConfig() []byte

func (*LoadCollectorRequest) GetMetricSelectors 

func (m *LoadCollectorRequest) GetMetricSelectors() []string

func (*LoadCollectorRequest) GetTaskId 

func (m *LoadCollectorRequest) GetTaskId() string

func (*LoadCollectorRequest) ProtoMessage 

func (*LoadCollectorRequest) ProtoMessage()

func (*LoadCollectorRequest) Reset 

func (m *LoadCollectorRequest) Reset()

func (*LoadCollectorRequest) String 

func (m *LoadCollectorRequest) String() string

func (*LoadCollectorRequest) XXX_DiscardUnknown 

func (m *LoadCollectorRequest) XXX_DiscardUnknown()

func (*LoadCollectorRequest) XXX_Marshal 

func (m *LoadCollectorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadCollectorRequest) XXX_Merge 

func (dst *LoadCollectorRequest) XXX_Merge(src proto.Message)

func (*LoadCollectorRequest) XXX_Size 

func (m *LoadCollectorRequest) XXX_Size() int

func (*LoadCollectorRequest) XXX_Unmarshal 

func (m *LoadCollectorRequest) XXX_Unmarshal(b []byte) error

type LoadCollectorResponse 

type LoadCollectorResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LoadCollectorResponse) Descriptor 

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

func (*LoadCollectorResponse) ProtoMessage 

func (*LoadCollectorResponse) ProtoMessage()

func (*LoadCollectorResponse) Reset 

func (m *LoadCollectorResponse) Reset()

func (*LoadCollectorResponse) String 

func (m *LoadCollectorResponse) String() string

func (*LoadCollectorResponse) XXX_DiscardUnknown 

func (m *LoadCollectorResponse) XXX_DiscardUnknown()

func (*LoadCollectorResponse) XXX_Marshal 

func (m *LoadCollectorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadCollectorResponse) XXX_Merge 

func (dst *LoadCollectorResponse) XXX_Merge(src proto.Message)

func (*LoadCollectorResponse) XXX_Size 

func (m *LoadCollectorResponse) XXX_Size() int

func (*LoadCollectorResponse) XXX_Unmarshal 

func (m *LoadCollectorResponse) XXX_Unmarshal(b []byte) error

type LoadPublisherRequest 

type LoadPublisherRequest struct {
	TaskId               string   `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	JsonConfig           []byte   `protobuf:"bytes,2,opt,name=json_config,json=jsonConfig,proto3" json:"json_config,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LoadPublisherRequest) Descriptor 

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

func (*LoadPublisherRequest) GetJsonConfig 

func (m *LoadPublisherRequest) GetJsonConfig() []byte

func (*LoadPublisherRequest) GetTaskId 

func (m *LoadPublisherRequest) GetTaskId() string

func (*LoadPublisherRequest) ProtoMessage 

func (*LoadPublisherRequest) ProtoMessage()

func (*LoadPublisherRequest) Reset 

func (m *LoadPublisherRequest) Reset()

func (*LoadPublisherRequest) String 

func (m *LoadPublisherRequest) String() string

func (*LoadPublisherRequest) XXX_DiscardUnknown 

func (m *LoadPublisherRequest) XXX_DiscardUnknown()

func (*LoadPublisherRequest) XXX_Marshal 

func (m *LoadPublisherRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadPublisherRequest) XXX_Merge 

func (dst *LoadPublisherRequest) XXX_Merge(src proto.Message)

func (*LoadPublisherRequest) XXX_Size 

func (m *LoadPublisherRequest) XXX_Size() int

func (*LoadPublisherRequest) XXX_Unmarshal 

func (m *LoadPublisherRequest) XXX_Unmarshal(b []byte) error

type LoadPublisherResponse 

type LoadPublisherResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LoadPublisherResponse) Descriptor 

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

func (*LoadPublisherResponse) ProtoMessage 

func (*LoadPublisherResponse) ProtoMessage()

func (*LoadPublisherResponse) Reset 

func (m *LoadPublisherResponse) Reset()

func (*LoadPublisherResponse) String 

func (m *LoadPublisherResponse) String() string

func (*LoadPublisherResponse) XXX_DiscardUnknown 

func (m *LoadPublisherResponse) XXX_DiscardUnknown()

func (*LoadPublisherResponse) XXX_Marshal 

func (m *LoadPublisherResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadPublisherResponse) XXX_Merge 

func (dst *LoadPublisherResponse) XXX_Merge(src proto.Message)

func (*LoadPublisherResponse) XXX_Size 

func (m *LoadPublisherResponse) XXX_Size() int

func (*LoadPublisherResponse) XXX_Unmarshal 

func (m *LoadPublisherResponse) XXX_Unmarshal(b []byte) error

type Metric 

type Metric struct {
	Namespace            []*Namespace      `protobuf:"bytes,1,rep,name=namespace,proto3" json:"namespace,omitempty"`
	Value                *MetricValue      `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Tags                 map[string]string `` /* 149-byte string literal not displayed */
	Timestamp            *Time             `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Description          string            `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	Unit                 string            `protobuf:"bytes,6,opt,name=unit,proto3" json:"unit,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Metric) Descriptor 

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

func (*Metric) GetDescription 

func (m *Metric) GetDescription() string

func (*Metric) GetNamespace 

func (m *Metric) GetNamespace() []*Namespace

func (*Metric) GetTags 

func (m *Metric) GetTags() map[string]string

func (*Metric) GetTimestamp 

func (m *Metric) GetTimestamp() *Time

func (*Metric) GetUnit 

func (m *Metric) GetUnit() string

func (*Metric) GetValue 

func (m *Metric) GetValue() *MetricValue

func (*Metric) ProtoMessage 

func (*Metric) ProtoMessage()

func (*Metric) Reset 

func (m *Metric) Reset()

func (*Metric) String 

func (m *Metric) String() string

func (*Metric) XXX_DiscardUnknown 

func (m *Metric) XXX_DiscardUnknown()

func (*Metric) XXX_Marshal 

func (m *Metric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Metric) XXX_Merge 

func (dst *Metric) XXX_Merge(src proto.Message)

func (*Metric) XXX_Size 

func (m *Metric) XXX_Size() int

func (*Metric) XXX_Unmarshal 

func (m *Metric) XXX_Unmarshal(b []byte) error

type MetricValue 

type MetricValue struct {
	// Types that are valid to be assigned to DataVariant:
	//	*MetricValue_VFloat
	//	*MetricValue_VDouble
	//	*MetricValue_VInt32
	//	*MetricValue_VInt64
	//	*MetricValue_VUint32
	//	*MetricValue_VUint64
	//	*MetricValue_VBool
	//	*MetricValue_VBytes
	//	*MetricValue_VString
	//	*MetricValue_VInt16
	//	*MetricValue_VUint16
	DataVariant          isMetricValue_DataVariant `protobuf_oneof:"data_variant"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*MetricValue) Descriptor 

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

func (*MetricValue) GetDataVariant 

func (m *MetricValue) GetDataVariant() isMetricValue_DataVariant

func (*MetricValue) GetVBool 

func (m *MetricValue) GetVBool() bool

func (*MetricValue) GetVBytes 

func (m *MetricValue) GetVBytes() []byte

func (*MetricValue) GetVDouble 

func (m *MetricValue) GetVDouble() float64

func (*MetricValue) GetVFloat 

func (m *MetricValue) GetVFloat() float32

func (*MetricValue) GetVInt16 

func (m *MetricValue) GetVInt16() int32

func (*MetricValue) GetVInt32 

func (m *MetricValue) GetVInt32() int32

func (*MetricValue) GetVInt64 

func (m *MetricValue) GetVInt64() int64

func (*MetricValue) GetVString 

func (m *MetricValue) GetVString() string

func (*MetricValue) GetVUint16 

func (m *MetricValue) GetVUint16() uint32

func (*MetricValue) GetVUint32 

func (m *MetricValue) GetVUint32() uint32

func (*MetricValue) GetVUint64 

func (m *MetricValue) GetVUint64() uint64

func (*MetricValue) ProtoMessage 

func (*MetricValue) ProtoMessage()

func (*MetricValue) Reset 

func (m *MetricValue) Reset()

func (*MetricValue) String 

func (m *MetricValue) String() string

func (*MetricValue) XXX_DiscardUnknown 

func (m *MetricValue) XXX_DiscardUnknown()

func (*MetricValue) XXX_Marshal 

func (m *MetricValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricValue) XXX_Merge 

func (dst *MetricValue) XXX_Merge(src proto.Message)

func (*MetricValue) XXX_OneofFuncs 

func (*MetricValue) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*MetricValue) XXX_Size 

func (m *MetricValue) XXX_Size() int

func (*MetricValue) XXX_Unmarshal 

func (m *MetricValue) XXX_Unmarshal(b []byte) error

type MetricValue_VBool 

type MetricValue_VBool struct {
	VBool bool `protobuf:"varint,7,opt,name=v_bool,json=vBool,proto3,oneof"`
}

type MetricValue_VBytes 

type MetricValue_VBytes struct {
	VBytes []byte `protobuf:"bytes,8,opt,name=v_bytes,json=vBytes,proto3,oneof"`
}

type MetricValue_VDouble 

type MetricValue_VDouble struct {
	VDouble float64 `protobuf:"fixed64,2,opt,name=v_double,json=vDouble,proto3,oneof"`
}

type MetricValue_VFloat 

type MetricValue_VFloat struct {
	VFloat float32 `protobuf:"fixed32,1,opt,name=v_float,json=vFloat,proto3,oneof"`
}

type MetricValue_VInt16 

type MetricValue_VInt16 struct {
	VInt16 int32 `protobuf:"varint,10,opt,name=v_int16,json=vInt16,proto3,oneof"`
}

type MetricValue_VInt32 

type MetricValue_VInt32 struct {
	VInt32 int32 `protobuf:"varint,3,opt,name=v_int32,json=vInt32,proto3,oneof"`
}

type MetricValue_VInt64 

type MetricValue_VInt64 struct {
	VInt64 int64 `protobuf:"varint,4,opt,name=v_int64,json=vInt64,proto3,oneof"`
}

type MetricValue_VString 

type MetricValue_VString struct {
	VString string `protobuf:"bytes,9,opt,name=v_string,json=vString,proto3,oneof"`
}

type MetricValue_VUint16 

type MetricValue_VUint16 struct {
	VUint16 uint32 `protobuf:"varint,11,opt,name=v_uint16,json=vUint16,proto3,oneof"`
}

type MetricValue_VUint32 

type MetricValue_VUint32 struct {
	VUint32 uint32 `protobuf:"varint,5,opt,name=v_uint32,json=vUint32,proto3,oneof"`
}

type MetricValue_VUint64 

type MetricValue_VUint64 struct {
	VUint64 uint64 `protobuf:"varint,6,opt,name=v_uint64,json=vUint64,proto3,oneof"`
}

type Namespace 

type Namespace struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Description          string   `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Namespace) Descriptor 

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

func (*Namespace) GetDescription 

func (m *Namespace) GetDescription() string

func (*Namespace) GetName 

func (m *Namespace) GetName() string

func (*Namespace) GetValue 

func (m *Namespace) GetValue() string

func (*Namespace) ProtoMessage 

func (*Namespace) ProtoMessage()

func (*Namespace) Reset 

func (m *Namespace) Reset()

func (*Namespace) String 

func (m *Namespace) String() string

func (*Namespace) XXX_DiscardUnknown 

func (m *Namespace) XXX_DiscardUnknown()

func (*Namespace) XXX_Marshal 

func (m *Namespace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Namespace) XXX_Merge 

func (dst *Namespace) XXX_Merge(src proto.Message)

func (*Namespace) XXX_Size 

func (m *Namespace) XXX_Size() int

func (*Namespace) XXX_Unmarshal 

func (m *Namespace) XXX_Unmarshal(b []byte) error

type PingRequest 

type PingRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PingRequest) Descriptor 

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

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) Reset 

func (m *PingRequest) Reset()

func (*PingRequest) String 

func (m *PingRequest) String() string

func (*PingRequest) XXX_DiscardUnknown 

func (m *PingRequest) XXX_DiscardUnknown()

func (*PingRequest) XXX_Marshal 

func (m *PingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PingRequest) XXX_Merge 

func (dst *PingRequest) XXX_Merge(src proto.Message)

func (*PingRequest) XXX_Size 

func (m *PingRequest) XXX_Size() int

func (*PingRequest) XXX_Unmarshal 

func (m *PingRequest) XXX_Unmarshal(b []byte) error

type PingResponse 

type PingResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PingResponse) Descriptor 

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

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) Reset 

func (m *PingResponse) Reset()

func (*PingResponse) String 

func (m *PingResponse) String() string

func (*PingResponse) XXX_DiscardUnknown 

func (m *PingResponse) XXX_DiscardUnknown()

func (*PingResponse) XXX_Marshal 

func (m *PingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PingResponse) XXX_Merge 

func (dst *PingResponse) XXX_Merge(src proto.Message)

func (*PingResponse) XXX_Size 

func (m *PingResponse) XXX_Size() int

func (*PingResponse) XXX_Unmarshal 

func (m *PingResponse) XXX_Unmarshal(b []byte) error

type PublishRequest 

type PublishRequest struct {
	TaskId               string    `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	MetricSet            []*Metric `protobuf:"bytes,2,rep,name=metric_set,json=metricSet,proto3" json:"metric_set,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*PublishRequest) Descriptor 

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

func (*PublishRequest) GetMetricSet 

func (m *PublishRequest) GetMetricSet() []*Metric

func (*PublishRequest) GetTaskId 

func (m *PublishRequest) GetTaskId() string

func (*PublishRequest) ProtoMessage 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) Reset 

func (m *PublishRequest) Reset()

func (*PublishRequest) String 

func (m *PublishRequest) String() string

func (*PublishRequest) XXX_DiscardUnknown 

func (m *PublishRequest) XXX_DiscardUnknown()

func (*PublishRequest) XXX_Marshal 

func (m *PublishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PublishRequest) XXX_Merge 

func (dst *PublishRequest) XXX_Merge(src proto.Message)

func (*PublishRequest) XXX_Size 

func (m *PublishRequest) XXX_Size() int

func (*PublishRequest) XXX_Unmarshal 

func (m *PublishRequest) XXX_Unmarshal(b []byte) error

type PublishResponse 

type PublishResponse struct {
	Warnings             []*Warning `protobuf:"bytes,1,rep,name=warnings,proto3" json:"warnings,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*PublishResponse) Descriptor 

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

func (*PublishResponse) GetWarnings 

func (m *PublishResponse) GetWarnings() []*Warning

func (*PublishResponse) ProtoMessage 

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) Reset 

func (m *PublishResponse) Reset()

func (*PublishResponse) String 

func (m *PublishResponse) String() string

func (*PublishResponse) XXX_DiscardUnknown 

func (m *PublishResponse) XXX_DiscardUnknown()

func (*PublishResponse) XXX_Marshal 

func (m *PublishResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PublishResponse) XXX_Merge 

func (dst *PublishResponse) XXX_Merge(src proto.Message)

func (*PublishResponse) XXX_Size 

func (m *PublishResponse) XXX_Size() int

func (*PublishResponse) XXX_Unmarshal 

func (m *PublishResponse) XXX_Unmarshal(b []byte) error

type PublisherClient 

type PublisherClient interface {
	Publish(ctx context.Context, opts ...grpc.CallOption) (Publisher_PublishClient, error)
	Load(ctx context.Context, in *LoadPublisherRequest, opts ...grpc.CallOption) (*LoadPublisherResponse, error)
	Unload(ctx context.Context, in *UnloadPublisherRequest, opts ...grpc.CallOption) (*UnloadPublisherResponse, error)
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)
}

PublisherClient is the client API for Publisher service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPublisherChannelClient 

func NewPublisherChannelClient(ch grpchan.Channel) PublisherClient

func NewPublisherClient 

func NewPublisherClient(cc *grpc.ClientConn) PublisherClient

type PublisherServer 

type PublisherServer interface {
	Publish(Publisher_PublishServer) error
	Load(context.Context, *LoadPublisherRequest) (*LoadPublisherResponse, error)
	Unload(context.Context, *UnloadPublisherRequest) (*UnloadPublisherResponse, error)
	Info(context.Context, *InfoRequest) (*InfoResponse, error)
}

PublisherServer is the server API for Publisher service.

type Publisher_PublishClient 

type Publisher_PublishClient interface {
	Send(*PublishRequest) error
	CloseAndRecv() (*PublishResponse, error)
	grpc.ClientStream
}

type Publisher_PublishServer 

type Publisher_PublishServer interface {
	SendAndClose(*PublishResponse) error
	Recv() (*PublishRequest, error)
	grpc.ServerStream
}

type Time 

type Time struct {
	Sec                  int64    `protobuf:"varint,1,opt,name=sec,proto3" json:"sec,omitempty"`
	Nsec                 int64    `protobuf:"varint,2,opt,name=nsec,proto3" json:"nsec,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Time) Descriptor 

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

func (*Time) GetNsec 

func (m *Time) GetNsec() int64

func (*Time) GetSec 

func (m *Time) GetSec() int64

func (*Time) ProtoMessage 

func (*Time) ProtoMessage()

func (*Time) Reset 

func (m *Time) Reset()

func (*Time) String 

func (m *Time) String() string

func (*Time) XXX_DiscardUnknown 

func (m *Time) XXX_DiscardUnknown()

func (*Time) XXX_Marshal 

func (m *Time) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Time) XXX_Merge 

func (dst *Time) XXX_Merge(src proto.Message)

func (*Time) XXX_Size 

func (m *Time) XXX_Size() int

func (*Time) XXX_Unmarshal 

func (m *Time) XXX_Unmarshal(b []byte) error

type UnloadCollectorRequest 

type UnloadCollectorRequest struct {
	TaskId               string   `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnloadCollectorRequest) Descriptor 

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

func (*UnloadCollectorRequest) GetTaskId 

func (m *UnloadCollectorRequest) GetTaskId() string

func (*UnloadCollectorRequest) ProtoMessage 

func (*UnloadCollectorRequest) ProtoMessage()

func (*UnloadCollectorRequest) Reset 

func (m *UnloadCollectorRequest) Reset()

func (*UnloadCollectorRequest) String 

func (m *UnloadCollectorRequest) String() string

func (*UnloadCollectorRequest) XXX_DiscardUnknown 

func (m *UnloadCollectorRequest) XXX_DiscardUnknown()

func (*UnloadCollectorRequest) XXX_Marshal 

func (m *UnloadCollectorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnloadCollectorRequest) XXX_Merge 

func (dst *UnloadCollectorRequest) XXX_Merge(src proto.Message)

func (*UnloadCollectorRequest) XXX_Size 

func (m *UnloadCollectorRequest) XXX_Size() int

func (*UnloadCollectorRequest) XXX_Unmarshal 

func (m *UnloadCollectorRequest) XXX_Unmarshal(b []byte) error

type UnloadCollectorResponse 

type UnloadCollectorResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnloadCollectorResponse) Descriptor 

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

func (*UnloadCollectorResponse) ProtoMessage 

func (*UnloadCollectorResponse) ProtoMessage()

func (*UnloadCollectorResponse) Reset 

func (m *UnloadCollectorResponse) Reset()

func (*UnloadCollectorResponse) String 

func (m *UnloadCollectorResponse) String() string

func (*UnloadCollectorResponse) XXX_DiscardUnknown 

func (m *UnloadCollectorResponse) XXX_DiscardUnknown()

func (*UnloadCollectorResponse) XXX_Marshal 

func (m *UnloadCollectorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnloadCollectorResponse) XXX_Merge 

func (dst *UnloadCollectorResponse) XXX_Merge(src proto.Message)

func (*UnloadCollectorResponse) XXX_Size 

func (m *UnloadCollectorResponse) XXX_Size() int

func (*UnloadCollectorResponse) XXX_Unmarshal 

func (m *UnloadCollectorResponse) XXX_Unmarshal(b []byte) error

type UnloadPublisherRequest 

type UnloadPublisherRequest struct {
	TaskId               string   `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnloadPublisherRequest) Descriptor 

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

func (*UnloadPublisherRequest) GetTaskId 

func (m *UnloadPublisherRequest) GetTaskId() string

func (*UnloadPublisherRequest) ProtoMessage 

func (*UnloadPublisherRequest) ProtoMessage()

func (*UnloadPublisherRequest) Reset 

func (m *UnloadPublisherRequest) Reset()

func (*UnloadPublisherRequest) String 

func (m *UnloadPublisherRequest) String() string

func (*UnloadPublisherRequest) XXX_DiscardUnknown 

func (m *UnloadPublisherRequest) XXX_DiscardUnknown()

func (*UnloadPublisherRequest) XXX_Marshal 

func (m *UnloadPublisherRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnloadPublisherRequest) XXX_Merge 

func (dst *UnloadPublisherRequest) XXX_Merge(src proto.Message)

func (*UnloadPublisherRequest) XXX_Size 

func (m *UnloadPublisherRequest) XXX_Size() int

func (*UnloadPublisherRequest) XXX_Unmarshal 

func (m *UnloadPublisherRequest) XXX_Unmarshal(b []byte) error

type UnloadPublisherResponse 

type UnloadPublisherResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnloadPublisherResponse) Descriptor 

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

func (*UnloadPublisherResponse) ProtoMessage 

func (*UnloadPublisherResponse) ProtoMessage()

func (*UnloadPublisherResponse) Reset 

func (m *UnloadPublisherResponse) Reset()

func (*UnloadPublisherResponse) String 

func (m *UnloadPublisherResponse) String() string

func (*UnloadPublisherResponse) XXX_DiscardUnknown 

func (m *UnloadPublisherResponse) XXX_DiscardUnknown()

func (*UnloadPublisherResponse) XXX_Marshal 

func (m *UnloadPublisherResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnloadPublisherResponse) XXX_Merge 

func (dst *UnloadPublisherResponse) XXX_Merge(src proto.Message)

func (*UnloadPublisherResponse) XXX_Size 

func (m *UnloadPublisherResponse) XXX_Size() int

func (*UnloadPublisherResponse) XXX_Unmarshal 

func (m *UnloadPublisherResponse) XXX_Unmarshal(b []byte) error

type Warning 

type Warning struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Timestamp            *Time    `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Warning) Descriptor 

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

func (*Warning) GetMessage 

func (m *Warning) GetMessage() string

func (*Warning) GetTimestamp 

func (m *Warning) GetTimestamp() *Time

func (*Warning) ProtoMessage 

func (*Warning) ProtoMessage()

func (*Warning) Reset 

func (m *Warning) Reset()

func (*Warning) String 

func (m *Warning) String() string

func (*Warning) XXX_DiscardUnknown 

func (m *Warning) XXX_DiscardUnknown()

func (*Warning) XXX_Marshal 

func (m *Warning) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Warning) XXX_Merge 

func (dst *Warning) XXX_Merge(src proto.Message)

func (*Warning) XXX_Size 

func (m *Warning) XXX_Size() int

func (*Warning) XXX_Unmarshal 

func (m *Warning) XXX_Unmarshal(b []byte) error

type XLegacyInfo 

type XLegacyInfo struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*XLegacyInfo) Descriptor 

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

func (*XLegacyInfo) ProtoMessage 

func (*XLegacyInfo) ProtoMessage()

func (*XLegacyInfo) Reset 

func (m *XLegacyInfo) Reset()

func (*XLegacyInfo) String 

func (m *XLegacyInfo) String() string

func (*XLegacyInfo) XXX_DiscardUnknown 

func (m *XLegacyInfo) XXX_DiscardUnknown()

func (*XLegacyInfo) XXX_Marshal 

func (m *XLegacyInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*XLegacyInfo) XXX_Merge 

func (dst *XLegacyInfo) XXX_Merge(src proto.Message)

func (*XLegacyInfo) XXX_Size 

func (m *XLegacyInfo) XXX_Size() int

func (*XLegacyInfo) XXX_Unmarshal 

func (m *XLegacyInfo) XXX_Unmarshal(b []byte) 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.