rpc

package
v1.0.0 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: 5 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 RegisterProcessorServer 

func RegisterProcessorServer(s *grpc.Server, srv ProcessorServer)

func RegisterPublisherServer 

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

func RegisterStreamCollectorServer 

func RegisterStreamCollectorServer(s *grpc.Server, srv StreamCollectorServer)

Types

type BoolPolicy 

type BoolPolicy struct {
	Rules                map[string]*BoolRule `` /* 151-byte string literal not displayed */
	Key                  []string             `protobuf:"bytes,2,rep,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*BoolPolicy) Descriptor 

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

func (*BoolPolicy) GetKey 

func (m *BoolPolicy) GetKey() []string

func (*BoolPolicy) GetRules 

func (m *BoolPolicy) GetRules() map[string]*BoolRule

func (*BoolPolicy) ProtoMessage 

func (*BoolPolicy) ProtoMessage()

func (*BoolPolicy) Reset 

func (m *BoolPolicy) Reset()

func (*BoolPolicy) String 

func (m *BoolPolicy) String() string

func (*BoolPolicy) XXX_DiscardUnknown 

func (m *BoolPolicy) XXX_DiscardUnknown()

func (*BoolPolicy) XXX_Marshal 

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

func (*BoolPolicy) XXX_Merge 

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

func (*BoolPolicy) XXX_Size 

func (m *BoolPolicy) XXX_Size() int

func (*BoolPolicy) XXX_Unmarshal 

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

type BoolRule 

type BoolRule struct {
	Required             bool     `protobuf:"varint,1,opt,name=required,proto3" json:"required,omitempty"`
	Default              bool     `protobuf:"varint,2,opt,name=default,proto3" json:"default,omitempty"`
	HasDefault           bool     `protobuf:"varint,3,opt,name=has_default,json=hasDefault,proto3" json:"has_default,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BoolRule) Descriptor 

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

func (*BoolRule) GetDefault 

func (m *BoolRule) GetDefault() bool

func (*BoolRule) GetHasDefault 

func (m *BoolRule) GetHasDefault() bool

func (*BoolRule) GetRequired 

func (m *BoolRule) GetRequired() bool

func (*BoolRule) ProtoMessage 

func (*BoolRule) ProtoMessage()

func (*BoolRule) Reset 

func (m *BoolRule) Reset()

func (*BoolRule) String 

func (m *BoolRule) String() string

func (*BoolRule) XXX_DiscardUnknown 

func (m *BoolRule) XXX_DiscardUnknown()

func (*BoolRule) XXX_Marshal 

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

func (*BoolRule) XXX_Merge 

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

func (*BoolRule) XXX_Size 

func (m *BoolRule) XXX_Size() int

func (*BoolRule) XXX_Unmarshal 

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

type CollectArg 

type CollectArg struct {
	// Request these metrics to be collected on the plugins schedule
	Metrics_Arg *MetricsArg `protobuf:"bytes,1,opt,name=Metrics_Arg,json=MetricsArg,proto3" json:"Metrics_Arg,omitempty"`
	// Set Maximum collection duration in ns. The events will be buffered
	// until the max duration is reached and/or the maxMetric buffer amount is
	// reached. 0 means the events will be sent immediately.
	MaxCollectDuration int64 `protobuf:"varint,2,opt,name=MaxCollectDuration,proto3" json:"MaxCollectDuration,omitempty"`
	// Set max number of metrics to buffer before forcing sending. Events
	// are sent as soon as MaxMetricsBuffer is reached or MaxCollectDuration
	// is exceeded, whichever happens first. If MaxMetricsBuffer is 0 metrics
	// will be sent immediately. If MaxCollectDuration is set to 0 then
	// maxMetricsBuffer will not be used as metrics will be sent immediately.
	MaxMetricsBuffer int64 `protobuf:"varint,3,opt,name=MaxMetricsBuffer,proto3" json:"MaxMetricsBuffer,omitempty"`
	// Blob of domain specific info
	Other                []byte   `protobuf:"bytes,4,opt,name=Other,proto3" json:"Other,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request that can be passed a stream collector

func (*CollectArg) Descriptor 

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

func (*CollectArg) GetMaxCollectDuration 

func (m *CollectArg) GetMaxCollectDuration() int64

func (*CollectArg) GetMaxMetricsBuffer 

func (m *CollectArg) GetMaxMetricsBuffer() int64

func (*CollectArg) GetMetrics_Arg 

func (m *CollectArg) GetMetrics_Arg() *MetricsArg

func (*CollectArg) GetOther 

func (m *CollectArg) GetOther() []byte

func (*CollectArg) ProtoMessage 

func (*CollectArg) ProtoMessage()

func (*CollectArg) Reset 

func (m *CollectArg) Reset()

func (*CollectArg) String 

func (m *CollectArg) String() string

func (*CollectArg) XXX_DiscardUnknown 

func (m *CollectArg) XXX_DiscardUnknown()

func (*CollectArg) XXX_Marshal 

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

func (*CollectArg) XXX_Merge 

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

func (*CollectArg) XXX_Size 

func (m *CollectArg) XXX_Size() int

func (*CollectArg) XXX_Unmarshal 

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

type CollectReply 

type CollectReply struct {
	// Reply with metrics
	Metrics_Reply        *MetricsReply `protobuf:"bytes,1,opt,name=Metrics_Reply,json=MetricsReply,proto3" json:"Metrics_Reply,omitempty"`
	Error                *ErrReply     `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Replies that can be sent from a stream collector

func (*CollectReply) Descriptor 

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

func (*CollectReply) GetError 

func (m *CollectReply) GetError() *ErrReply

func (*CollectReply) GetMetrics_Reply 

func (m *CollectReply) GetMetrics_Reply() *MetricsReply

func (*CollectReply) ProtoMessage 

func (*CollectReply) ProtoMessage()

func (*CollectReply) Reset 

func (m *CollectReply) Reset()

func (*CollectReply) String 

func (m *CollectReply) String() string

func (*CollectReply) XXX_DiscardUnknown 

func (m *CollectReply) XXX_DiscardUnknown()

func (*CollectReply) XXX_Marshal 

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

func (*CollectReply) XXX_Merge 

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

func (*CollectReply) XXX_Size 

func (m *CollectReply) XXX_Size() int

func (*CollectReply) XXX_Unmarshal 

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

type CollectorClient 

type CollectorClient interface {
	CollectMetrics(ctx context.Context, in *MetricsArg, opts ...grpc.CallOption) (*MetricsReply, error)
	CollectMetricsAsStream(ctx context.Context, in *MetricsArg, opts ...grpc.CallOption) (Collector_CollectMetricsAsStreamClient, error)
	GetMetricTypes(ctx context.Context, in *GetMetricTypesArg, opts ...grpc.CallOption) (*MetricsReply, error)
	Ping(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ErrReply, error)
	Kill(ctx context.Context, in *KillArg, opts ...grpc.CallOption) (*ErrReply, error)
	GetConfigPolicy(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetConfigPolicyReply, 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 NewCollectorClient 

func NewCollectorClient(cc *grpc.ClientConn) CollectorClient

type CollectorServer 

type CollectorServer interface {
	CollectMetrics(context.Context, *MetricsArg) (*MetricsReply, error)
	CollectMetricsAsStream(*MetricsArg, Collector_CollectMetricsAsStreamServer) error
	GetMetricTypes(context.Context, *GetMetricTypesArg) (*MetricsReply, error)
	Ping(context.Context, *Empty) (*ErrReply, error)
	Kill(context.Context, *KillArg) (*ErrReply, error)
	GetConfigPolicy(context.Context, *Empty) (*GetConfigPolicyReply, error)
}

CollectorServer is the server API for Collector service.

type Collector_CollectMetricsAsStreamClient 

type Collector_CollectMetricsAsStreamClient interface {
	Recv() (*MetricsReply, error)
	grpc.ClientStream
}

type Collector_CollectMetricsAsStreamServer 

type Collector_CollectMetricsAsStreamServer interface {
	Send(*MetricsReply) error
	grpc.ServerStream
}

type ConfigMap 

type ConfigMap struct {
	IntMap    map[string]int64  `` /* 154-byte string literal not displayed */
	StringMap map[string]string `` /* 159-byte string literal not displayed */
	// double is float64
	FloatMap             map[string]float64 `` /* 159-byte string literal not displayed */
	BoolMap              map[string]bool    `` /* 156-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ConfigMap) Descriptor 

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

func (*ConfigMap) GetBoolMap 

func (m *ConfigMap) GetBoolMap() map[string]bool

func (*ConfigMap) GetFloatMap 

func (m *ConfigMap) GetFloatMap() map[string]float64

func (*ConfigMap) GetIntMap 

func (m *ConfigMap) GetIntMap() map[string]int64

func (*ConfigMap) GetStringMap 

func (m *ConfigMap) GetStringMap() map[string]string

func (*ConfigMap) ProtoMessage 

func (*ConfigMap) ProtoMessage()

func (*ConfigMap) Reset 

func (m *ConfigMap) Reset()

func (*ConfigMap) String 

func (m *ConfigMap) String() string

func (*ConfigMap) XXX_DiscardUnknown 

func (m *ConfigMap) XXX_DiscardUnknown()

func (*ConfigMap) XXX_Marshal 

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

func (*ConfigMap) XXX_Merge 

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

func (*ConfigMap) XXX_Size 

func (m *ConfigMap) XXX_Size() int

func (*ConfigMap) XXX_Unmarshal 

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

type Empty 

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

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

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

func (*Empty) XXX_Merge 

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

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

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

type ErrReply 

type ErrReply struct {
	Error                string   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ErrReply) Descriptor 

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

func (*ErrReply) GetError 

func (m *ErrReply) GetError() string

func (*ErrReply) ProtoMessage 

func (*ErrReply) ProtoMessage()

func (*ErrReply) Reset 

func (m *ErrReply) Reset()

func (*ErrReply) String 

func (m *ErrReply) String() string

func (*ErrReply) XXX_DiscardUnknown 

func (m *ErrReply) XXX_DiscardUnknown()

func (*ErrReply) XXX_Marshal 

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

func (*ErrReply) XXX_Merge 

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

func (*ErrReply) XXX_Size 

func (m *ErrReply) XXX_Size() int

func (*ErrReply) XXX_Unmarshal 

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

type FloatPolicy 

type FloatPolicy struct {
	Rules                map[string]*FloatRule `` /* 151-byte string literal not displayed */
	Key                  []string              `protobuf:"bytes,2,rep,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*FloatPolicy) Descriptor 

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

func (*FloatPolicy) GetKey 

func (m *FloatPolicy) GetKey() []string

func (*FloatPolicy) GetRules 

func (m *FloatPolicy) GetRules() map[string]*FloatRule

func (*FloatPolicy) ProtoMessage 

func (*FloatPolicy) ProtoMessage()

func (*FloatPolicy) Reset 

func (m *FloatPolicy) Reset()

func (*FloatPolicy) String 

func (m *FloatPolicy) String() string

func (*FloatPolicy) XXX_DiscardUnknown 

func (m *FloatPolicy) XXX_DiscardUnknown()

func (*FloatPolicy) XXX_Marshal 

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

func (*FloatPolicy) XXX_Merge 

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

func (*FloatPolicy) XXX_Size 

func (m *FloatPolicy) XXX_Size() int

func (*FloatPolicy) XXX_Unmarshal 

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

type FloatRule 

type FloatRule struct {
	Required             bool     `protobuf:"varint,1,opt,name=required,proto3" json:"required,omitempty"`
	Minimum              float64  `protobuf:"fixed64,2,opt,name=minimum,proto3" json:"minimum,omitempty"`
	Maximum              float64  `protobuf:"fixed64,3,opt,name=maximum,proto3" json:"maximum,omitempty"`
	Default              float64  `protobuf:"fixed64,4,opt,name=default,proto3" json:"default,omitempty"`
	HasDefault           bool     `protobuf:"varint,5,opt,name=has_default,json=hasDefault,proto3" json:"has_default,omitempty"`
	HasMin               bool     `protobuf:"varint,6,opt,name=has_min,json=hasMin,proto3" json:"has_min,omitempty"`
	HasMax               bool     `protobuf:"varint,7,opt,name=has_max,json=hasMax,proto3" json:"has_max,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FloatRule) Descriptor 

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

func (*FloatRule) GetDefault 

func (m *FloatRule) GetDefault() float64

func (*FloatRule) GetHasDefault 

func (m *FloatRule) GetHasDefault() bool

func (*FloatRule) GetHasMax 

func (m *FloatRule) GetHasMax() bool

func (*FloatRule) GetHasMin 

func (m *FloatRule) GetHasMin() bool

func (*FloatRule) GetMaximum 

func (m *FloatRule) GetMaximum() float64

func (*FloatRule) GetMinimum 

func (m *FloatRule) GetMinimum() float64

func (*FloatRule) GetRequired 

func (m *FloatRule) GetRequired() bool

func (*FloatRule) ProtoMessage 

func (*FloatRule) ProtoMessage()

func (*FloatRule) Reset 

func (m *FloatRule) Reset()

func (*FloatRule) String 

func (m *FloatRule) String() string

func (*FloatRule) XXX_DiscardUnknown 

func (m *FloatRule) XXX_DiscardUnknown()

func (*FloatRule) XXX_Marshal 

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

func (*FloatRule) XXX_Merge 

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

func (*FloatRule) XXX_Size 

func (m *FloatRule) XXX_Size() int

func (*FloatRule) XXX_Unmarshal 

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

type GetConfigPolicyReply 

type GetConfigPolicyReply struct {
	Error                string                    `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	BoolPolicy           map[string]*BoolPolicy    `` /* 179-byte string literal not displayed */
	FloatPolicy          map[string]*FloatPolicy   `` /* 182-byte string literal not displayed */
	IntegerPolicy        map[string]*IntegerPolicy `` /* 188-byte string literal not displayed */
	StringPolicy         map[string]*StringPolicy  `` /* 185-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*GetConfigPolicyReply) Descriptor 

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

func (*GetConfigPolicyReply) GetBoolPolicy 

func (m *GetConfigPolicyReply) GetBoolPolicy() map[string]*BoolPolicy

func (*GetConfigPolicyReply) GetError 

func (m *GetConfigPolicyReply) GetError() string

func (*GetConfigPolicyReply) GetFloatPolicy 

func (m *GetConfigPolicyReply) GetFloatPolicy() map[string]*FloatPolicy

func (*GetConfigPolicyReply) GetIntegerPolicy 

func (m *GetConfigPolicyReply) GetIntegerPolicy() map[string]*IntegerPolicy

func (*GetConfigPolicyReply) GetStringPolicy 

func (m *GetConfigPolicyReply) GetStringPolicy() map[string]*StringPolicy

func (*GetConfigPolicyReply) ProtoMessage 

func (*GetConfigPolicyReply) ProtoMessage()

func (*GetConfigPolicyReply) Reset 

func (m *GetConfigPolicyReply) Reset()

func (*GetConfigPolicyReply) String 

func (m *GetConfigPolicyReply) String() string

func (*GetConfigPolicyReply) XXX_DiscardUnknown 

func (m *GetConfigPolicyReply) XXX_DiscardUnknown()

func (*GetConfigPolicyReply) XXX_Marshal 

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

func (*GetConfigPolicyReply) XXX_Merge 

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

func (*GetConfigPolicyReply) XXX_Size 

func (m *GetConfigPolicyReply) XXX_Size() int

func (*GetConfigPolicyReply) XXX_Unmarshal 

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

type GetMetricTypesArg 

type GetMetricTypesArg struct {
	Config               *ConfigMap `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*GetMetricTypesArg) Descriptor 

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

func (*GetMetricTypesArg) GetConfig 

func (m *GetMetricTypesArg) GetConfig() *ConfigMap

func (*GetMetricTypesArg) ProtoMessage 

func (*GetMetricTypesArg) ProtoMessage()

func (*GetMetricTypesArg) Reset 

func (m *GetMetricTypesArg) Reset()

func (*GetMetricTypesArg) String 

func (m *GetMetricTypesArg) String() string

func (*GetMetricTypesArg) XXX_DiscardUnknown 

func (m *GetMetricTypesArg) XXX_DiscardUnknown()

func (*GetMetricTypesArg) XXX_Marshal 

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

func (*GetMetricTypesArg) XXX_Merge 

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

func (*GetMetricTypesArg) XXX_Size 

func (m *GetMetricTypesArg) XXX_Size() int

func (*GetMetricTypesArg) XXX_Unmarshal 

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

type IntegerPolicy 

type IntegerPolicy struct {
	Rules                map[string]*IntegerRule `` /* 151-byte string literal not displayed */
	Key                  []string                `protobuf:"bytes,2,rep,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*IntegerPolicy) Descriptor 

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

func (*IntegerPolicy) GetKey 

func (m *IntegerPolicy) GetKey() []string

func (*IntegerPolicy) GetRules 

func (m *IntegerPolicy) GetRules() map[string]*IntegerRule

func (*IntegerPolicy) ProtoMessage 

func (*IntegerPolicy) ProtoMessage()

func (*IntegerPolicy) Reset 

func (m *IntegerPolicy) Reset()

func (*IntegerPolicy) String 

func (m *IntegerPolicy) String() string

func (*IntegerPolicy) XXX_DiscardUnknown 

func (m *IntegerPolicy) XXX_DiscardUnknown()

func (*IntegerPolicy) XXX_Marshal 

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

func (*IntegerPolicy) XXX_Merge 

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

func (*IntegerPolicy) XXX_Size 

func (m *IntegerPolicy) XXX_Size() int

func (*IntegerPolicy) XXX_Unmarshal 

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

type IntegerRule 

type IntegerRule struct {
	Required             bool     `protobuf:"varint,1,opt,name=required,proto3" json:"required,omitempty"`
	Minimum              int64    `protobuf:"varint,2,opt,name=minimum,proto3" json:"minimum,omitempty"`
	Maximum              int64    `protobuf:"varint,3,opt,name=maximum,proto3" json:"maximum,omitempty"`
	Default              int64    `protobuf:"varint,4,opt,name=default,proto3" json:"default,omitempty"`
	HasDefault           bool     `protobuf:"varint,5,opt,name=has_default,json=hasDefault,proto3" json:"has_default,omitempty"`
	HasMin               bool     `protobuf:"varint,6,opt,name=has_min,json=hasMin,proto3" json:"has_min,omitempty"`
	HasMax               bool     `protobuf:"varint,7,opt,name=has_max,json=hasMax,proto3" json:"has_max,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IntegerRule) Descriptor 

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

func (*IntegerRule) GetDefault 

func (m *IntegerRule) GetDefault() int64

func (*IntegerRule) GetHasDefault 

func (m *IntegerRule) GetHasDefault() bool

func (*IntegerRule) GetHasMax 

func (m *IntegerRule) GetHasMax() bool

func (*IntegerRule) GetHasMin 

func (m *IntegerRule) GetHasMin() bool

func (*IntegerRule) GetMaximum 

func (m *IntegerRule) GetMaximum() int64

func (*IntegerRule) GetMinimum 

func (m *IntegerRule) GetMinimum() int64

func (*IntegerRule) GetRequired 

func (m *IntegerRule) GetRequired() bool

func (*IntegerRule) ProtoMessage 

func (*IntegerRule) ProtoMessage()

func (*IntegerRule) Reset 

func (m *IntegerRule) Reset()

func (*IntegerRule) String 

func (m *IntegerRule) String() string

func (*IntegerRule) XXX_DiscardUnknown 

func (m *IntegerRule) XXX_DiscardUnknown()

func (*IntegerRule) XXX_Marshal 

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

func (*IntegerRule) XXX_Merge 

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

func (*IntegerRule) XXX_Size 

func (m *IntegerRule) XXX_Size() int

func (*IntegerRule) XXX_Unmarshal 

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

type KillArg 

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

func (*KillArg) Descriptor 

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

func (*KillArg) GetReason 

func (m *KillArg) GetReason() string

func (*KillArg) ProtoMessage 

func (*KillArg) ProtoMessage()

func (*KillArg) Reset 

func (m *KillArg) Reset()

func (*KillArg) String 

func (m *KillArg) String() string

func (*KillArg) XXX_DiscardUnknown 

func (m *KillArg) XXX_DiscardUnknown()

func (*KillArg) XXX_Marshal 

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

func (*KillArg) XXX_Merge 

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

func (*KillArg) XXX_Size 

func (m *KillArg) XXX_Size() int

func (*KillArg) XXX_Unmarshal 

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

type Metric 

type Metric struct {
	Namespace          []*NamespaceElement `protobuf:"bytes,1,rep,name=Namespace,proto3" json:"Namespace,omitempty"`
	Version            int64               `protobuf:"varint,2,opt,name=Version,proto3" json:"Version,omitempty"`
	Config             *ConfigMap          `protobuf:"bytes,3,opt,name=Config,proto3" json:"Config,omitempty"`
	LastAdvertisedTime *Time               `protobuf:"bytes,4,opt,name=LastAdvertisedTime,proto3" json:"LastAdvertisedTime,omitempty"`
	Tags               map[string]string   `` /* 149-byte string literal not displayed */
	Timestamp          *Time               `protobuf:"bytes,6,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Unit               string              `protobuf:"bytes,7,opt,name=Unit,proto3" json:"Unit,omitempty"`
	Description        string              `protobuf:"bytes,8,opt,name=Description,proto3" json:"Description,omitempty"`
	// Types that are valid to be assigned to Data:
	//	*Metric_StringData
	//	*Metric_Float32Data
	//	*Metric_Float64Data
	//	*Metric_Int32Data
	//	*Metric_Int64Data
	//	*Metric_BytesData
	//	*Metric_BoolData
	//	*Metric_Uint32Data
	//	*Metric_Uint64Data
	Data                 isMetric_Data `protobuf_oneof:"data"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

core.Metric

func (*Metric) Descriptor 

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

func (*Metric) GetBoolData 

func (m *Metric) GetBoolData() bool

func (*Metric) GetBytesData 

func (m *Metric) GetBytesData() []byte

func (*Metric) GetConfig 

func (m *Metric) GetConfig() *ConfigMap

func (*Metric) GetData 

func (m *Metric) GetData() isMetric_Data

func (*Metric) GetDescription 

func (m *Metric) GetDescription() string

func (*Metric) GetFloat32Data 

func (m *Metric) GetFloat32Data() float32

func (*Metric) GetFloat64Data 

func (m *Metric) GetFloat64Data() float64

func (*Metric) GetInt32Data 

func (m *Metric) GetInt32Data() int32

func (*Metric) GetInt64Data 

func (m *Metric) GetInt64Data() int64

func (*Metric) GetLastAdvertisedTime 

func (m *Metric) GetLastAdvertisedTime() *Time

func (*Metric) GetNamespace 

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

func (*Metric) GetStringData 

func (m *Metric) GetStringData() string

func (*Metric) GetTags 

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

func (*Metric) GetTimestamp 

func (m *Metric) GetTimestamp() *Time

func (*Metric) GetUint32Data 

func (m *Metric) GetUint32Data() uint32

func (*Metric) GetUint64Data 

func (m *Metric) GetUint64Data() uint64

func (*Metric) GetUnit 

func (m *Metric) GetUnit() string

func (*Metric) GetVersion 

func (m *Metric) GetVersion() int64

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_OneofFuncs 

func (*Metric) 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 (*Metric) XXX_Size 

func (m *Metric) XXX_Size() int

func (*Metric) XXX_Unmarshal 

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

type Metric_BoolData 

type Metric_BoolData struct {
	BoolData bool `protobuf:"varint,15,opt,name=bool_data,json=boolData,proto3,oneof"`
}

type Metric_BytesData 

type Metric_BytesData struct {
	BytesData []byte `protobuf:"bytes,14,opt,name=bytes_data,json=bytesData,proto3,oneof"`
}

type Metric_Float32Data 

type Metric_Float32Data struct {
	Float32Data float32 `protobuf:"fixed32,10,opt,name=float32_data,json=float32Data,proto3,oneof"`
}

type Metric_Float64Data 

type Metric_Float64Data struct {
	Float64Data float64 `protobuf:"fixed64,11,opt,name=float64_data,json=float64Data,proto3,oneof"`
}

type Metric_Int32Data 

type Metric_Int32Data struct {
	Int32Data int32 `protobuf:"varint,12,opt,name=int32_data,json=int32Data,proto3,oneof"`
}

type Metric_Int64Data 

type Metric_Int64Data struct {
	Int64Data int64 `protobuf:"varint,13,opt,name=int64_data,json=int64Data,proto3,oneof"`
}

type Metric_StringData 

type Metric_StringData struct {
	StringData string `protobuf:"bytes,9,opt,name=string_data,json=stringData,proto3,oneof"`
}

type Metric_Uint32Data 

type Metric_Uint32Data struct {
	Uint32Data uint32 `protobuf:"varint,16,opt,name=uint32_data,json=uint32Data,proto3,oneof"`
}

type Metric_Uint64Data 

type Metric_Uint64Data struct {
	Uint64Data uint64 `protobuf:"varint,17,opt,name=uint64_data,json=uint64Data,proto3,oneof"`
}

type MetricsArg 

type MetricsArg struct {
	Metrics              []*Metric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*MetricsArg) Descriptor 

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

func (*MetricsArg) GetMetrics 

func (m *MetricsArg) GetMetrics() []*Metric

func (*MetricsArg) ProtoMessage 

func (*MetricsArg) ProtoMessage()

func (*MetricsArg) Reset 

func (m *MetricsArg) Reset()

func (*MetricsArg) String 

func (m *MetricsArg) String() string

func (*MetricsArg) XXX_DiscardUnknown 

func (m *MetricsArg) XXX_DiscardUnknown()

func (*MetricsArg) XXX_Marshal 

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

func (*MetricsArg) XXX_Merge 

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

func (*MetricsArg) XXX_Size 

func (m *MetricsArg) XXX_Size() int

func (*MetricsArg) XXX_Unmarshal 

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

type MetricsReply 

type MetricsReply struct {
	Metrics              []*Metric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	Error                string    `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*MetricsReply) Descriptor 

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

func (*MetricsReply) GetError 

func (m *MetricsReply) GetError() string

func (*MetricsReply) GetMetrics 

func (m *MetricsReply) GetMetrics() []*Metric

func (*MetricsReply) ProtoMessage 

func (*MetricsReply) ProtoMessage()

func (*MetricsReply) Reset 

func (m *MetricsReply) Reset()

func (*MetricsReply) String 

func (m *MetricsReply) String() string

func (*MetricsReply) XXX_DiscardUnknown 

func (m *MetricsReply) XXX_DiscardUnknown()

func (*MetricsReply) XXX_Marshal 

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

func (*MetricsReply) XXX_Merge 

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

func (*MetricsReply) XXX_Size 

func (m *MetricsReply) XXX_Size() int

func (*MetricsReply) XXX_Unmarshal 

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

type NamespaceElement 

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

func (*NamespaceElement) Descriptor 

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

func (*NamespaceElement) GetDescription 

func (m *NamespaceElement) GetDescription() string

func (*NamespaceElement) GetName 

func (m *NamespaceElement) GetName() string

func (*NamespaceElement) GetValue 

func (m *NamespaceElement) GetValue() string

func (*NamespaceElement) ProtoMessage 

func (*NamespaceElement) ProtoMessage()

func (*NamespaceElement) Reset 

func (m *NamespaceElement) Reset()

func (*NamespaceElement) String 

func (m *NamespaceElement) String() string

func (*NamespaceElement) XXX_DiscardUnknown 

func (m *NamespaceElement) XXX_DiscardUnknown()

func (*NamespaceElement) XXX_Marshal 

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

func (*NamespaceElement) XXX_Merge 

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

func (*NamespaceElement) XXX_Size 

func (m *NamespaceElement) XXX_Size() int

func (*NamespaceElement) XXX_Unmarshal 

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

type ProcessorClient 

type ProcessorClient interface {
	Process(ctx context.Context, in *PubProcArg, opts ...grpc.CallOption) (*MetricsReply, error)
	Ping(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ErrReply, error)
	Kill(ctx context.Context, in *KillArg, opts ...grpc.CallOption) (*ErrReply, error)
	GetConfigPolicy(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetConfigPolicyReply, error)
}

ProcessorClient is the client API for Processor service.

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

func NewProcessorClient 

func NewProcessorClient(cc *grpc.ClientConn) ProcessorClient

type ProcessorServer 

type ProcessorServer interface {
	Process(context.Context, *PubProcArg) (*MetricsReply, error)
	Ping(context.Context, *Empty) (*ErrReply, error)
	Kill(context.Context, *KillArg) (*ErrReply, error)
	GetConfigPolicy(context.Context, *Empty) (*GetConfigPolicyReply, error)
}

ProcessorServer is the server API for Processor service.

type PubProcArg 

type PubProcArg struct {
	Metrics              []*Metric  `protobuf:"bytes,1,rep,name=Metrics,proto3" json:"Metrics,omitempty"`
	Config               *ConfigMap `protobuf:"bytes,2,opt,name=Config,proto3" json:"Config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*PubProcArg) Descriptor 

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

func (*PubProcArg) GetConfig 

func (m *PubProcArg) GetConfig() *ConfigMap

func (*PubProcArg) GetMetrics 

func (m *PubProcArg) GetMetrics() []*Metric

func (*PubProcArg) ProtoMessage 

func (*PubProcArg) ProtoMessage()

func (*PubProcArg) Reset 

func (m *PubProcArg) Reset()

func (*PubProcArg) String 

func (m *PubProcArg) String() string

func (*PubProcArg) XXX_DiscardUnknown 

func (m *PubProcArg) XXX_DiscardUnknown()

func (*PubProcArg) XXX_Marshal 

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

func (*PubProcArg) XXX_Merge 

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

func (*PubProcArg) XXX_Size 

func (m *PubProcArg) XXX_Size() int

func (*PubProcArg) XXX_Unmarshal 

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

type PublisherClient 

type PublisherClient interface {
	Publish(ctx context.Context, in *PubProcArg, opts ...grpc.CallOption) (*ErrReply, error)
	PublishAsStream(ctx context.Context, opts ...grpc.CallOption) (Publisher_PublishAsStreamClient, error)
	Ping(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ErrReply, error)
	Kill(ctx context.Context, in *KillArg, opts ...grpc.CallOption) (*ErrReply, error)
	GetConfigPolicy(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetConfigPolicyReply, 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 NewPublisherClient 

func NewPublisherClient(cc *grpc.ClientConn) PublisherClient

type PublisherServer 

type PublisherServer interface {
	Publish(context.Context, *PubProcArg) (*ErrReply, error)
	PublishAsStream(Publisher_PublishAsStreamServer) error
	Ping(context.Context, *Empty) (*ErrReply, error)
	Kill(context.Context, *KillArg) (*ErrReply, error)
	GetConfigPolicy(context.Context, *Empty) (*GetConfigPolicyReply, error)
}

PublisherServer is the server API for Publisher service.

type Publisher_PublishAsStreamClient 

type Publisher_PublishAsStreamClient interface {
	Send(*PubProcArg) error
	CloseAndRecv() (*ErrReply, error)
	grpc.ClientStream
}

type Publisher_PublishAsStreamServer 

type Publisher_PublishAsStreamServer interface {
	SendAndClose(*ErrReply) error
	Recv() (*PubProcArg, error)
	grpc.ServerStream
}

type StreamCollectorClient 

type StreamCollectorClient interface {
	StreamMetrics(ctx context.Context, opts ...grpc.CallOption) (StreamCollector_StreamMetricsClient, error)
	GetMetricTypes(ctx context.Context, in *GetMetricTypesArg, opts ...grpc.CallOption) (*MetricsReply, error)
	Ping(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ErrReply, error)
	Kill(ctx context.Context, in *KillArg, opts ...grpc.CallOption) (*ErrReply, error)
	GetConfigPolicy(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetConfigPolicyReply, error)
}

StreamCollectorClient is the client API for StreamCollector service.

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

func NewStreamCollectorClient 

func NewStreamCollectorClient(cc *grpc.ClientConn) StreamCollectorClient

type StreamCollectorServer 

type StreamCollectorServer interface {
	StreamMetrics(StreamCollector_StreamMetricsServer) error
	GetMetricTypes(context.Context, *GetMetricTypesArg) (*MetricsReply, error)
	Ping(context.Context, *Empty) (*ErrReply, error)
	Kill(context.Context, *KillArg) (*ErrReply, error)
	GetConfigPolicy(context.Context, *Empty) (*GetConfigPolicyReply, error)
}

StreamCollectorServer is the server API for StreamCollector service.

type StreamCollector_StreamMetricsClient 

type StreamCollector_StreamMetricsClient interface {
	Send(*CollectArg) error
	Recv() (*CollectReply, error)
	grpc.ClientStream
}

type StreamCollector_StreamMetricsServer 

type StreamCollector_StreamMetricsServer interface {
	Send(*CollectReply) error
	Recv() (*CollectArg, error)
	grpc.ServerStream
}

type StringPolicy 

type StringPolicy struct {
	Rules                map[string]*StringRule `` /* 151-byte string literal not displayed */
	Key                  []string               `protobuf:"bytes,2,rep,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*StringPolicy) Descriptor 

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

func (*StringPolicy) GetKey 

func (m *StringPolicy) GetKey() []string

func (*StringPolicy) GetRules 

func (m *StringPolicy) GetRules() map[string]*StringRule

func (*StringPolicy) ProtoMessage 

func (*StringPolicy) ProtoMessage()

func (*StringPolicy) Reset 

func (m *StringPolicy) Reset()

func (*StringPolicy) String 

func (m *StringPolicy) String() string

func (*StringPolicy) XXX_DiscardUnknown 

func (m *StringPolicy) XXX_DiscardUnknown()

func (*StringPolicy) XXX_Marshal 

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

func (*StringPolicy) XXX_Merge 

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

func (*StringPolicy) XXX_Size 

func (m *StringPolicy) XXX_Size() int

func (*StringPolicy) XXX_Unmarshal 

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

type StringRule 

type StringRule struct {
	Required             bool     `protobuf:"varint,1,opt,name=required,proto3" json:"required,omitempty"`
	Default              string   `protobuf:"bytes,2,opt,name=default,proto3" json:"default,omitempty"`
	HasDefault           bool     `protobuf:"varint,3,opt,name=has_default,json=hasDefault,proto3" json:"has_default,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StringRule) Descriptor 

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

func (*StringRule) GetDefault 

func (m *StringRule) GetDefault() string

func (*StringRule) GetHasDefault 

func (m *StringRule) GetHasDefault() bool

func (*StringRule) GetRequired 

func (m *StringRule) GetRequired() bool

func (*StringRule) ProtoMessage 

func (*StringRule) ProtoMessage()

func (*StringRule) Reset 

func (m *StringRule) Reset()

func (*StringRule) String 

func (m *StringRule) String() string

func (*StringRule) XXX_DiscardUnknown 

func (m *StringRule) XXX_DiscardUnknown()

func (*StringRule) XXX_Marshal 

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

func (*StringRule) XXX_Merge 

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

func (*StringRule) XXX_Size 

func (m *StringRule) XXX_Size() int

func (*StringRule) XXX_Unmarshal 

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

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

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.