generic

package
v2.5.0-alpha+incompatible Latest Latest
Warning

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

 Go to latest Published: Oct 22, 2019 License: Apache-2.0 Imports: 8 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 RegisterManagerServer 

func RegisterManagerServer(s *grpc.Server, srv ManagerServer)

func RegisterMetaServiceServer 

func RegisterMetaServiceServer(s *grpc.Server, srv MetaServiceServer)

Types

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 {
	// Types that are valid to be assigned to Union:
	//	*Data_Any
	Union                isData_Union `protobuf_oneof:"union"`
	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() *any.Any

func (*Data) GetUnion 

func (m *Data) GetUnion() isData_Union

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_OneofWrappers 

func (*Data) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Data) XXX_Size 

func (m *Data) XXX_Size() int

func (*Data) XXX_Unmarshal 

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

type Data_Any 

type Data_Any struct {
	Any *any.Any `protobuf:"bytes,1,opt,name=any,proto3,oneof"`
}

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 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                string   `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() string

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 KnownModelsRequest 

type KnownModelsRequest struct {
	Class                string   `protobuf:"bytes,1,opt,name=class,proto3" json:"class,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KnownModelsRequest) Descriptor 

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

func (*KnownModelsRequest) GetClass 

func (m *KnownModelsRequest) GetClass() string

func (*KnownModelsRequest) ProtoMessage 

func (*KnownModelsRequest) ProtoMessage()

func (*KnownModelsRequest) Reset 

func (m *KnownModelsRequest) Reset()

func (*KnownModelsRequest) String 

func (m *KnownModelsRequest) String() string

func (*KnownModelsRequest) XXX_DiscardUnknown 

func (m *KnownModelsRequest) XXX_DiscardUnknown()

func (*KnownModelsRequest) XXX_Marshal 

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

func (*KnownModelsRequest) XXX_Merge 

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

func (*KnownModelsRequest) XXX_Size 

func (m *KnownModelsRequest) XXX_Size() int

func (*KnownModelsRequest) XXX_Unmarshal 

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

type KnownModelsResponse 

type KnownModelsResponse struct {
	KnownModels          []*ModelDescriptor `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 (*KnownModelsResponse) Descriptor 

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

func (*KnownModelsResponse) GetActiveModules 

func (m *KnownModelsResponse) GetActiveModules() []string

func (*KnownModelsResponse) GetKnownModels 

func (m *KnownModelsResponse) GetKnownModels() []*ModelDescriptor

func (*KnownModelsResponse) ProtoMessage 

func (*KnownModelsResponse) ProtoMessage()

func (*KnownModelsResponse) Reset 

func (m *KnownModelsResponse) Reset()

func (*KnownModelsResponse) String 

func (m *KnownModelsResponse) String() string

func (*KnownModelsResponse) XXX_DiscardUnknown 

func (m *KnownModelsResponse) XXX_DiscardUnknown()

func (*KnownModelsResponse) XXX_Marshal 

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

func (*KnownModelsResponse) XXX_Merge 

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

func (*KnownModelsResponse) XXX_Size 

func (m *KnownModelsResponse) XXX_Size() int

func (*KnownModelsResponse) XXX_Unmarshal 

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

type ManagerClient 

type ManagerClient interface {
	// 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) (Manager_SubscribeClient, error)
}

ManagerClient is the client API for Manager service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewManagerClient 

func NewManagerClient(cc *grpc.ClientConn) ManagerClient

type ManagerServer 

type ManagerServer interface {
	// 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, Manager_SubscribeServer) error
}

ManagerServer is the server API for Manager service.

type Manager_SubscribeClient 

type Manager_SubscribeClient interface {
	Recv() (*SubscribeResponse, error)
	grpc.ClientStream
}

type Manager_SubscribeServer 

type Manager_SubscribeServer interface {
	Send(*SubscribeResponse) error
	grpc.ServerStream
}

type MetaServiceClient 

type MetaServiceClient interface {
	// KnownModels returns information about service capabilities
	// including list of models supported by the server.
	KnownModels(ctx context.Context, in *KnownModelsRequest, opts ...grpc.CallOption) (*KnownModelsResponse, error)
}

MetaServiceClient is the client API for MetaService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMetaServiceClient 

func NewMetaServiceClient(cc *grpc.ClientConn) MetaServiceClient

type MetaServiceServer 

type MetaServiceServer interface {
	// KnownModels returns information about service capabilities
	// including list of models supported by the server.
	KnownModels(context.Context, *KnownModelsRequest) (*KnownModelsResponse, error)
}

MetaServiceServer is the server API for MetaService service.

type ModelDescriptor 

type ModelDescriptor struct {
	// Spec is a specificaiton the model was registered with.
	Spec *ModelSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// ProtoName is a name of protobuf message representing the model.
	ProtoName            string                    `protobuf:"bytes,2,opt,name=proto_name,json=protoName,proto3" json:"proto_name,omitempty"`
	Options              []*ModelDescriptor_Option `protobuf:"bytes,3,rep,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

ModelDescriptor defines model descriptor to describe a model.

func (*ModelDescriptor) Descriptor 

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

func (*ModelDescriptor) GetOptions 

func (m *ModelDescriptor) GetOptions() []*ModelDescriptor_Option

func (*ModelDescriptor) GetProtoName 

func (m *ModelDescriptor) GetProtoName() string

func (*ModelDescriptor) GetSpec 

func (m *ModelDescriptor) GetSpec() *ModelSpec

func (*ModelDescriptor) ProtoMessage 

func (*ModelDescriptor) ProtoMessage()

func (*ModelDescriptor) Reset 

func (m *ModelDescriptor) Reset()

func (*ModelDescriptor) String 

func (m *ModelDescriptor) String() string

func (*ModelDescriptor) XXX_DiscardUnknown 

func (m *ModelDescriptor) XXX_DiscardUnknown()

func (*ModelDescriptor) XXX_Marshal 

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

func (*ModelDescriptor) XXX_Merge 

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

func (*ModelDescriptor) XXX_Size 

func (m *ModelDescriptor) XXX_Size() int

func (*ModelDescriptor) XXX_Unmarshal 

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

type ModelDescriptor_Option 

type ModelDescriptor_Option struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values               []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ModelDescriptor_Option) Descriptor 

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

func (*ModelDescriptor_Option) GetKey 

func (m *ModelDescriptor_Option) GetKey() string

func (*ModelDescriptor_Option) GetValues 

func (m *ModelDescriptor_Option) GetValues() []string

func (*ModelDescriptor_Option) ProtoMessage 

func (*ModelDescriptor_Option) ProtoMessage()

func (*ModelDescriptor_Option) Reset 

func (m *ModelDescriptor_Option) Reset()

func (*ModelDescriptor_Option) String 

func (m *ModelDescriptor_Option) String() string

func (*ModelDescriptor_Option) XXX_DiscardUnknown 

func (m *ModelDescriptor_Option) XXX_DiscardUnknown()

func (*ModelDescriptor_Option) XXX_Marshal 

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

func (*ModelDescriptor_Option) XXX_Merge 

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

func (*ModelDescriptor_Option) XXX_Size 

func (m *ModelDescriptor_Option) XXX_Size() int

func (*ModelDescriptor_Option) XXX_Unmarshal 

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

type ModelSpec 

type ModelSpec struct {
	// Module describes grouping for the model.
	Module string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	// Version describes 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"`
	// Class describes purpose for the model.
	Class                string   `protobuf:"bytes,4,opt,name=class,proto3" json:"class,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ModelSpec defines a model specification to identify a model.

func (*ModelSpec) Descriptor 

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

func (*ModelSpec) GetClass 

func (m *ModelSpec) GetClass() string

func (*ModelSpec) GetModule 

func (m *ModelSpec) GetModule() string

func (*ModelSpec) GetType 

func (m *ModelSpec) GetType() string

func (*ModelSpec) GetVersion 

func (m *ModelSpec) GetVersion() string

func (*ModelSpec) ProtoMessage 

func (*ModelSpec) ProtoMessage()

func (*ModelSpec) Reset 

func (m *ModelSpec) Reset()

func (*ModelSpec) String 

func (m *ModelSpec) String() string

func (*ModelSpec) XXX_DiscardUnknown 

func (m *ModelSpec) XXX_DiscardUnknown()

func (*ModelSpec) XXX_Marshal 

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

func (*ModelSpec) XXX_Merge 

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

func (*ModelSpec) XXX_Size 

func (m *ModelSpec) XXX_Size() int

func (*ModelSpec) XXX_Unmarshal 

func (m *ModelSpec) 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 UnimplementedManagerServer 

type UnimplementedManagerServer struct {
}

UnimplementedManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedManagerServer) DumpState 

func (*UnimplementedManagerServer) DumpState(ctx context.Context, req *DumpStateRequest) (*DumpStateResponse, error)

func (*UnimplementedManagerServer) GetConfig 

func (*UnimplementedManagerServer) GetConfig(ctx context.Context, req *GetConfigRequest) (*GetConfigResponse, error)

func (*UnimplementedManagerServer) SetConfig 

func (*UnimplementedManagerServer) SetConfig(ctx context.Context, req *SetConfigRequest) (*SetConfigResponse, error)

func (*UnimplementedManagerServer) Subscribe 

func (*UnimplementedManagerServer) Subscribe(req *SubscribeRequest, srv Manager_SubscribeServer) error

type UnimplementedMetaServiceServer 

type UnimplementedMetaServiceServer struct {
}

UnimplementedMetaServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMetaServiceServer) KnownModels 

func (*UnimplementedMetaServiceServer) KnownModels(ctx context.Context, req *KnownModelsRequest) (*KnownModelsResponse, 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=generic.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

  • manager.pb.go
  • model.pb.go

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.