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 MetricManagerServer 

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

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

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.