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

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
GetPluginContentTypesRequest
GetPluginContentTypesReply
ValidateDepsRequest
ValidateDepsReply
SubscribeDepsRequest
SubscribeDepsReply
Map
MapEntry
CollectMetricsRequest
CollectMetricsResponse
ExpandWildcardsRequest
ArrString
ExpandWildcardsReply
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,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,omitempty"`
	Metrics  []*common.Metric `protobuf:"bytes,2,rep,name=Metrics" json:"Metrics,omitempty"`
	Deadline *common.Time     `protobuf:"bytes,3,opt,name=Deadline" json:"Deadline,omitempty"`
	AllTags  map[string]*Map  `` /* 134-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) GetDeadline 

func (m *CollectMetricsRequest) GetDeadline() *common.Time

func (*CollectMetricsRequest) GetMetrics 

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

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,omitempty"`
	Errors  []string         `protobuf:"bytes,2,rep,name=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,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 ExpandWildcardsReply 

type ExpandWildcardsReply struct {
	NSS   []*ArrString      `protobuf:"bytes,1,rep,name=NSS" json:"NSS,omitempty"`
	Error *common.SnapError `protobuf:"bytes,2,opt,name=Error" json:"Error,omitempty"`
}

func (*ExpandWildcardsReply) Descriptor 

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

func (*ExpandWildcardsReply) GetError 

func (m *ExpandWildcardsReply) GetError() *common.SnapError

func (*ExpandWildcardsReply) GetNSS 

func (m *ExpandWildcardsReply) GetNSS() []*ArrString

func (*ExpandWildcardsReply) ProtoMessage 

func (*ExpandWildcardsReply) ProtoMessage()

func (*ExpandWildcardsReply) Reset 

func (m *ExpandWildcardsReply) Reset()

func (*ExpandWildcardsReply) String 

func (m *ExpandWildcardsReply) String() string

type ExpandWildcardsRequest 

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

func (*ExpandWildcardsRequest) Descriptor 

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

func (*ExpandWildcardsRequest) GetNamespace 

func (m *ExpandWildcardsRequest) GetNamespace() []*common.NamespaceElement

func (*ExpandWildcardsRequest) ProtoMessage 

func (*ExpandWildcardsRequest) ProtoMessage()

func (*ExpandWildcardsRequest) Reset 

func (m *ExpandWildcardsRequest) Reset()

func (*ExpandWildcardsRequest) String 

func (m *ExpandWildcardsRequest) String() string

type GetAutodiscoverPathsReply 

type GetAutodiscoverPathsReply struct {
	Paths []string `protobuf:"bytes,1,rep,name=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 GetPluginContentTypesReply 

type GetPluginContentTypesReply struct {
	AcceptedTypes []string `protobuf:"bytes,1,rep,name=AcceptedTypes" json:"AcceptedTypes,omitempty"`
	ReturnedTypes []string `protobuf:"bytes,2,rep,name=ReturnedTypes" json:"ReturnedTypes,omitempty"`
	Error         string   `protobuf:"bytes,3,opt,name=Error" json:"Error,omitempty"`
}

func (*GetPluginContentTypesReply) Descriptor 

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

func (*GetPluginContentTypesReply) ProtoMessage 

func (*GetPluginContentTypesReply) ProtoMessage()

func (*GetPluginContentTypesReply) Reset 

func (m *GetPluginContentTypesReply) Reset()

func (*GetPluginContentTypesReply) String 

func (m *GetPluginContentTypesReply) String() string

type GetPluginContentTypesRequest 

type GetPluginContentTypesRequest struct {
	Name       string `protobuf:"bytes,1,opt,name=Name" json:"Name,omitempty"`
	PluginType int32  `protobuf:"varint,2,opt,name=PluginType" json:"PluginType,omitempty"`
	Version    int32  `protobuf:"varint,3,opt,name=Version" json:"Version,omitempty"`
}

func (*GetPluginContentTypesRequest) Descriptor 

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

func (*GetPluginContentTypesRequest) ProtoMessage 

func (*GetPluginContentTypesRequest) ProtoMessage()

func (*GetPluginContentTypesRequest) Reset 

func (m *GetPluginContentTypesRequest) Reset()

func (*GetPluginContentTypesRequest) String 

func (m *GetPluginContentTypesRequest) 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,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,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=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
	GetPluginContentTypes(ctx context.Context, in *GetPluginContentTypesRequest, opts ...grpc.CallOption) (*GetPluginContentTypesReply, error)
	ExpandWildcards(ctx context.Context, in *ExpandWildcardsRequest, opts ...grpc.CallOption) (*ExpandWildcardsReply, error)
	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 *SubscribeDepsRequest, opts ...grpc.CallOption) (*SubscribeDepsReply, error)
	MatchQueryToNamespaces(ctx context.Context, in *ExpandWildcardsRequest, opts ...grpc.CallOption) (*ExpandWildcardsReply, 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
	GetPluginContentTypes(context.Context, *GetPluginContentTypesRequest) (*GetPluginContentTypesReply, error)
	ExpandWildcards(context.Context, *ExpandWildcardsRequest) (*ExpandWildcardsReply, error)
	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, *SubscribeDepsRequest) (*SubscribeDepsReply, error)
	MatchQueryToNamespaces(context.Context, *ExpandWildcardsRequest) (*ExpandWildcardsReply, error)
	GetAutodiscoverPaths(context.Context, *common.Empty) (*GetAutodiscoverPathsReply, error)
}

type ProcessMetricsReply 

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

func (*ProcessMetricsReply) Descriptor 

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

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 {
	ContentType   string            `protobuf:"bytes,1,opt,name=ContentType" json:"ContentType,omitempty"`
	Content       []byte            `protobuf:"bytes,2,opt,name=Content,proto3" json:"Content,omitempty"`
	PluginName    string            `protobuf:"bytes,3,opt,name=PluginName" json:"PluginName,omitempty"`
	PluginVersion int64             `protobuf:"varint,4,opt,name=PluginVersion" json:"PluginVersion,omitempty"`
	Config        *common.ConfigMap `protobuf:"bytes,5,opt,name=Config" json:"Config,omitempty"`
	TaskId        string            `protobuf:"bytes,6,opt,name=TaskId" json:"TaskId,omitempty"`
}

func (*PubProcMetricsRequest) Descriptor 

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

func (*PubProcMetricsRequest) GetConfig 

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

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,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 {
	Metrics []*common.Metric `protobuf:"bytes,1,rep,name=Metrics" json:"Metrics,omitempty"`
	Plugins []*common.Plugin `protobuf:"bytes,2,rep,name=Plugins" json:"Plugins,omitempty"`
	TaskId  string           `protobuf:"bytes,3,opt,name=TaskId" json:"TaskId,omitempty"`
}

func (*SubscribeDepsRequest) Descriptor 

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

func (*SubscribeDepsRequest) GetMetrics 

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

func (*SubscribeDepsRequest) GetPlugins 

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

func (*SubscribeDepsRequest) ProtoMessage 

func (*SubscribeDepsRequest) ProtoMessage()

func (*SubscribeDepsRequest) Reset 

func (m *SubscribeDepsRequest) Reset()

func (*SubscribeDepsRequest) String 

func (m *SubscribeDepsRequest) String() string

type ValidateDepsReply 

type ValidateDepsReply struct {
	Errors []*common.SnapError `protobuf:"bytes,1,rep,name=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,omitempty"`
	Plugins []*common.SubscribedPlugin `protobuf:"bytes,2,rep,name=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.