Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pluginrpc

package

Go to main page

Versions in this module

v2

v2.6.3

Oct 22, 2024

v2.6.2

Jul 3, 2024

v2.6.1

Apr 1, 2022

v2.6.0

Jan 28, 2022

v2.5.2

Jan 27, 2022

v2.5.1

Jan 14, 2022

v2.5.0

Dec 31, 2021

v2.4.1

Nov 24, 2021

v2.4.0

Nov 23, 2021

v2.3.2

Oct 14, 2021

v2.3.1

Oct 14, 2021

v2.3.0

Oct 14, 2021

Changes in this version

+ var MetricType_name = map[int32]string

+ var MetricType_value = map[string]int32

+ type Histogram struct

+ Bounds []float64

+ Count int64

+ Sum float64

+ Values []float64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Histogram) Descriptor() ([]byte, []int)

+ func (*Histogram) ProtoMessage()

+ func (dst *Histogram) XXX_Merge(src proto.Message)

+ func (m *Histogram) GetBounds() []float64

+ func (m *Histogram) GetCount() int64

+ func (m *Histogram) GetSum() float64

+ func (m *Histogram) GetValues() []float64

+ func (m *Histogram) Reset()

+ func (m *Histogram) String() string

+ func (m *Histogram) XXX_DiscardUnknown()

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

+ func (m *Histogram) XXX_Size() int

+ func (m *Histogram) XXX_Unmarshal(b []byte) error

type Metric

+ Type MetricType

+ func (m *Metric) GetType() MetricType

+ type MetricType int32

+ const MetricType_GAUGE

+ const MetricType_HISTOGRAM

+ const MetricType_SUM

+ const MetricType_SUMMARY

+ const MetricType_UNKNOWN

+ func (MetricType) EnumDescriptor() ([]byte, []int)

+ func (x MetricType) String() string

type MetricValue

+ func (m *MetricValue) GetVHistogram() *Histogram

+ func (m *MetricValue) GetVSummary() *Summary

+ type MetricValue_VHistogram struct

+ VHistogram *Histogram

+ type MetricValue_VSummary struct

+ VSummary *Summary

+ type Summary struct

+ Count int64

+ Sum float64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Summary) Descriptor() ([]byte, []int)

+ func (*Summary) ProtoMessage()

+ func (dst *Summary) XXX_Merge(src proto.Message)

+ func (m *Summary) GetCount() int64

+ func (m *Summary) GetSum() float64

+ func (m *Summary) Reset()

+ func (m *Summary) String() string

+ func (m *Summary) XXX_DiscardUnknown()

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

+ func (m *Summary) XXX_Size() int

+ func (m *Summary) XXX_Unmarshal(b []byte) error

v2.2.0

Oct 13, 2021

v2.1.0

Jul 29, 2021

v2.0.8

May 31, 2021

v2.0.7

Mar 3, 2021

v2.0.6

Feb 19, 2021

v2.0.5

Feb 12, 2021

v2.0.4

Feb 3, 2021

v2.0.3

Jan 14, 2021

v2.0.2

Dec 16, 2020

v2.0.1

Dec 2, 2020

v2.0.0

Nov 17, 2020

Changes in this version

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

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

+ func RegisterHandlerCollector(reg grpchan.ServiceRegistry, srv CollectorServer)

+ func RegisterHandlerController(reg grpchan.ServiceRegistry, srv ControllerServer)

+ func RegisterHandlerPublisher(reg grpchan.ServiceRegistry, srv PublisherServer)

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

+ type CollectRequest struct

+ TaskId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CollectRequest) ProtoMessage()

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

+ func (m *CollectRequest) GetTaskId() string

+ func (m *CollectRequest) Reset()

+ func (m *CollectRequest) String() string

+ func (m *CollectRequest) XXX_DiscardUnknown()

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

+ func (m *CollectRequest) XXX_Size() int

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

+ type CollectResponse struct

+ MetricSet []*Metric

+ Warnings []*Warning

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CollectResponse) ProtoMessage()

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

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

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

+ func (m *CollectResponse) Reset()

+ func (m *CollectResponse) String() string

+ func (m *CollectResponse) XXX_DiscardUnknown()

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

+ func (m *CollectResponse) XXX_Size() int

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

+ type CollectorClient interface

+ Collect func(ctx context.Context, in *CollectRequest, opts ...grpc.CallOption) (Collector_CollectClient, error)

+ Info func(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)

+ Load func(ctx context.Context, in *LoadCollectorRequest, opts ...grpc.CallOption) (*LoadCollectorResponse, error)

+ Unload func(ctx context.Context, in *UnloadCollectorRequest, opts ...grpc.CallOption) (*UnloadCollectorResponse, error)

+ func NewCollectorChannelClient(ch grpchan.Channel) CollectorClient

+ func NewCollectorClient(cc *grpc.ClientConn) CollectorClient

+ type CollectorServer interface

+ Collect func(*CollectRequest, Collector_CollectServer) error

+ Info func(context.Context, *InfoRequest) (*InfoResponse, error)

+ Load func(context.Context, *LoadCollectorRequest) (*LoadCollectorResponse, error)

+ Unload func(context.Context, *UnloadCollectorRequest) (*UnloadCollectorResponse, error)

+ type Collector_CollectClient interface

+ Recv func() (*CollectResponse, error)

+ type Collector_CollectServer interface

+ Send func(*CollectResponse) error

+ type ControllerClient interface

+ Kill func(ctx context.Context, in *KillRequest, opts ...grpc.CallOption) (*KillResponse, error)

+ Ping func(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)

+ func NewControllerChannelClient(ch grpchan.Channel) ControllerClient

+ func NewControllerClient(cc *grpc.ClientConn) ControllerClient

+ type ControllerServer interface

+ Kill func(context.Context, *KillRequest) (*KillResponse, error)

+ Ping func(context.Context, *PingRequest) (*PingResponse, error)

+ type InfoRequest struct

+ TaskId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*InfoRequest) ProtoMessage()

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

+ func (m *InfoRequest) GetTaskId() string

+ func (m *InfoRequest) Reset()

+ func (m *InfoRequest) String() string

+ func (m *InfoRequest) XXX_DiscardUnknown()

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

+ func (m *InfoRequest) XXX_Size() int

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

+ type InfoResponse struct

+ Info []byte

+ XLegacyInfo *XLegacyInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*InfoResponse) ProtoMessage()

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

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

+ func (m *InfoResponse) GetXLegacyInfo() *XLegacyInfo

+ func (m *InfoResponse) Reset()

+ func (m *InfoResponse) String() string

+ func (m *InfoResponse) XXX_DiscardUnknown()

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

+ func (m *InfoResponse) XXX_Size() int

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

+ type KillRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*KillRequest) ProtoMessage()

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

+ func (m *KillRequest) Reset()

+ func (m *KillRequest) String() string

+ func (m *KillRequest) XXX_DiscardUnknown()

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

+ func (m *KillRequest) XXX_Size() int

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

+ type KillResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*KillResponse) ProtoMessage()

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

+ func (m *KillResponse) Reset()

+ func (m *KillResponse) String() string

+ func (m *KillResponse) XXX_DiscardUnknown()

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

+ func (m *KillResponse) XXX_Size() int

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

+ type LoadCollectorRequest struct

+ JsonConfig []byte

+ MetricSelectors []string

+ TaskId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*LoadCollectorRequest) ProtoMessage()

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

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

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

+ func (m *LoadCollectorRequest) GetTaskId() string

+ func (m *LoadCollectorRequest) Reset()

+ func (m *LoadCollectorRequest) String() string

+ func (m *LoadCollectorRequest) XXX_DiscardUnknown()

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

+ func (m *LoadCollectorRequest) XXX_Size() int

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

+ type LoadCollectorResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*LoadCollectorResponse) ProtoMessage()

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

+ func (m *LoadCollectorResponse) Reset()

+ func (m *LoadCollectorResponse) String() string

+ func (m *LoadCollectorResponse) XXX_DiscardUnknown()

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

+ func (m *LoadCollectorResponse) XXX_Size() int

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

+ type LoadPublisherRequest struct

+ JsonConfig []byte

+ TaskId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*LoadPublisherRequest) ProtoMessage()

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

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

+ func (m *LoadPublisherRequest) GetTaskId() string

+ func (m *LoadPublisherRequest) Reset()

+ func (m *LoadPublisherRequest) String() string

+ func (m *LoadPublisherRequest) XXX_DiscardUnknown()

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

+ func (m *LoadPublisherRequest) XXX_Size() int

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

+ type LoadPublisherResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*LoadPublisherResponse) ProtoMessage()

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

+ func (m *LoadPublisherResponse) Reset()

+ func (m *LoadPublisherResponse) String() string

+ func (m *LoadPublisherResponse) XXX_DiscardUnknown()

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

+ func (m *LoadPublisherResponse) XXX_Size() int

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

+ type Metric struct

+ Description string

+ Namespace []*Namespace

+ Tags map[string]string

+ Timestamp *Time

+ Unit string

+ Value *MetricValue

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Metric) ProtoMessage()

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

+ func (m *Metric) GetDescription() string

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

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

+ func (m *Metric) GetTimestamp() *Time

+ func (m *Metric) GetUnit() string

+ func (m *Metric) GetValue() *MetricValue

+ func (m *Metric) Reset()

+ func (m *Metric) String() string

+ func (m *Metric) XXX_DiscardUnknown()

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

+ func (m *Metric) XXX_Size() int

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

+ type MetricValue struct

+ DataVariant isMetricValue_DataVariant

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MetricValue) ProtoMessage()

+ func (*MetricValue) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

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

+ func (m *MetricValue) GetDataVariant() isMetricValue_DataVariant

+ func (m *MetricValue) GetVBool() bool

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

+ func (m *MetricValue) GetVDouble() float64

+ func (m *MetricValue) GetVFloat() float32

+ func (m *MetricValue) GetVInt16() int32

+ func (m *MetricValue) GetVInt32() int32

+ func (m *MetricValue) GetVInt64() int64

+ func (m *MetricValue) GetVString() string

+ func (m *MetricValue) GetVUint16() uint32

+ func (m *MetricValue) GetVUint32() uint32

+ func (m *MetricValue) GetVUint64() uint64

+ func (m *MetricValue) Reset()

+ func (m *MetricValue) String() string

+ func (m *MetricValue) XXX_DiscardUnknown()

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

+ func (m *MetricValue) XXX_Size() int

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

+ type MetricValue_VBool struct

+ VBool bool

+ type MetricValue_VBytes struct

+ VBytes []byte

+ type MetricValue_VDouble struct

+ VDouble float64

+ type MetricValue_VFloat struct

+ VFloat float32

+ type MetricValue_VInt16 struct

+ VInt16 int32

+ type MetricValue_VInt32 struct

+ VInt32 int32

+ type MetricValue_VInt64 struct

+ VInt64 int64

+ type MetricValue_VString struct

+ VString string

+ type MetricValue_VUint16 struct

+ VUint16 uint32

+ type MetricValue_VUint32 struct

+ VUint32 uint32

+ type MetricValue_VUint64 struct

+ VUint64 uint64

+ type Namespace struct

+ Description string

+ Name string

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Namespace) ProtoMessage()

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

+ func (m *Namespace) GetDescription() string

+ func (m *Namespace) GetName() string

+ func (m *Namespace) GetValue() string

+ func (m *Namespace) Reset()

+ func (m *Namespace) String() string

+ func (m *Namespace) XXX_DiscardUnknown()

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

+ func (m *Namespace) XXX_Size() int

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

+ type PingRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PingRequest) ProtoMessage()

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

+ func (m *PingRequest) Reset()

+ func (m *PingRequest) String() string

+ func (m *PingRequest) XXX_DiscardUnknown()

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

+ func (m *PingRequest) XXX_Size() int

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

+ type PingResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PingResponse) ProtoMessage()

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

+ func (m *PingResponse) Reset()

+ func (m *PingResponse) String() string

+ func (m *PingResponse) XXX_DiscardUnknown()

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

+ func (m *PingResponse) XXX_Size() int

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

+ type PublishRequest struct

+ MetricSet []*Metric

+ TaskId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PublishRequest) ProtoMessage()

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

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

+ func (m *PublishRequest) GetTaskId() string

+ func (m *PublishRequest) Reset()

+ func (m *PublishRequest) String() string

+ func (m *PublishRequest) XXX_DiscardUnknown()

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

+ func (m *PublishRequest) XXX_Size() int

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

+ type PublishResponse struct

+ Warnings []*Warning

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PublishResponse) ProtoMessage()

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

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

+ func (m *PublishResponse) Reset()

+ func (m *PublishResponse) String() string

+ func (m *PublishResponse) XXX_DiscardUnknown()

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

+ func (m *PublishResponse) XXX_Size() int

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

+ type PublisherClient interface

+ Info func(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)

+ Load func(ctx context.Context, in *LoadPublisherRequest, opts ...grpc.CallOption) (*LoadPublisherResponse, error)

+ Publish func(ctx context.Context, opts ...grpc.CallOption) (Publisher_PublishClient, error)

+ Unload func(ctx context.Context, in *UnloadPublisherRequest, opts ...grpc.CallOption) (*UnloadPublisherResponse, error)

+ func NewPublisherChannelClient(ch grpchan.Channel) PublisherClient

+ func NewPublisherClient(cc *grpc.ClientConn) PublisherClient

+ type PublisherServer interface

+ Info func(context.Context, *InfoRequest) (*InfoResponse, error)

+ Load func(context.Context, *LoadPublisherRequest) (*LoadPublisherResponse, error)

+ Publish func(Publisher_PublishServer) error

+ Unload func(context.Context, *UnloadPublisherRequest) (*UnloadPublisherResponse, error)

+ type Publisher_PublishClient interface

+ CloseAndRecv func() (*PublishResponse, error)

+ Send func(*PublishRequest) error

+ type Publisher_PublishServer interface

+ Recv func() (*PublishRequest, error)

+ SendAndClose func(*PublishResponse) error

+ type Time struct

+ Nsec int64

+ Sec int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Time) ProtoMessage()

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

+ func (m *Time) GetNsec() int64

+ func (m *Time) GetSec() int64

+ func (m *Time) Reset()

+ func (m *Time) String() string

+ func (m *Time) XXX_DiscardUnknown()

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

+ func (m *Time) XXX_Size() int

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

+ type UnloadCollectorRequest struct

+ TaskId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UnloadCollectorRequest) ProtoMessage()

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

+ func (m *UnloadCollectorRequest) GetTaskId() string

+ func (m *UnloadCollectorRequest) Reset()

+ func (m *UnloadCollectorRequest) String() string

+ func (m *UnloadCollectorRequest) XXX_DiscardUnknown()

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

+ func (m *UnloadCollectorRequest) XXX_Size() int

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

+ type UnloadCollectorResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UnloadCollectorResponse) ProtoMessage()

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

+ func (m *UnloadCollectorResponse) Reset()

+ func (m *UnloadCollectorResponse) String() string

+ func (m *UnloadCollectorResponse) XXX_DiscardUnknown()

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

+ func (m *UnloadCollectorResponse) XXX_Size() int

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

+ type UnloadPublisherRequest struct

+ TaskId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UnloadPublisherRequest) ProtoMessage()

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

+ func (m *UnloadPublisherRequest) GetTaskId() string

+ func (m *UnloadPublisherRequest) Reset()

+ func (m *UnloadPublisherRequest) String() string

+ func (m *UnloadPublisherRequest) XXX_DiscardUnknown()

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

+ func (m *UnloadPublisherRequest) XXX_Size() int

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

+ type UnloadPublisherResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UnloadPublisherResponse) ProtoMessage()

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

+ func (m *UnloadPublisherResponse) Reset()

+ func (m *UnloadPublisherResponse) String() string

+ func (m *UnloadPublisherResponse) XXX_DiscardUnknown()

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

+ func (m *UnloadPublisherResponse) XXX_Size() int

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

+ type Warning struct

+ Message string

+ Timestamp *Time

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Warning) ProtoMessage()

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

+ func (m *Warning) GetMessage() string

+ func (m *Warning) GetTimestamp() *Time

+ func (m *Warning) Reset()

+ func (m *Warning) String() string

+ func (m *Warning) XXX_DiscardUnknown()

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

+ func (m *Warning) XXX_Size() int

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

+ type XLegacyInfo struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*XLegacyInfo) ProtoMessage()

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

+ func (m *XLegacyInfo) Reset()

+ func (m *XLegacyInfo) String() string

+ func (m *XLegacyInfo) XXX_DiscardUnknown()

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

+ func (m *XLegacyInfo) XXX_Size() int

+ func (m *XLegacyInfo) XXX_Unmarshal(b []byte) error

v2.0.0-beta-3

Oct 15, 2020

v2.0.0-beta-2

Oct 5, 2020

v2.0.0-beta

Oct 2, 2020