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: 12 Imported by: 32

Documentation

Overview

Package rpc is a generated protocol buffer package.

It is generated from these files:

github.com/intelsdi-x/snap/grpc/controlproxy/rpc/control.proto

It has these top-level messages:

SerrorReply
PubProcMetricsRequest
ErrorReply
ProcessMetricsReply
ValidateDepsRequest
ValidateDepsReply
SubscribeDepsRequest
SubscribeDepsReply
UnsubscribeDepsRequest
UnsubscribeDepsReply
Map
MapEntry
CollectMetricsRequest
CollectMetricsResponse
ArrString
GetAutodiscoverPathsReply

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConvertSnapErrors

func ConvertSnapErrors(s []*common.SnapError) []serror.SnapError

func NewErrors

func NewErrors(errs []serror.SnapError) []*common.SnapError

func RegisterMetricManagerServer

func RegisterMetricManagerServer(s *grpc.Server, srv MetricManagerServer)

Types

type ArrString

type ArrString struct {
	S []*common.NamespaceElement `protobuf:"bytes,1,rep,name=S,json=s" json:"S,omitempty"`
}

func (*ArrString) Descriptor

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

func (*ArrString) GetS

func (m *ArrString) GetS() []*common.NamespaceElement

func (*ArrString) ProtoMessage

func (*ArrString) ProtoMessage()

func (*ArrString) Reset

func (m *ArrString) Reset()

func (*ArrString) String

func (m *ArrString) String() string

type AvailablePlugin

type AvailablePlugin struct {
	Name     string    `json:"name"`
	Version  int       `json:"version"`
	TypeName string    `json:"type_name"`
	Signed   bool      `json:"signed"`
	HitCount int       `json:"hit_count"`
	ID       uint32    `json:"id"`
	LastHit  time.Time `json:"last_hit"`
}

type CollectMetricsRequest

type CollectMetricsRequest struct {
	TaskID  string          `protobuf:"bytes,1,opt,name=TaskID,json=taskID" json:"TaskID,omitempty"`
	AllTags map[string]*Map `` /* 147-byte string literal not displayed */
}

func (*CollectMetricsRequest) Descriptor

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

func (*CollectMetricsRequest) GetAllTags

func (m *CollectMetricsRequest) GetAllTags() map[string]*Map

func (*CollectMetricsRequest) ProtoMessage

func (*CollectMetricsRequest) ProtoMessage()

func (*CollectMetricsRequest) Reset

func (m *CollectMetricsRequest) Reset()

func (*CollectMetricsRequest) String

func (m *CollectMetricsRequest) String() string

type CollectMetricsResponse

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

func (*CollectMetricsResponse) Descriptor

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

func (*CollectMetricsResponse) GetMetrics

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

func (*CollectMetricsResponse) ProtoMessage

func (*CollectMetricsResponse) ProtoMessage()

func (*CollectMetricsResponse) Reset

func (m *CollectMetricsResponse) Reset()

func (*CollectMetricsResponse) String

func (m *CollectMetricsResponse) String() string

type ErrorReply

type ErrorReply struct {
	Errors []string `protobuf:"bytes,1,rep,name=Errors,json=errors" json:"Errors,omitempty"`
}

func (*ErrorReply) Descriptor

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

func (*ErrorReply) ProtoMessage

func (*ErrorReply) ProtoMessage()

func (*ErrorReply) Reset

func (m *ErrorReply) Reset()

func (*ErrorReply) String

func (m *ErrorReply) String() string

type GetAutodiscoverPathsReply

type GetAutodiscoverPathsReply struct {
	Paths []string `protobuf:"bytes,1,rep,name=Paths,json=paths" json:"Paths,omitempty"`
}

func (*GetAutodiscoverPathsReply) Descriptor

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

func (*GetAutodiscoverPathsReply) ProtoMessage

func (*GetAutodiscoverPathsReply) ProtoMessage()

func (*GetAutodiscoverPathsReply) Reset

func (m *GetAutodiscoverPathsReply) Reset()

func (*GetAutodiscoverPathsReply) String

func (m *GetAutodiscoverPathsReply) String() string

type LoadedPlugin

type LoadedPlugin struct {
	Name            string                `json:"name"`
	Version         int                   `json:"version"`
	TypeName        string                `json:"type_name"`
	IsSigned        bool                  `json:"signed"`
	Status          string                `json:"status"`
	LoadedTimestamp time.Time             `json:"timestamp"`
	ConfigPolicy    *cpolicy.ConfigPolicy `json:"policy,omitempty"`
}

type Map

type Map struct {
	Entries []*MapEntry `protobuf:"bytes,1,rep,name=Entries,json=entries" json:"Entries,omitempty"`
}

func (*Map) Descriptor

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

func (*Map) GetEntries

func (m *Map) GetEntries() []*MapEntry

func (*Map) ProtoMessage

func (*Map) ProtoMessage()

func (*Map) Reset

func (m *Map) Reset()

func (*Map) String

func (m *Map) String() string

type MapEntry

type MapEntry struct {
	Key   string `protobuf:"bytes,1,opt,name=Key,json=key" json:"Key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=Value,json=value" json:"Value,omitempty"`
}

func (*MapEntry) Descriptor

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

func (*MapEntry) ProtoMessage

func (*MapEntry) ProtoMessage()

func (*MapEntry) Reset

func (m *MapEntry) Reset()

func (*MapEntry) String

func (m *MapEntry) String() string

type Metric

type Metric struct {
	Namespace          []string                  `json:"namespace"`
	Version            int                       `json:"version"`
	LastAdvertisedTime time.Time                 `json:"last_advertised_time"`
	ConfigPolicy       *cpolicy.ConfigPolicyNode `json:"policy"`
}

type MetricManagerClient

type MetricManagerClient interface {
	// managesMetrics from scheduler
	CollectMetrics(ctx context.Context, in *CollectMetricsRequest, opts ...grpc.CallOption) (*CollectMetricsResponse, error)
	PublishMetrics(ctx context.Context, in *PubProcMetricsRequest, opts ...grpc.CallOption) (*ErrorReply, error)
	ProcessMetrics(ctx context.Context, in *PubProcMetricsRequest, opts ...grpc.CallOption) (*ProcessMetricsReply, error)
	ValidateDeps(ctx context.Context, in *ValidateDepsRequest, opts ...grpc.CallOption) (*ValidateDepsReply, error)
	SubscribeDeps(ctx context.Context, in *SubscribeDepsRequest, opts ...grpc.CallOption) (*SubscribeDepsReply, error)
	UnsubscribeDeps(ctx context.Context, in *UnsubscribeDepsRequest, opts ...grpc.CallOption) (*UnsubscribeDepsReply, error)
	GetAutodiscoverPaths(ctx context.Context, in *common.Empty, opts ...grpc.CallOption) (*GetAutodiscoverPathsReply, error)
}

func NewMetricManagerClient

func NewMetricManagerClient(cc *grpc.ClientConn) MetricManagerClient

type ProcessMetricsReply

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

func (*ProcessMetricsReply) Descriptor

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

func (*ProcessMetricsReply) GetMetrics

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

func (*ProcessMetricsReply) ProtoMessage

func (*ProcessMetricsReply) ProtoMessage()

func (*ProcessMetricsReply) Reset

func (m *ProcessMetricsReply) Reset()

func (*ProcessMetricsReply) String

func (m *ProcessMetricsReply) String() string

type PubProcMetricsRequest

type PubProcMetricsRequest struct {
	Metrics       []*common.Metric  `protobuf:"bytes,1,rep,name=Metrics,json=metrics" json:"Metrics,omitempty"`
	PluginName    string            `protobuf:"bytes,2,opt,name=PluginName,json=pluginName" json:"PluginName,omitempty"`
	PluginVersion int64             `protobuf:"varint,3,opt,name=PluginVersion,json=pluginVersion" json:"PluginVersion,omitempty"`
	Config        *common.ConfigMap `protobuf:"bytes,4,opt,name=Config,json=config" json:"Config,omitempty"`
	TaskId        string            `protobuf:"bytes,5,opt,name=TaskId,json=taskId" json:"TaskId,omitempty"`
}

func (*PubProcMetricsRequest) Descriptor

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

func (*PubProcMetricsRequest) GetConfig

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

func (*PubProcMetricsRequest) GetMetrics

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

func (*PubProcMetricsRequest) ProtoMessage

func (*PubProcMetricsRequest) ProtoMessage()

func (*PubProcMetricsRequest) Reset

func (m *PubProcMetricsRequest) Reset()

func (*PubProcMetricsRequest) String

func (m *PubProcMetricsRequest) String() string

type SerrorReply

type SerrorReply struct {
}

func (*SerrorReply) Descriptor

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

func (*SerrorReply) ProtoMessage

func (*SerrorReply) ProtoMessage()

func (*SerrorReply) Reset

func (m *SerrorReply) Reset()

func (*SerrorReply) String

func (m *SerrorReply) String() string

type SubscribeDepsReply

type SubscribeDepsReply struct {
	Errors []*common.SnapError `protobuf:"bytes,1,rep,name=Errors,json=errors" json:"Errors,omitempty"`
}

func (*SubscribeDepsReply) Descriptor

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

func (*SubscribeDepsReply) GetErrors

func (m *SubscribeDepsReply) GetErrors() []*common.SnapError

func (*SubscribeDepsReply) ProtoMessage

func (*SubscribeDepsReply) ProtoMessage()

func (*SubscribeDepsReply) Reset

func (m *SubscribeDepsReply) Reset()

func (*SubscribeDepsReply) String

func (m *SubscribeDepsReply) String() string

type SubscribeDepsRequest

type SubscribeDepsRequest struct {
	Requested []*common.Metric           `protobuf:"bytes,1,rep,name=Requested,json=requested" json:"Requested,omitempty"`
	Plugins   []*common.SubscribedPlugin `protobuf:"bytes,2,rep,name=Plugins,json=plugins" json:"Plugins,omitempty"`
	TaskId    string                     `protobuf:"bytes,3,opt,name=TaskId,json=taskId" json:"TaskId,omitempty"`
}

func (*SubscribeDepsRequest) Descriptor

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

func (*SubscribeDepsRequest) GetPlugins

func (m *SubscribeDepsRequest) GetPlugins() []*common.SubscribedPlugin

func (*SubscribeDepsRequest) GetRequested

func (m *SubscribeDepsRequest) GetRequested() []*common.Metric

func (*SubscribeDepsRequest) ProtoMessage

func (*SubscribeDepsRequest) ProtoMessage()

func (*SubscribeDepsRequest) Reset

func (m *SubscribeDepsRequest) Reset()

func (*SubscribeDepsRequest) String

func (m *SubscribeDepsRequest) String() string

type UnsubscribeDepsReply

type UnsubscribeDepsReply struct {
	Errors []*common.SnapError `protobuf:"bytes,1,rep,name=Errors,json=errors" json:"Errors,omitempty"`
}

func (*UnsubscribeDepsReply) Descriptor

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

func (*UnsubscribeDepsReply) GetErrors

func (m *UnsubscribeDepsReply) GetErrors() []*common.SnapError

func (*UnsubscribeDepsReply) ProtoMessage

func (*UnsubscribeDepsReply) ProtoMessage()

func (*UnsubscribeDepsReply) Reset

func (m *UnsubscribeDepsReply) Reset()

func (*UnsubscribeDepsReply) String

func (m *UnsubscribeDepsReply) String() string

type UnsubscribeDepsRequest

type UnsubscribeDepsRequest struct {
	TaskId string `protobuf:"bytes,1,opt,name=TaskId,json=taskId" json:"TaskId,omitempty"`
}

func (*UnsubscribeDepsRequest) Descriptor

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

func (*UnsubscribeDepsRequest) ProtoMessage

func (*UnsubscribeDepsRequest) ProtoMessage()

func (*UnsubscribeDepsRequest) Reset

func (m *UnsubscribeDepsRequest) Reset()

func (*UnsubscribeDepsRequest) String

func (m *UnsubscribeDepsRequest) String() string

type ValidateDepsReply

type ValidateDepsReply struct {
	Errors []*common.SnapError `protobuf:"bytes,1,rep,name=Errors,json=errors" json:"Errors,omitempty"`
}

func (*ValidateDepsReply) Descriptor

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

func (*ValidateDepsReply) GetErrors

func (m *ValidateDepsReply) GetErrors() []*common.SnapError

func (*ValidateDepsReply) ProtoMessage

func (*ValidateDepsReply) ProtoMessage()

func (*ValidateDepsReply) Reset

func (m *ValidateDepsReply) Reset()

func (*ValidateDepsReply) String

func (m *ValidateDepsReply) String() string

type ValidateDepsRequest

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

func (*ValidateDepsRequest) Descriptor

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

func (*ValidateDepsRequest) GetMetrics

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

func (*ValidateDepsRequest) GetPlugins

func (m *ValidateDepsRequest) GetPlugins() []*common.SubscribedPlugin

func (*ValidateDepsRequest) ProtoMessage

func (*ValidateDepsRequest) ProtoMessage()

func (*ValidateDepsRequest) Reset

func (m *ValidateDepsRequest) Reset()

func (*ValidateDepsRequest) String

func (m *ValidateDepsRequest) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL