Documentation
¶
Index ¶
- Variables
- func RegisterGenericManagerServer(s *grpc.Server, srv GenericManagerServer)
- type CapabilitiesRequest
- func (*CapabilitiesRequest) Descriptor() ([]byte, []int)
- func (*CapabilitiesRequest) ProtoMessage()
- func (m *CapabilitiesRequest) Reset()
- func (m *CapabilitiesRequest) String() string
- func (m *CapabilitiesRequest) XXX_DiscardUnknown()
- func (m *CapabilitiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CapabilitiesRequest) XXX_Merge(src proto.Message)
- func (m *CapabilitiesRequest) XXX_Size() int
- func (m *CapabilitiesRequest) XXX_Unmarshal(b []byte) error
- type CapabilitiesResponse
- func (*CapabilitiesResponse) Descriptor() ([]byte, []int)
- func (m *CapabilitiesResponse) GetActiveModules() []string
- func (m *CapabilitiesResponse) GetKnownModels() []*ModelInfo
- func (*CapabilitiesResponse) ProtoMessage()
- func (m *CapabilitiesResponse) Reset()
- func (m *CapabilitiesResponse) String() string
- func (m *CapabilitiesResponse) XXX_DiscardUnknown()
- func (m *CapabilitiesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CapabilitiesResponse) XXX_Merge(src proto.Message)
- func (m *CapabilitiesResponse) XXX_Size() int
- func (m *CapabilitiesResponse) XXX_Unmarshal(b []byte) error
- type ConfigItem
- func (*ConfigItem) Descriptor() ([]byte, []int)
- func (m *ConfigItem) GetItem() *Item
- func (m *ConfigItem) GetLabels() map[string]string
- func (m *ConfigItem) GetStatus() *ItemStatus
- func (*ConfigItem) ProtoMessage()
- func (m *ConfigItem) Reset()
- func (m *ConfigItem) String() string
- func (m *ConfigItem) XXX_DiscardUnknown()
- func (m *ConfigItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConfigItem) XXX_Merge(src proto.Message)
- func (m *ConfigItem) XXX_Size() int
- func (m *ConfigItem) XXX_Unmarshal(b []byte) error
- type Data
- func (*Data) Descriptor() ([]byte, []int)
- func (m *Data) GetAny() *types.Any
- func (*Data) ProtoMessage()
- func (m *Data) Reset()
- func (m *Data) String() string
- func (m *Data) XXX_DiscardUnknown()
- func (m *Data) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Data) XXX_Merge(src proto.Message)
- func (m *Data) XXX_Size() int
- func (m *Data) XXX_Unmarshal(b []byte) error
- type DumpStateRequest
- func (*DumpStateRequest) Descriptor() ([]byte, []int)
- func (m *DumpStateRequest) GetIds() []*Item_ID
- func (*DumpStateRequest) ProtoMessage()
- func (m *DumpStateRequest) Reset()
- func (m *DumpStateRequest) String() string
- func (m *DumpStateRequest) XXX_DiscardUnknown()
- func (m *DumpStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DumpStateRequest) XXX_Merge(src proto.Message)
- func (m *DumpStateRequest) XXX_Size() int
- func (m *DumpStateRequest) XXX_Unmarshal(b []byte) error
- type DumpStateResponse
- func (*DumpStateResponse) Descriptor() ([]byte, []int)
- func (m *DumpStateResponse) GetItems() []*StateItem
- func (*DumpStateResponse) ProtoMessage()
- func (m *DumpStateResponse) Reset()
- func (m *DumpStateResponse) String() string
- func (m *DumpStateResponse) XXX_DiscardUnknown()
- func (m *DumpStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DumpStateResponse) XXX_Merge(src proto.Message)
- func (m *DumpStateResponse) XXX_Size() int
- func (m *DumpStateResponse) XXX_Unmarshal(b []byte) error
- type GenericManagerClient
- type GenericManagerServer
- type GenericManager_SubscribeClient
- type GenericManager_SubscribeServer
- type GetConfigRequest
- func (*GetConfigRequest) Descriptor() ([]byte, []int)
- func (m *GetConfigRequest) GetIds() []*Item_ID
- func (*GetConfigRequest) ProtoMessage()
- func (m *GetConfigRequest) Reset()
- func (m *GetConfigRequest) String() string
- func (m *GetConfigRequest) XXX_DiscardUnknown()
- func (m *GetConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetConfigRequest) XXX_Merge(src proto.Message)
- func (m *GetConfigRequest) XXX_Size() int
- func (m *GetConfigRequest) XXX_Unmarshal(b []byte) error
- type GetConfigResponse
- func (*GetConfigResponse) Descriptor() ([]byte, []int)
- func (m *GetConfigResponse) GetItems() []*ConfigItem
- func (*GetConfigResponse) ProtoMessage()
- func (m *GetConfigResponse) Reset()
- func (m *GetConfigResponse) String() string
- func (m *GetConfigResponse) XXX_DiscardUnknown()
- func (m *GetConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetConfigResponse) XXX_Merge(src proto.Message)
- func (m *GetConfigResponse) XXX_Size() int
- func (m *GetConfigResponse) XXX_Unmarshal(b []byte) error
- type Item
- func (*Item) Descriptor() ([]byte, []int)
- func (m *Item) GetData() *Data
- func (m *Item) GetId() *Item_ID
- func (*Item) ProtoMessage()
- func (m *Item) Reset()
- func (m *Item) String() string
- func (m *Item) XXX_DiscardUnknown()
- func (m *Item) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Item) XXX_Merge(src proto.Message)
- func (m *Item) XXX_Size() int
- func (m *Item) XXX_Unmarshal(b []byte) error
- type ItemStatus
- func (*ItemStatus) Descriptor() ([]byte, []int)
- func (m *ItemStatus) GetMessage() string
- func (m *ItemStatus) GetStatus() string
- func (*ItemStatus) ProtoMessage()
- func (m *ItemStatus) Reset()
- func (m *ItemStatus) String() string
- func (m *ItemStatus) XXX_DiscardUnknown()
- func (m *ItemStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ItemStatus) XXX_Merge(src proto.Message)
- func (m *ItemStatus) XXX_Size() int
- func (m *ItemStatus) XXX_Unmarshal(b []byte) error
- type Item_ID
- func (*Item_ID) Descriptor() ([]byte, []int)
- func (m *Item_ID) GetModel() *Model
- func (m *Item_ID) GetName() string
- func (*Item_ID) ProtoMessage()
- func (m *Item_ID) Reset()
- func (m *Item_ID) String() string
- func (m *Item_ID) XXX_DiscardUnknown()
- func (m *Item_ID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Item_ID) XXX_Merge(src proto.Message)
- func (m *Item_ID) XXX_Size() int
- func (m *Item_ID) XXX_Unmarshal(b []byte) error
- type Model
- func (*Model) Descriptor() ([]byte, []int)
- func (m *Model) GetModule() string
- func (m *Model) GetType() string
- func (m *Model) GetVersion() string
- func (*Model) ProtoMessage()
- func (m *Model) Reset()
- func (m *Model) String() string
- func (m *Model) XXX_DiscardUnknown()
- func (m *Model) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Model) XXX_Merge(src proto.Message)
- func (m *Model) XXX_Size() int
- func (m *Model) XXX_Unmarshal(b []byte) error
- type ModelInfo
- func (*ModelInfo) Descriptor() ([]byte, []int)
- func (m *ModelInfo) GetInfo() map[string]string
- func (m *ModelInfo) GetModel() *Model
- func (*ModelInfo) ProtoMessage()
- func (m *ModelInfo) Reset()
- func (m *ModelInfo) String() string
- func (m *ModelInfo) XXX_DiscardUnknown()
- func (m *ModelInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ModelInfo) XXX_Merge(src proto.Message)
- func (m *ModelInfo) XXX_Size() int
- func (m *ModelInfo) XXX_Unmarshal(b []byte) error
- type Notification
- func (*Notification) Descriptor() ([]byte, []int)
- func (m *Notification) GetItem() *Item
- func (m *Notification) GetStatus() *ItemStatus
- func (*Notification) ProtoMessage()
- func (m *Notification) Reset()
- func (m *Notification) String() string
- func (m *Notification) XXX_DiscardUnknown()
- func (m *Notification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Notification) XXX_Merge(src proto.Message)
- func (m *Notification) XXX_Size() int
- func (m *Notification) XXX_Unmarshal(b []byte) error
- type SetConfigRequest
- func (*SetConfigRequest) Descriptor() ([]byte, []int)
- func (m *SetConfigRequest) GetOverwriteAll() bool
- func (m *SetConfigRequest) GetUpdates() []*UpdateItem
- func (*SetConfigRequest) ProtoMessage()
- func (m *SetConfigRequest) Reset()
- func (m *SetConfigRequest) String() string
- func (m *SetConfigRequest) XXX_DiscardUnknown()
- func (m *SetConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetConfigRequest) XXX_Merge(src proto.Message)
- func (m *SetConfigRequest) XXX_Size() int
- func (m *SetConfigRequest) XXX_Unmarshal(b []byte) error
- type SetConfigResponse
- func (*SetConfigResponse) Descriptor() ([]byte, []int)
- func (m *SetConfigResponse) GetResults() []*UpdateResult
- func (*SetConfigResponse) ProtoMessage()
- func (m *SetConfigResponse) Reset()
- func (m *SetConfigResponse) String() string
- func (m *SetConfigResponse) XXX_DiscardUnknown()
- func (m *SetConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetConfigResponse) XXX_Merge(src proto.Message)
- func (m *SetConfigResponse) XXX_Size() int
- func (m *SetConfigResponse) XXX_Unmarshal(b []byte) error
- type StateItem
- func (*StateItem) Descriptor() ([]byte, []int)
- func (m *StateItem) GetItem() *Item
- func (m *StateItem) GetMetadata() map[string]string
- func (*StateItem) ProtoMessage()
- func (m *StateItem) Reset()
- func (m *StateItem) String() string
- func (m *StateItem) XXX_DiscardUnknown()
- func (m *StateItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StateItem) XXX_Merge(src proto.Message)
- func (m *StateItem) XXX_Size() int
- func (m *StateItem) XXX_Unmarshal(b []byte) error
- type SubscribeRequest
- func (*SubscribeRequest) Descriptor() ([]byte, []int)
- func (m *SubscribeRequest) GetSubscriptions() []*Subscription
- func (*SubscribeRequest) ProtoMessage()
- func (m *SubscribeRequest) Reset()
- func (m *SubscribeRequest) String() string
- func (m *SubscribeRequest) XXX_DiscardUnknown()
- func (m *SubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SubscribeRequest) XXX_Merge(src proto.Message)
- func (m *SubscribeRequest) XXX_Size() int
- func (m *SubscribeRequest) XXX_Unmarshal(b []byte) error
- type SubscribeResponse
- func (*SubscribeResponse) Descriptor() ([]byte, []int)
- func (m *SubscribeResponse) GetNotifications() []*Notification
- func (*SubscribeResponse) ProtoMessage()
- func (m *SubscribeResponse) Reset()
- func (m *SubscribeResponse) String() string
- func (m *SubscribeResponse) XXX_DiscardUnknown()
- func (m *SubscribeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SubscribeResponse) XXX_Merge(src proto.Message)
- func (m *SubscribeResponse) XXX_Size() int
- func (m *SubscribeResponse) XXX_Unmarshal(b []byte) error
- type Subscription
- func (*Subscription) Descriptor() ([]byte, []int)
- func (m *Subscription) GetId() *Item_ID
- func (*Subscription) ProtoMessage()
- func (m *Subscription) Reset()
- func (m *Subscription) String() string
- func (m *Subscription) XXX_DiscardUnknown()
- func (m *Subscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Subscription) XXX_Merge(src proto.Message)
- func (m *Subscription) XXX_Size() int
- func (m *Subscription) XXX_Unmarshal(b []byte) error
- type UpdateItem
- func (*UpdateItem) Descriptor() ([]byte, []int)
- func (m *UpdateItem) GetItem() *Item
- func (m *UpdateItem) GetLabels() map[string]string
- func (*UpdateItem) ProtoMessage()
- func (m *UpdateItem) Reset()
- func (m *UpdateItem) String() string
- func (m *UpdateItem) XXX_DiscardUnknown()
- func (m *UpdateItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateItem) XXX_Merge(src proto.Message)
- func (m *UpdateItem) XXX_Size() int
- func (m *UpdateItem) XXX_Unmarshal(b []byte) error
- type UpdateResult
- func (*UpdateResult) Descriptor() ([]byte, []int)
- func (m *UpdateResult) GetId() *Item_ID
- func (m *UpdateResult) GetKey() string
- func (m *UpdateResult) GetOp() UpdateResult_Operation
- func (m *UpdateResult) GetStatus() *ItemStatus
- func (*UpdateResult) ProtoMessage()
- func (m *UpdateResult) Reset()
- func (m *UpdateResult) String() string
- func (m *UpdateResult) XXX_DiscardUnknown()
- func (m *UpdateResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateResult) XXX_Merge(src proto.Message)
- func (m *UpdateResult) XXX_Size() int
- func (m *UpdateResult) XXX_Unmarshal(b []byte) error
- type UpdateResult_Operation
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func RegisterGenericManagerServer ¶
func RegisterGenericManagerServer(s *grpc.Server, srv GenericManagerServer)
Types ¶
type CapabilitiesRequest ¶
type CapabilitiesRequest struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*CapabilitiesRequest) Descriptor ¶
func (*CapabilitiesRequest) Descriptor() ([]byte, []int)
func (*CapabilitiesRequest) ProtoMessage ¶
func (*CapabilitiesRequest) ProtoMessage()
func (*CapabilitiesRequest) Reset ¶
func (m *CapabilitiesRequest) Reset()
func (*CapabilitiesRequest) String ¶
func (m *CapabilitiesRequest) String() string
func (*CapabilitiesRequest) XXX_DiscardUnknown ¶
func (m *CapabilitiesRequest) XXX_DiscardUnknown()
func (*CapabilitiesRequest) XXX_Marshal ¶
func (m *CapabilitiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CapabilitiesRequest) XXX_Merge ¶
func (m *CapabilitiesRequest) XXX_Merge(src proto.Message)
func (*CapabilitiesRequest) XXX_Size ¶
func (m *CapabilitiesRequest) XXX_Size() int
func (*CapabilitiesRequest) XXX_Unmarshal ¶
func (m *CapabilitiesRequest) XXX_Unmarshal(b []byte) error
type CapabilitiesResponse ¶
type CapabilitiesResponse struct {
KnownModels []*ModelInfo `protobuf:"bytes,1,rep,name=known_models,json=knownModels,proto3" json:"known_models,omitempty"`
ActiveModules []string `protobuf:"bytes,2,rep,name=active_modules,json=activeModules,proto3" json:"active_modules,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*CapabilitiesResponse) Descriptor ¶
func (*CapabilitiesResponse) Descriptor() ([]byte, []int)
func (*CapabilitiesResponse) GetActiveModules ¶
func (m *CapabilitiesResponse) GetActiveModules() []string
func (*CapabilitiesResponse) GetKnownModels ¶
func (m *CapabilitiesResponse) GetKnownModels() []*ModelInfo
func (*CapabilitiesResponse) ProtoMessage ¶
func (*CapabilitiesResponse) ProtoMessage()
func (*CapabilitiesResponse) Reset ¶
func (m *CapabilitiesResponse) Reset()
func (*CapabilitiesResponse) String ¶
func (m *CapabilitiesResponse) String() string
func (*CapabilitiesResponse) XXX_DiscardUnknown ¶
func (m *CapabilitiesResponse) XXX_DiscardUnknown()
func (*CapabilitiesResponse) XXX_Marshal ¶
func (m *CapabilitiesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CapabilitiesResponse) XXX_Merge ¶
func (m *CapabilitiesResponse) XXX_Merge(src proto.Message)
func (*CapabilitiesResponse) XXX_Size ¶
func (m *CapabilitiesResponse) XXX_Size() int
func (*CapabilitiesResponse) XXX_Unmarshal ¶
func (m *CapabilitiesResponse) XXX_Unmarshal(b []byte) error
type ConfigItem ¶
type ConfigItem struct {
Item *Item `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
Status *ItemStatus `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
Labels map[string]string `` /* 153-byte string literal not displayed */
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ConfigItem) Descriptor ¶
func (*ConfigItem) Descriptor() ([]byte, []int)
func (*ConfigItem) GetItem ¶
func (m *ConfigItem) GetItem() *Item
func (*ConfigItem) GetLabels ¶
func (m *ConfigItem) GetLabels() map[string]string
func (*ConfigItem) GetStatus ¶
func (m *ConfigItem) GetStatus() *ItemStatus
func (*ConfigItem) ProtoMessage ¶
func (*ConfigItem) ProtoMessage()
func (*ConfigItem) Reset ¶
func (m *ConfigItem) Reset()
func (*ConfigItem) String ¶
func (m *ConfigItem) String() string
func (*ConfigItem) XXX_DiscardUnknown ¶
func (m *ConfigItem) XXX_DiscardUnknown()
func (*ConfigItem) XXX_Marshal ¶
func (m *ConfigItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConfigItem) XXX_Merge ¶
func (m *ConfigItem) XXX_Merge(src proto.Message)
func (*ConfigItem) XXX_Size ¶
func (m *ConfigItem) XXX_Size() int
func (*ConfigItem) XXX_Unmarshal ¶
func (m *ConfigItem) XXX_Unmarshal(b []byte) error
type Data ¶
type Data struct {
Any *types.Any `protobuf:"bytes,1,opt,name=any,proto3" json:"any,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Data represents encoded data for an item.
type DumpStateRequest ¶
type DumpStateRequest struct {
Ids []*Item_ID `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*DumpStateRequest) Descriptor ¶
func (*DumpStateRequest) Descriptor() ([]byte, []int)
func (*DumpStateRequest) GetIds ¶
func (m *DumpStateRequest) GetIds() []*Item_ID
func (*DumpStateRequest) ProtoMessage ¶
func (*DumpStateRequest) ProtoMessage()
func (*DumpStateRequest) Reset ¶
func (m *DumpStateRequest) Reset()
func (*DumpStateRequest) String ¶
func (m *DumpStateRequest) String() string
func (*DumpStateRequest) XXX_DiscardUnknown ¶
func (m *DumpStateRequest) XXX_DiscardUnknown()
func (*DumpStateRequest) XXX_Marshal ¶
func (m *DumpStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DumpStateRequest) XXX_Merge ¶
func (m *DumpStateRequest) XXX_Merge(src proto.Message)
func (*DumpStateRequest) XXX_Size ¶
func (m *DumpStateRequest) XXX_Size() int
func (*DumpStateRequest) XXX_Unmarshal ¶
func (m *DumpStateRequest) XXX_Unmarshal(b []byte) error
type DumpStateResponse ¶
type DumpStateResponse struct {
Items []*StateItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*DumpStateResponse) Descriptor ¶
func (*DumpStateResponse) Descriptor() ([]byte, []int)
func (*DumpStateResponse) GetItems ¶
func (m *DumpStateResponse) GetItems() []*StateItem
func (*DumpStateResponse) ProtoMessage ¶
func (*DumpStateResponse) ProtoMessage()
func (*DumpStateResponse) Reset ¶
func (m *DumpStateResponse) Reset()
func (*DumpStateResponse) String ¶
func (m *DumpStateResponse) String() string
func (*DumpStateResponse) XXX_DiscardUnknown ¶
func (m *DumpStateResponse) XXX_DiscardUnknown()
func (*DumpStateResponse) XXX_Marshal ¶
func (m *DumpStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DumpStateResponse) XXX_Merge ¶
func (m *DumpStateResponse) XXX_Merge(src proto.Message)
func (*DumpStateResponse) XXX_Size ¶
func (m *DumpStateResponse) XXX_Size() int
func (*DumpStateResponse) XXX_Unmarshal ¶
func (m *DumpStateResponse) XXX_Unmarshal(b []byte) error
type GenericManagerClient ¶
type GenericManagerClient interface {
// Capabilities returns information about service capabilities
// including list of models supported by the server.
Capabilities(ctx context.Context, in *CapabilitiesRequest, opts ...grpc.CallOption) (*CapabilitiesResponse, error)
// SetConfig is used to update desired configuration.
SetConfig(ctx context.Context, in *SetConfigRequest, opts ...grpc.CallOption) (*SetConfigResponse, error)
// GetConfig is used to read the desired configuration.
GetConfig(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*GetConfigResponse, error)
// DumpState is used to retrieve the actual running state.
DumpState(ctx context.Context, in *DumpStateRequest, opts ...grpc.CallOption) (*DumpStateResponse, error)
// Subscribe is used for subscribing to events.
// Notifications are returned by streaming updates.
Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (GenericManager_SubscribeClient, error)
}
GenericManagerClient is the client API for GenericManager service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewGenericManagerClient ¶
func NewGenericManagerClient(cc *grpc.ClientConn) GenericManagerClient
type GenericManagerServer ¶
type GenericManagerServer interface {
// Capabilities returns information about service capabilities
// including list of models supported by the server.
Capabilities(context.Context, *CapabilitiesRequest) (*CapabilitiesResponse, error)
// SetConfig is used to update desired configuration.
SetConfig(context.Context, *SetConfigRequest) (*SetConfigResponse, error)
// GetConfig is used to read the desired configuration.
GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
// DumpState is used to retrieve the actual running state.
DumpState(context.Context, *DumpStateRequest) (*DumpStateResponse, error)
// Subscribe is used for subscribing to events.
// Notifications are returned by streaming updates.
Subscribe(*SubscribeRequest, GenericManager_SubscribeServer) error
}
GenericManagerServer is the server API for GenericManager service.
type GenericManager_SubscribeClient ¶
type GenericManager_SubscribeClient interface {
Recv() (*SubscribeResponse, error)
grpc.ClientStream
}
type GenericManager_SubscribeServer ¶
type GenericManager_SubscribeServer interface {
Send(*SubscribeResponse) error
grpc.ServerStream
}
type GetConfigRequest ¶
type GetConfigRequest struct {
Ids []*Item_ID `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*GetConfigRequest) Descriptor ¶
func (*GetConfigRequest) Descriptor() ([]byte, []int)
func (*GetConfigRequest) GetIds ¶
func (m *GetConfigRequest) GetIds() []*Item_ID
func (*GetConfigRequest) ProtoMessage ¶
func (*GetConfigRequest) ProtoMessage()
func (*GetConfigRequest) Reset ¶
func (m *GetConfigRequest) Reset()
func (*GetConfigRequest) String ¶
func (m *GetConfigRequest) String() string
func (*GetConfigRequest) XXX_DiscardUnknown ¶
func (m *GetConfigRequest) XXX_DiscardUnknown()
func (*GetConfigRequest) XXX_Marshal ¶
func (m *GetConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetConfigRequest) XXX_Merge ¶
func (m *GetConfigRequest) XXX_Merge(src proto.Message)
func (*GetConfigRequest) XXX_Size ¶
func (m *GetConfigRequest) XXX_Size() int
func (*GetConfigRequest) XXX_Unmarshal ¶
func (m *GetConfigRequest) XXX_Unmarshal(b []byte) error
type GetConfigResponse ¶
type GetConfigResponse struct {
Items []*ConfigItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*GetConfigResponse) Descriptor ¶
func (*GetConfigResponse) Descriptor() ([]byte, []int)
func (*GetConfigResponse) GetItems ¶
func (m *GetConfigResponse) GetItems() []*ConfigItem
func (*GetConfigResponse) ProtoMessage ¶
func (*GetConfigResponse) ProtoMessage()
func (*GetConfigResponse) Reset ¶
func (m *GetConfigResponse) Reset()
func (*GetConfigResponse) String ¶
func (m *GetConfigResponse) String() string
func (*GetConfigResponse) XXX_DiscardUnknown ¶
func (m *GetConfigResponse) XXX_DiscardUnknown()
func (*GetConfigResponse) XXX_Marshal ¶
func (m *GetConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetConfigResponse) XXX_Merge ¶
func (m *GetConfigResponse) XXX_Merge(src proto.Message)
func (*GetConfigResponse) XXX_Size ¶
func (m *GetConfigResponse) XXX_Size() int
func (*GetConfigResponse) XXX_Unmarshal ¶
func (m *GetConfigResponse) XXX_Unmarshal(b []byte) error
type Item ¶
type Item struct {
Id *Item_ID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Data *Data `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Item represents single instance described by the Model.
type ItemStatus ¶
type ItemStatus struct {
Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Item status describes status of an item.
func (*ItemStatus) Descriptor ¶
func (*ItemStatus) Descriptor() ([]byte, []int)
func (*ItemStatus) GetMessage ¶
func (m *ItemStatus) GetMessage() string
func (*ItemStatus) GetStatus ¶
func (m *ItemStatus) GetStatus() string
func (*ItemStatus) ProtoMessage ¶
func (*ItemStatus) ProtoMessage()
func (*ItemStatus) Reset ¶
func (m *ItemStatus) Reset()
func (*ItemStatus) String ¶
func (m *ItemStatus) String() string
func (*ItemStatus) XXX_DiscardUnknown ¶
func (m *ItemStatus) XXX_DiscardUnknown()
func (*ItemStatus) XXX_Marshal ¶
func (m *ItemStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ItemStatus) XXX_Merge ¶
func (m *ItemStatus) XXX_Merge(src proto.Message)
func (*ItemStatus) XXX_Size ¶
func (m *ItemStatus) XXX_Size() int
func (*ItemStatus) XXX_Unmarshal ¶
func (m *ItemStatus) XXX_Unmarshal(b []byte) error
type Item_ID ¶
type Item_ID struct {
Model *Model `protobuf:"bytes,1,opt,name=model,proto3" json:"model,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
ID represents identifier for distinguishing items.
func (*Item_ID) XXX_Marshal ¶
type Model ¶
type Model struct {
// Module describes group of the model.
Module string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
// Version describes concrete version of the model schema.
Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
// Type describes name of type described by this model.
Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Model represents a model description to for recognizing different item types.
func (*Model) XXX_Marshal ¶
type ModelInfo ¶
type ModelInfo struct {
Model *Model `protobuf:"bytes,1,opt,name=model,proto3" json:"model,omitempty"`
Info map[string]string `` /* 149-byte string literal not displayed */
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ModelInfo) XXX_Marshal ¶
type Notification ¶
type Notification struct {
Item *Item `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
Status *ItemStatus `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Notification) Descriptor ¶
func (*Notification) Descriptor() ([]byte, []int)
func (*Notification) GetItem ¶
func (m *Notification) GetItem() *Item
func (*Notification) GetStatus ¶
func (m *Notification) GetStatus() *ItemStatus
func (*Notification) ProtoMessage ¶
func (*Notification) ProtoMessage()
func (*Notification) Reset ¶
func (m *Notification) Reset()
func (*Notification) String ¶
func (m *Notification) String() string
func (*Notification) XXX_DiscardUnknown ¶
func (m *Notification) XXX_DiscardUnknown()
func (*Notification) XXX_Marshal ¶
func (m *Notification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Notification) XXX_Merge ¶
func (m *Notification) XXX_Merge(src proto.Message)
func (*Notification) XXX_Size ¶
func (m *Notification) XXX_Size() int
func (*Notification) XXX_Unmarshal ¶
func (m *Notification) XXX_Unmarshal(b []byte) error
type SetConfigRequest ¶
type SetConfigRequest struct {
Updates []*UpdateItem `protobuf:"bytes,1,rep,name=updates,proto3" json:"updates,omitempty"`
// The overwrite_all can be set to true to overwrite all other configuration
// (this is also known as Full Resync)
OverwriteAll bool `protobuf:"varint,2,opt,name=overwrite_all,json=overwriteAll,proto3" json:"overwrite_all,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*SetConfigRequest) Descriptor ¶
func (*SetConfigRequest) Descriptor() ([]byte, []int)
func (*SetConfigRequest) GetOverwriteAll ¶
func (m *SetConfigRequest) GetOverwriteAll() bool
func (*SetConfigRequest) GetUpdates ¶
func (m *SetConfigRequest) GetUpdates() []*UpdateItem
func (*SetConfigRequest) ProtoMessage ¶
func (*SetConfigRequest) ProtoMessage()
func (*SetConfigRequest) Reset ¶
func (m *SetConfigRequest) Reset()
func (*SetConfigRequest) String ¶
func (m *SetConfigRequest) String() string
func (*SetConfigRequest) XXX_DiscardUnknown ¶
func (m *SetConfigRequest) XXX_DiscardUnknown()
func (*SetConfigRequest) XXX_Marshal ¶
func (m *SetConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetConfigRequest) XXX_Merge ¶
func (m *SetConfigRequest) XXX_Merge(src proto.Message)
func (*SetConfigRequest) XXX_Size ¶
func (m *SetConfigRequest) XXX_Size() int
func (*SetConfigRequest) XXX_Unmarshal ¶
func (m *SetConfigRequest) XXX_Unmarshal(b []byte) error
type SetConfigResponse ¶
type SetConfigResponse struct {
Results []*UpdateResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*SetConfigResponse) Descriptor ¶
func (*SetConfigResponse) Descriptor() ([]byte, []int)
func (*SetConfigResponse) GetResults ¶
func (m *SetConfigResponse) GetResults() []*UpdateResult
func (*SetConfigResponse) ProtoMessage ¶
func (*SetConfigResponse) ProtoMessage()
func (*SetConfigResponse) Reset ¶
func (m *SetConfigResponse) Reset()
func (*SetConfigResponse) String ¶
func (m *SetConfigResponse) String() string
func (*SetConfigResponse) XXX_DiscardUnknown ¶
func (m *SetConfigResponse) XXX_DiscardUnknown()
func (*SetConfigResponse) XXX_Marshal ¶
func (m *SetConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetConfigResponse) XXX_Merge ¶
func (m *SetConfigResponse) XXX_Merge(src proto.Message)
func (*SetConfigResponse) XXX_Size ¶
func (m *SetConfigResponse) XXX_Size() int
func (*SetConfigResponse) XXX_Unmarshal ¶
func (m *SetConfigResponse) XXX_Unmarshal(b []byte) error
type StateItem ¶
type StateItem struct {
Item *Item `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
Metadata map[string]string `` /* 157-byte string literal not displayed */
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*StateItem) XXX_Marshal ¶
type SubscribeRequest ¶
type SubscribeRequest struct {
Subscriptions []*Subscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*SubscribeRequest) Descriptor ¶
func (*SubscribeRequest) Descriptor() ([]byte, []int)
func (*SubscribeRequest) GetSubscriptions ¶
func (m *SubscribeRequest) GetSubscriptions() []*Subscription
func (*SubscribeRequest) ProtoMessage ¶
func (*SubscribeRequest) ProtoMessage()
func (*SubscribeRequest) Reset ¶
func (m *SubscribeRequest) Reset()
func (*SubscribeRequest) String ¶
func (m *SubscribeRequest) String() string
func (*SubscribeRequest) XXX_DiscardUnknown ¶
func (m *SubscribeRequest) XXX_DiscardUnknown()
func (*SubscribeRequest) XXX_Marshal ¶
func (m *SubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SubscribeRequest) XXX_Merge ¶
func (m *SubscribeRequest) XXX_Merge(src proto.Message)
func (*SubscribeRequest) XXX_Size ¶
func (m *SubscribeRequest) XXX_Size() int
func (*SubscribeRequest) XXX_Unmarshal ¶
func (m *SubscribeRequest) XXX_Unmarshal(b []byte) error
type SubscribeResponse ¶
type SubscribeResponse struct {
Notifications []*Notification `protobuf:"bytes,1,rep,name=notifications,proto3" json:"notifications,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*SubscribeResponse) Descriptor ¶
func (*SubscribeResponse) Descriptor() ([]byte, []int)
func (*SubscribeResponse) GetNotifications ¶
func (m *SubscribeResponse) GetNotifications() []*Notification
func (*SubscribeResponse) ProtoMessage ¶
func (*SubscribeResponse) ProtoMessage()
func (*SubscribeResponse) Reset ¶
func (m *SubscribeResponse) Reset()
func (*SubscribeResponse) String ¶
func (m *SubscribeResponse) String() string
func (*SubscribeResponse) XXX_DiscardUnknown ¶
func (m *SubscribeResponse) XXX_DiscardUnknown()
func (*SubscribeResponse) XXX_Marshal ¶
func (m *SubscribeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SubscribeResponse) XXX_Merge ¶
func (m *SubscribeResponse) XXX_Merge(src proto.Message)
func (*SubscribeResponse) XXX_Size ¶
func (m *SubscribeResponse) XXX_Size() int
func (*SubscribeResponse) XXX_Unmarshal ¶
func (m *SubscribeResponse) XXX_Unmarshal(b []byte) error
type Subscription ¶
type Subscription struct {
Id *Item_ID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Subscription) Descriptor ¶
func (*Subscription) Descriptor() ([]byte, []int)
func (*Subscription) GetId ¶
func (m *Subscription) GetId() *Item_ID
func (*Subscription) ProtoMessage ¶
func (*Subscription) ProtoMessage()
func (*Subscription) Reset ¶
func (m *Subscription) Reset()
func (*Subscription) String ¶
func (m *Subscription) String() string
func (*Subscription) XXX_DiscardUnknown ¶
func (m *Subscription) XXX_DiscardUnknown()
func (*Subscription) XXX_Marshal ¶
func (m *Subscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Subscription) XXX_Merge ¶
func (m *Subscription) XXX_Merge(src proto.Message)
func (*Subscription) XXX_Size ¶
func (m *Subscription) XXX_Size() int
func (*Subscription) XXX_Unmarshal ¶
func (m *Subscription) XXX_Unmarshal(b []byte) error
type UpdateItem ¶
type UpdateItem struct {
// The item describes item to be updated.
// For a delete operation set fields item.Data to nil.
Item *Item `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
// The labels can be used to define user-defined labels for item.
Labels map[string]string `` /* 153-byte string literal not displayed */
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*UpdateItem) Descriptor ¶
func (*UpdateItem) Descriptor() ([]byte, []int)
func (*UpdateItem) GetItem ¶
func (m *UpdateItem) GetItem() *Item
func (*UpdateItem) GetLabels ¶
func (m *UpdateItem) GetLabels() map[string]string
func (*UpdateItem) ProtoMessage ¶
func (*UpdateItem) ProtoMessage()
func (*UpdateItem) Reset ¶
func (m *UpdateItem) Reset()
func (*UpdateItem) String ¶
func (m *UpdateItem) String() string
func (*UpdateItem) XXX_DiscardUnknown ¶
func (m *UpdateItem) XXX_DiscardUnknown()
func (*UpdateItem) XXX_Marshal ¶
func (m *UpdateItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateItem) XXX_Merge ¶
func (m *UpdateItem) XXX_Merge(src proto.Message)
func (*UpdateItem) XXX_Size ¶
func (m *UpdateItem) XXX_Size() int
func (*UpdateItem) XXX_Unmarshal ¶
func (m *UpdateItem) XXX_Unmarshal(b []byte) error
type UpdateResult ¶
type UpdateResult struct {
Id *Item_ID `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
Op UpdateResult_Operation `protobuf:"varint,2,opt,name=op,proto3,enum=genericmanager.UpdateResult_Operation" json:"op,omitempty"`
Status *ItemStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*UpdateResult) Descriptor ¶
func (*UpdateResult) Descriptor() ([]byte, []int)
func (*UpdateResult) GetId ¶
func (m *UpdateResult) GetId() *Item_ID
func (*UpdateResult) GetKey ¶
func (m *UpdateResult) GetKey() string
func (*UpdateResult) GetOp ¶
func (m *UpdateResult) GetOp() UpdateResult_Operation
func (*UpdateResult) GetStatus ¶
func (m *UpdateResult) GetStatus() *ItemStatus
func (*UpdateResult) ProtoMessage ¶
func (*UpdateResult) ProtoMessage()
func (*UpdateResult) Reset ¶
func (m *UpdateResult) Reset()
func (*UpdateResult) String ¶
func (m *UpdateResult) String() string
func (*UpdateResult) XXX_DiscardUnknown ¶
func (m *UpdateResult) XXX_DiscardUnknown()
func (*UpdateResult) XXX_Marshal ¶
func (m *UpdateResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateResult) XXX_Merge ¶
func (m *UpdateResult) XXX_Merge(src proto.Message)
func (*UpdateResult) XXX_Size ¶
func (m *UpdateResult) XXX_Size() int
func (*UpdateResult) XXX_Unmarshal ¶
func (m *UpdateResult) XXX_Unmarshal(b []byte) error
type UpdateResult_Operation ¶
type UpdateResult_Operation int32
const ( UpdateResult_UNSPECIFIED UpdateResult_Operation = 0 UpdateResult_CREATE UpdateResult_Operation = 1 UpdateResult_UPDATE UpdateResult_Operation = 2 UpdateResult_DELETE UpdateResult_Operation = 3 )
func (UpdateResult_Operation) EnumDescriptor ¶
func (UpdateResult_Operation) EnumDescriptor() ([]byte, []int)
func (UpdateResult_Operation) String ¶
func (x UpdateResult_Operation) String() string
Source Files
¶
- genericmanager.pb.go
Click to show internal directories.
Click to hide internal directories.