rpc

package
v0.16.1-beta Latest Latest
Warning

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

 Go to latest Published: Sep 16, 2016 License: Apache-2.0 Imports: 9 Imported by: 15

Documentation

Overview

Package rpc is a generated protocol buffer package.

It is generated from these files: 

github.com/intelsdi-x/snap/control/plugin/rpc/plugin.proto

It has these top-level messages: 

Empty
ErrReply
Time
NamespaceElement
PubProcArg
Metric
ConfigMap
KillArg
GetConfigPolicyReply
BoolRule
BoolPolicy
FloatRule
FloatPolicy
IntegerRule
IntegerPolicy
StringRule
StringPolicy
MetricsArg
MetricsReply
GetMetricTypesArg

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 ToConfigPolicy 

func ToConfigPolicy(reply *GetConfigPolicyReply) *cpolicy.ConfigPolicy

Types

type BoolPolicy 

type BoolPolicy struct {
	Rules map[string]*BoolRule `` /* 130-byte string literal not displayed */
}

func (*BoolPolicy) Descriptor 

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

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

type BoolRule 

type BoolRule struct {
	Required   bool `protobuf:"varint,1,opt,name=required" json:"required,omitempty"`
	Default    bool `protobuf:"varint,2,opt,name=default" json:"default,omitempty"`
	HasDefault bool `protobuf:"varint,3,opt,name=has_default,json=hasDefault" json:"has_default,omitempty"`
}

func (*BoolRule) Descriptor 

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

func (*BoolRule) ProtoMessage 

func (*BoolRule) ProtoMessage()

func (*BoolRule) Reset 

func (m *BoolRule) Reset()

func (*BoolRule) String 

func (m *BoolRule) String() string

type CollectorClient 

type CollectorClient interface {
	CollectMetrics(ctx context.Context, in *MetricsArg, opts ...grpc.CallOption) (*MetricsReply, 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)
}

func NewCollectorClient 

func NewCollectorClient(cc *grpc.ClientConn) CollectorClient

type CollectorServer 

type CollectorServer interface {
	CollectMetrics(context.Context, *MetricsArg) (*MetricsReply, 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)
}

type ConfigMap 

type ConfigMap struct {
	IntMap    map[string]int64  `` /* 145-byte string literal not displayed */
	StringMap map[string]string `` /* 153-byte string literal not displayed */
	// double is float64
	FloatMap map[string]float64 `` /* 152-byte string literal not displayed */
	BoolMap  map[string]bool    `` /* 148-byte string literal not displayed */
}

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

type Empty 

type Empty struct {
}

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

type ErrReply 

type ErrReply struct {
	Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*ErrReply) Descriptor 

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

func (*ErrReply) ProtoMessage 

func (*ErrReply) ProtoMessage()

func (*ErrReply) Reset 

func (m *ErrReply) Reset()

func (*ErrReply) String 

func (m *ErrReply) String() string

type FloatPolicy 

type FloatPolicy struct {
	Rules map[string]*FloatRule `` /* 130-byte string literal not displayed */
}

func (*FloatPolicy) Descriptor 

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

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

type FloatRule 

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

func (*FloatRule) Descriptor 

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

func (*FloatRule) ProtoMessage 

func (*FloatRule) ProtoMessage()

func (*FloatRule) Reset 

func (m *FloatRule) Reset()

func (*FloatRule) String 

func (m *FloatRule) String() string

type GetConfigPolicyReply 

type GetConfigPolicyReply struct {
	Error         string                    `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	BoolPolicy    map[string]*BoolPolicy    `` /* 158-byte string literal not displayed */
	FloatPolicy   map[string]*FloatPolicy   `` /* 161-byte string literal not displayed */
	IntegerPolicy map[string]*IntegerPolicy `` /* 167-byte string literal not displayed */
	StringPolicy  map[string]*StringPolicy  `` /* 164-byte string literal not displayed */
}

func NewGetConfigPolicyReply 

func NewGetConfigPolicyReply(policy *cpolicy.ConfigPolicy) (*GetConfigPolicyReply, error)

NewGetConfigPolicyReply given a config *cpolicy.ConfigPolicy returns a GetConfigPolicyReply.

func (*GetConfigPolicyReply) Descriptor 

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

func (*GetConfigPolicyReply) GetBoolPolicy 

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

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

type GetMetricTypesArg 

type GetMetricTypesArg struct {
	Config *ConfigMap `protobuf:"bytes,1,opt,name=config" json:"config,omitempty"`
}

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

type IntegerPolicy 

type IntegerPolicy struct {
	Rules map[string]*IntegerRule `` /* 130-byte string literal not displayed */
}

func (*IntegerPolicy) Descriptor 

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

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

type IntegerRule 

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

func (*IntegerRule) Descriptor 

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

func (*IntegerRule) ProtoMessage 

func (*IntegerRule) ProtoMessage()

func (*IntegerRule) Reset 

func (m *IntegerRule) Reset()

func (*IntegerRule) String 

func (m *IntegerRule) String() string

type KillArg 

type KillArg struct {
	Reason string `protobuf:"bytes,1,opt,name=Reason,json=reason" json:"Reason,omitempty"`
}

func (*KillArg) Descriptor 

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

func (*KillArg) ProtoMessage 

func (*KillArg) ProtoMessage()

func (*KillArg) Reset 

func (m *KillArg) Reset()

func (*KillArg) String 

func (m *KillArg) String() string

type Metric 

type Metric struct {
	Namespace          []*NamespaceElement `protobuf:"bytes,1,rep,name=Namespace,json=namespace" json:"Namespace,omitempty"`
	Version            int64               `protobuf:"varint,2,opt,name=Version,json=version" json:"Version,omitempty"`
	Config             *ConfigMap          `protobuf:"bytes,3,opt,name=Config,json=config" json:"Config,omitempty"`
	LastAdvertisedTime *Time               `protobuf:"bytes,4,opt,name=LastAdvertisedTime,json=lastAdvertisedTime" json:"LastAdvertisedTime,omitempty"`
	Tags               map[string]string   `` /* 138-byte string literal not displayed */
	Timestamp          *Time               `protobuf:"bytes,6,opt,name=Timestamp,json=timestamp" json:"Timestamp,omitempty"`
	Unit               string              `protobuf:"bytes,7,opt,name=Unit,json=unit" json:"Unit,omitempty"`
	Description        string              `protobuf:"bytes,8,opt,name=Description,json=description" 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
	Data isMetric_Data `protobuf_oneof:"data"`
}

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

func (*Metric) ProtoMessage()

func (*Metric) Reset 

func (m *Metric) Reset()

func (*Metric) String 

func (m *Metric) String() string

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.

type Metric_BoolData 

type Metric_BoolData struct {
	BoolData bool `protobuf:"varint,15,opt,name=bool_data,json=boolData,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,oneof"`
}

type Metric_Float64Data 

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

type Metric_Int32Data 

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

type Metric_Int64Data 

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

type Metric_StringData 

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

type MetricsArg 

type MetricsArg struct {
	Metrics []*Metric `protobuf:"bytes,1,rep,name=metrics" json:"metrics,omitempty"`
}

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

type MetricsReply 

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

func (*MetricsReply) Descriptor 

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

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

type NamespaceElement 

type NamespaceElement struct {
	Value       string `protobuf:"bytes,1,opt,name=Value,json=value" json:"Value,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=Description,json=description" json:"Description,omitempty"`
	Name        string `protobuf:"bytes,3,opt,name=Name,json=name" json:"Name,omitempty"`
}

func (*NamespaceElement) Descriptor 

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

func (*NamespaceElement) ProtoMessage 

func (*NamespaceElement) ProtoMessage()

func (*NamespaceElement) Reset 

func (m *NamespaceElement) Reset()

func (*NamespaceElement) String 

func (m *NamespaceElement) String() string

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

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

type PubProcArg 

type PubProcArg struct {
	Metrics []*Metric  `protobuf:"bytes,1,rep,name=Metrics,json=metrics" json:"Metrics,omitempty"`
	Config  *ConfigMap `protobuf:"bytes,2,opt,name=Config,json=config" json:"Config,omitempty"`
}

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

type PublisherClient 

type PublisherClient interface {
	Publish(ctx context.Context, in *PubProcArg, opts ...grpc.CallOption) (*ErrReply, 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)
}

func NewPublisherClient 

func NewPublisherClient(cc *grpc.ClientConn) PublisherClient

type PublisherServer 

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

type StringPolicy 

type StringPolicy struct {
	Rules map[string]*StringRule `` /* 130-byte string literal not displayed */
}

func (*StringPolicy) Descriptor 

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

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

type StringRule 

type StringRule struct {
	Required   bool   `protobuf:"varint,1,opt,name=required" json:"required,omitempty"`
	Default    string `protobuf:"bytes,2,opt,name=default" json:"default,omitempty"`
	HasDefault bool   `protobuf:"varint,3,opt,name=has_default,json=hasDefault" json:"has_default,omitempty"`
}

func (*StringRule) Descriptor 

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

func (*StringRule) ProtoMessage 

func (*StringRule) ProtoMessage()

func (*StringRule) Reset 

func (m *StringRule) Reset()

func (*StringRule) String 

func (m *StringRule) String() string

type Time 

type Time struct {
	Sec  int64 `protobuf:"varint,1,opt,name=sec" json:"sec,omitempty"`
	Nsec int64 `protobuf:"varint,2,opt,name=nsec" json:"nsec,omitempty"`
}

func (*Time) Descriptor 

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

func (*Time) ProtoMessage 

func (*Time) ProtoMessage()

func (*Time) Reset 

func (m *Time) Reset()

func (*Time) String 

func (m *Time) String() string

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.