rpc

package
v0.15.0-beta Latest Latest
Warning

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

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

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: 

ProcessArg
ProcessReply
PublishArg
Rule
SetKeyArg
SetKeyReply
PingReply
KillRequest
KillReply
GetConfigPolicyReply
BoolRule
BoolPolicy
FloatRule
FloatPolicy
IntegerRule
IntegerPolicy
StringRule
StringPolicy
CollectMetricsArg
CollectMetricsReply
GetMetricTypesArg
GetMetricTypesReply

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"`
}

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 CollectMetricsArg 

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

func (*CollectMetricsArg) Descriptor 

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

func (*CollectMetricsArg) GetMetrics 

func (m *CollectMetricsArg) GetMetrics() []*common.Metric

func (*CollectMetricsArg) ProtoMessage 

func (*CollectMetricsArg) ProtoMessage()

func (*CollectMetricsArg) Reset 

func (m *CollectMetricsArg) Reset()

func (*CollectMetricsArg) String 

func (m *CollectMetricsArg) String() string

type CollectMetricsReply 

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

func (*CollectMetricsReply) Descriptor 

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

func (*CollectMetricsReply) GetMetrics 

func (m *CollectMetricsReply) GetMetrics() []*common.Metric

func (*CollectMetricsReply) ProtoMessage 

func (*CollectMetricsReply) ProtoMessage()

func (*CollectMetricsReply) Reset 

func (m *CollectMetricsReply) Reset()

func (*CollectMetricsReply) String 

func (m *CollectMetricsReply) String() string

type CollectorClient 

type CollectorClient interface {
	CollectMetrics(ctx context.Context, in *CollectMetricsArg, opts ...grpc.CallOption) (*CollectMetricsReply, error)
	GetMetricTypes(ctx context.Context, in *GetMetricTypesArg, opts ...grpc.CallOption) (*GetMetricTypesReply, error)
	SetKey(ctx context.Context, in *SetKeyArg, opts ...grpc.CallOption) (*SetKeyReply, error)
	Ping(ctx context.Context, in *common.Empty, opts ...grpc.CallOption) (*PingReply, error)
	Kill(ctx context.Context, in *KillRequest, opts ...grpc.CallOption) (*KillReply, error)
	GetConfigPolicy(ctx context.Context, in *common.Empty, opts ...grpc.CallOption) (*GetConfigPolicyReply, error)
}

func NewCollectorClient 

func NewCollectorClient(cc *grpc.ClientConn) CollectorClient

type CollectorServer 

type CollectorServer interface {
	CollectMetrics(context.Context, *CollectMetricsArg) (*CollectMetricsReply, error)
	GetMetricTypes(context.Context, *GetMetricTypesArg) (*GetMetricTypesReply, error)
	SetKey(context.Context, *SetKeyArg) (*SetKeyReply, error)
	Ping(context.Context, *common.Empty) (*PingReply, error)
	Kill(context.Context, *KillRequest) (*KillReply, error)
	GetConfigPolicy(context.Context, *common.Empty) (*GetConfigPolicyReply, error)
}

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"`
}

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    `` /* 142-byte string literal not displayed */
	FloatPolicy   map[string]*FloatPolicy   `` /* 144-byte string literal not displayed */
	IntegerPolicy map[string]*IntegerPolicy `` /* 148-byte string literal not displayed */
	StringPolicy  map[string]*StringPolicy  `` /* 146-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 *common.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() *common.ConfigMap

func (*GetMetricTypesArg) ProtoMessage 

func (*GetMetricTypesArg) ProtoMessage()

func (*GetMetricTypesArg) Reset 

func (m *GetMetricTypesArg) Reset()

func (*GetMetricTypesArg) String 

func (m *GetMetricTypesArg) String() string

type GetMetricTypesReply 

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

func (*GetMetricTypesReply) Descriptor 

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

func (*GetMetricTypesReply) GetMetrics 

func (m *GetMetricTypesReply) GetMetrics() []*common.Metric

func (*GetMetricTypesReply) ProtoMessage 

func (*GetMetricTypesReply) ProtoMessage()

func (*GetMetricTypesReply) Reset 

func (m *GetMetricTypesReply) Reset()

func (*GetMetricTypesReply) String 

func (m *GetMetricTypesReply) 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"`
}

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 KillReply 

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

func (*KillReply) Descriptor 

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

func (*KillReply) ProtoMessage 

func (*KillReply) ProtoMessage()

func (*KillReply) Reset 

func (m *KillReply) Reset()

func (*KillReply) String 

func (m *KillReply) String() string

type KillRequest 

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

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

type PingReply 

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

func (*PingReply) Descriptor 

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

func (*PingReply) ProtoMessage 

func (*PingReply) ProtoMessage()

func (*PingReply) Reset 

func (m *PingReply) Reset()

func (*PingReply) String 

func (m *PingReply) String() string

type ProcessArg 

type ProcessArg struct {
	ContentType string            `protobuf:"bytes,1,opt,name=ContentType" json:"ContentType,omitempty"`
	Content     []byte            `protobuf:"bytes,2,opt,name=Content,proto3" json:"Content,omitempty"`
	Config      *common.ConfigMap `protobuf:"bytes,3,opt,name=Config" json:"Config,omitempty"`
}

func (*ProcessArg) Descriptor 

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

func (*ProcessArg) GetConfig 

func (m *ProcessArg) GetConfig() *common.ConfigMap

func (*ProcessArg) ProtoMessage 

func (*ProcessArg) ProtoMessage()

func (*ProcessArg) Reset 

func (m *ProcessArg) Reset()

func (*ProcessArg) String 

func (m *ProcessArg) String() string

type ProcessReply 

type ProcessReply struct {
	ContentType string `protobuf:"bytes,1,opt,name=ContentType" json:"ContentType,omitempty"`
	Content     []byte `protobuf:"bytes,2,opt,name=Content,proto3" json:"Content,omitempty"`
	Error       string `protobuf:"bytes,3,opt,name=Error" json:"Error,omitempty"`
}

func (*ProcessReply) Descriptor 

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

func (*ProcessReply) ProtoMessage 

func (*ProcessReply) ProtoMessage()

func (*ProcessReply) Reset 

func (m *ProcessReply) Reset()

func (*ProcessReply) String 

func (m *ProcessReply) String() string

type ProcessorClient 

type ProcessorClient interface {
	Process(ctx context.Context, in *ProcessArg, opts ...grpc.CallOption) (*ProcessReply, error)
	SetKey(ctx context.Context, in *SetKeyArg, opts ...grpc.CallOption) (*SetKeyReply, error)
	Ping(ctx context.Context, in *common.Empty, opts ...grpc.CallOption) (*PingReply, error)
	Kill(ctx context.Context, in *KillRequest, opts ...grpc.CallOption) (*KillReply, error)
	GetConfigPolicy(ctx context.Context, in *common.Empty, opts ...grpc.CallOption) (*GetConfigPolicyReply, error)
}

func NewProcessorClient 

func NewProcessorClient(cc *grpc.ClientConn) ProcessorClient

type ProcessorServer 

type ProcessorServer interface {
	Process(context.Context, *ProcessArg) (*ProcessReply, error)
	SetKey(context.Context, *SetKeyArg) (*SetKeyReply, error)
	Ping(context.Context, *common.Empty) (*PingReply, error)
	Kill(context.Context, *KillRequest) (*KillReply, error)
	GetConfigPolicy(context.Context, *common.Empty) (*GetConfigPolicyReply, error)
}

type PublishArg 

type PublishArg struct {
	ContentType string            `protobuf:"bytes,1,opt,name=ContentType" json:"ContentType,omitempty"`
	Content     []byte            `protobuf:"bytes,2,opt,name=Content,proto3" json:"Content,omitempty"`
	Config      *common.ConfigMap `protobuf:"bytes,3,opt,name=Config" json:"Config,omitempty"`
}

func (*PublishArg) Descriptor 

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

func (*PublishArg) GetConfig 

func (m *PublishArg) GetConfig() *common.ConfigMap

func (*PublishArg) ProtoMessage 

func (*PublishArg) ProtoMessage()

func (*PublishArg) Reset 

func (m *PublishArg) Reset()

func (*PublishArg) String 

func (m *PublishArg) String() string

type PublisherClient 

type PublisherClient interface {
	Publish(ctx context.Context, in *PublishArg, opts ...grpc.CallOption) (*common.Empty, error)
	SetKey(ctx context.Context, in *SetKeyArg, opts ...grpc.CallOption) (*SetKeyReply, error)
	Ping(ctx context.Context, in *common.Empty, opts ...grpc.CallOption) (*PingReply, error)
	Kill(ctx context.Context, in *KillRequest, opts ...grpc.CallOption) (*KillReply, error)
	GetConfigPolicy(ctx context.Context, in *common.Empty, opts ...grpc.CallOption) (*GetConfigPolicyReply, error)
}

func NewPublisherClient 

func NewPublisherClient(cc *grpc.ClientConn) PublisherClient

type PublisherServer 

type PublisherServer interface {
	Publish(context.Context, *PublishArg) (*common.Empty, error)
	SetKey(context.Context, *SetKeyArg) (*SetKeyReply, error)
	Ping(context.Context, *common.Empty) (*PingReply, error)
	Kill(context.Context, *KillRequest) (*KillReply, error)
	GetConfigPolicy(context.Context, *common.Empty) (*GetConfigPolicyReply, error)
}

type Rule 

type Rule struct {
	RuleType      string  `protobuf:"bytes,1,opt,name=rule_type" json:"rule_type,omitempty"`
	Key           string  `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"`
	Required      bool    `protobuf:"varint,3,opt,name=required" json:"required,omitempty"`
	Eescription   string  `protobuf:"bytes,4,opt,name=eescription" json:"eescription,omitempty"`
	BoolDefault   bool    `protobuf:"varint,5,opt,name=bool_default" json:"bool_default,omitempty"`
	FloatDefault  float64 `protobuf:"fixed64,6,opt,name=float_default" json:"float_default,omitempty"`
	FloatMinimum  float64 `protobuf:"fixed64,7,opt,name=float_minimum" json:"float_minimum,omitempty"`
	FloatMaximum  float64 `protobuf:"fixed64,8,opt,name=float_maximum" json:"float_maximum,omitempty"`
	IntDefault    int64   `protobuf:"varint,9,opt,name=int_default" json:"int_default,omitempty"`
	IntMinimum    int64   `protobuf:"varint,10,opt,name=int_minimum" json:"int_minimum,omitempty"`
	IntMaximum    int64   `protobuf:"varint,11,opt,name=int_maximum" json:"int_maximum,omitempty"`
	StringDefault string  `protobuf:"bytes,12,opt,name=string_default" json:"string_default,omitempty"`
}

func (*Rule) Descriptor 

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

func (*Rule) ProtoMessage 

func (*Rule) ProtoMessage()

func (*Rule) Reset 

func (m *Rule) Reset()

func (*Rule) String 

func (m *Rule) String() string

type SetKeyArg 

type SetKeyArg struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
}

func (*SetKeyArg) Descriptor 

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

func (*SetKeyArg) ProtoMessage 

func (*SetKeyArg) ProtoMessage()

func (*SetKeyArg) Reset 

func (m *SetKeyArg) Reset()

func (*SetKeyArg) String 

func (m *SetKeyArg) String() string

type SetKeyReply 

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

func (*SetKeyReply) Descriptor 

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

func (*SetKeyReply) ProtoMessage 

func (*SetKeyReply) ProtoMessage()

func (*SetKeyReply) Reset 

func (m *SetKeyReply) Reset()

func (*SetKeyReply) String 

func (m *SetKeyReply) String() string

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"`
}

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

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.