genericmanager

package
v2.5.1+incompatible Latest Latest
Warning

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

Go to latest
Published: Dec 6, 2019 License: Apache-2.0 Imports: 6 Imported by: 57

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 (*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

Jump to

Keyboard shortcuts

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