genericmanager

package
v2.3.0+incompatible Latest Latest
Warning

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

 Go to latest Published: Oct 7, 2019 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var UpdateResult_Operation_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "CREATE",
	2: "UPDATE",
	3: "DELETE",
}
View Source 
var UpdateResult_Operation_value = map[string]int32{
	"UNSPECIFIED": 0,
	"CREATE":      1,
	"UPDATE":      2,
	"DELETE":      3,
}

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.

func (*Data) Descriptor 

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

func (*Data) GetAny 

func (m *Data) GetAny() *types.Any

func (*Data) ProtoMessage 

func (*Data) ProtoMessage()

func (*Data) Reset 

func (m *Data) Reset()

func (*Data) String 

func (m *Data) String() string

func (*Data) XXX_DiscardUnknown 

func (m *Data) XXX_DiscardUnknown()

func (*Data) XXX_Marshal 

func (m *Data) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Data) XXX_Merge 

func (m *Data) XXX_Merge(src proto.Message)

func (*Data) XXX_Size 

func (m *Data) XXX_Size() int

func (*Data) XXX_Unmarshal 

func (m *Data) XXX_Unmarshal(b []byte) error

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.

func (*Item) Descriptor 

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

func (*Item) GetData 

func (m *Item) GetData() *Data

func (*Item) GetId 

func (m *Item) GetId() *Item_ID

func (*Item) ProtoMessage 

func (*Item) ProtoMessage()

func (*Item) Reset 

func (m *Item) Reset()

func (*Item) String 

func (m *Item) String() string

func (*Item) XXX_DiscardUnknown 

func (m *Item) XXX_DiscardUnknown()

func (*Item) XXX_Marshal 

func (m *Item) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Item) XXX_Merge 

func (m *Item) XXX_Merge(src proto.Message)

func (*Item) XXX_Size 

func (m *Item) XXX_Size() int

func (*Item) XXX_Unmarshal 

func (m *Item) XXX_Unmarshal(b []byte) error

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) Descriptor 

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

func (*Item_ID) GetModel 

func (m *Item_ID) GetModel() *Model

func (*Item_ID) GetName 

func (m *Item_ID) GetName() string

func (*Item_ID) ProtoMessage 

func (*Item_ID) ProtoMessage()

func (*Item_ID) Reset 

func (m *Item_ID) Reset()

func (*Item_ID) String 

func (m *Item_ID) String() string

func (*Item_ID) XXX_DiscardUnknown 

func (m *Item_ID) XXX_DiscardUnknown()

func (*Item_ID) XXX_Marshal 

func (m *Item_ID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Item_ID) XXX_Merge 

func (m *Item_ID) XXX_Merge(src proto.Message)

func (*Item_ID) XXX_Size 

func (m *Item_ID) XXX_Size() int

func (*Item_ID) XXX_Unmarshal 

func (m *Item_ID) XXX_Unmarshal(b []byte) error

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) Descriptor 

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

func (*Model) GetModule 

func (m *Model) GetModule() string

func (*Model) GetType 

func (m *Model) GetType() string

func (*Model) GetVersion 

func (m *Model) GetVersion() string

func (*Model) ProtoMessage 

func (*Model) ProtoMessage()

func (*Model) Reset 

func (m *Model) Reset()

func (*Model) String 

func (m *Model) String() string

func (*Model) XXX_DiscardUnknown 

func (m *Model) XXX_DiscardUnknown()

func (*Model) XXX_Marshal 

func (m *Model) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Model) XXX_Merge 

func (m *Model) XXX_Merge(src proto.Message)

func (*Model) XXX_Size 

func (m *Model) XXX_Size() int

func (*Model) XXX_Unmarshal 

func (m *Model) XXX_Unmarshal(b []byte) error

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) Descriptor 

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

func (*ModelInfo) GetInfo 

func (m *ModelInfo) GetInfo() map[string]string

func (*ModelInfo) GetModel 

func (m *ModelInfo) GetModel() *Model

func (*ModelInfo) ProtoMessage 

func (*ModelInfo) ProtoMessage()

func (*ModelInfo) Reset 

func (m *ModelInfo) Reset()

func (*ModelInfo) String 

func (m *ModelInfo) String() string

func (*ModelInfo) XXX_DiscardUnknown 

func (m *ModelInfo) XXX_DiscardUnknown()

func (*ModelInfo) XXX_Marshal 

func (m *ModelInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModelInfo) XXX_Merge 

func (m *ModelInfo) XXX_Merge(src proto.Message)

func (*ModelInfo) XXX_Size 

func (m *ModelInfo) XXX_Size() int

func (*ModelInfo) XXX_Unmarshal 

func (m *ModelInfo) XXX_Unmarshal(b []byte) error

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) Descriptor 

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

func (*StateItem) GetItem 

func (m *StateItem) GetItem() *Item

func (*StateItem) GetMetadata 

func (m *StateItem) GetMetadata() map[string]string

func (*StateItem) ProtoMessage 

func (*StateItem) ProtoMessage()

func (*StateItem) Reset 

func (m *StateItem) Reset()

func (*StateItem) String 

func (m *StateItem) String() string

func (*StateItem) XXX_DiscardUnknown 

func (m *StateItem) XXX_DiscardUnknown()

func (*StateItem) XXX_Marshal 

func (m *StateItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StateItem) XXX_Merge 

func (m *StateItem) XXX_Merge(src proto.Message)

func (*StateItem) XXX_Size 

func (m *StateItem) XXX_Size() int

func (*StateItem) XXX_Unmarshal 

func (m *StateItem) XXX_Unmarshal(b []byte) error

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

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.