Documentation ¶
Index ¶
- Variables
- func RegisterManagerServiceServer(s grpc.ServiceRegistrar, srv ManagerServiceServer)
- func RegisterMetaServiceServer(s grpc.ServiceRegistrar, srv MetaServiceServer)
- type ConfigItem
- func (*ConfigItem) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigItem) GetItem() *Item
- func (x *ConfigItem) GetLabels() map[string]string
- func (x *ConfigItem) GetStatus() *ItemStatus
- func (*ConfigItem) ProtoMessage()
- func (x *ConfigItem) ProtoReflect() protoreflect.Message
- func (x *ConfigItem) Reset()
- func (x *ConfigItem) String() string
- type Data
- type Data_Any
- type DumpStateRequest
- type DumpStateResponse
- func (*DumpStateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DumpStateResponse) GetItems() []*StateItem
- func (*DumpStateResponse) ProtoMessage()
- func (x *DumpStateResponse) ProtoReflect() protoreflect.Message
- func (x *DumpStateResponse) Reset()
- func (x *DumpStateResponse) String() string
- type GetConfigRequest
- func (*GetConfigRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetConfigRequest) GetIds() []*Item_ID
- func (x *GetConfigRequest) GetLabels() map[string]string
- func (*GetConfigRequest) ProtoMessage()
- func (x *GetConfigRequest) ProtoReflect() protoreflect.Message
- func (x *GetConfigRequest) Reset()
- func (x *GetConfigRequest) String() string
- type GetConfigResponse
- func (*GetConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetConfigResponse) GetItems() []*ConfigItem
- func (*GetConfigResponse) ProtoMessage()
- func (x *GetConfigResponse) ProtoReflect() protoreflect.Message
- func (x *GetConfigResponse) Reset()
- func (x *GetConfigResponse) String() string
- type Item
- type ItemStatus
- type Item_ID
- type KnownModelsRequest
- func (*KnownModelsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *KnownModelsRequest) GetClass() string
- func (*KnownModelsRequest) ProtoMessage()
- func (x *KnownModelsRequest) ProtoReflect() protoreflect.Message
- func (x *KnownModelsRequest) Reset()
- func (x *KnownModelsRequest) String() string
- type KnownModelsResponse
- func (*KnownModelsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *KnownModelsResponse) GetActiveModules() []string
- func (x *KnownModelsResponse) GetKnownModels() []*ModelDetail
- func (*KnownModelsResponse) ProtoMessage()
- func (x *KnownModelsResponse) ProtoReflect() protoreflect.Message
- func (x *KnownModelsResponse) Reset()
- func (x *KnownModelsResponse) String() string
- type ManagerServiceClient
- type ManagerServiceServer
- type ManagerService_SubscribeClient
- type ManagerService_SubscribeServer
- type MetaServiceClient
- type MetaServiceServer
- type ModelDetail
- func (*ModelDetail) Descriptor() ([]byte, []int)deprecated
- func (x *ModelDetail) GetOptions() []*ModelDetail_Option
- func (x *ModelDetail) GetProtoName() string
- func (x *ModelDetail) GetSpec() *ModelSpec
- func (*ModelDetail) ProtoMessage()
- func (x *ModelDetail) ProtoReflect() protoreflect.Message
- func (x *ModelDetail) Reset()
- func (x *ModelDetail) String() string
- type ModelDetail_Option
- func (*ModelDetail_Option) Descriptor() ([]byte, []int)deprecated
- func (x *ModelDetail_Option) GetKey() string
- func (x *ModelDetail_Option) GetValues() []string
- func (*ModelDetail_Option) ProtoMessage()
- func (x *ModelDetail_Option) ProtoReflect() protoreflect.Message
- func (x *ModelDetail_Option) Reset()
- func (x *ModelDetail_Option) String() string
- type ModelSpec
- func (*ModelSpec) Descriptor() ([]byte, []int)deprecated
- func (x *ModelSpec) GetClass() string
- func (x *ModelSpec) GetModule() string
- func (x *ModelSpec) GetType() string
- func (x *ModelSpec) GetVersion() string
- func (*ModelSpec) ProtoMessage()
- func (x *ModelSpec) ProtoReflect() protoreflect.Message
- func (x *ModelSpec) Reset()
- func (x *ModelSpec) String() string
- type Notification
- func (*Notification) Descriptor() ([]byte, []int)deprecated
- func (x *Notification) GetItem() *Item
- func (x *Notification) GetStatus() *ItemStatus
- func (*Notification) ProtoMessage()
- func (x *Notification) ProtoReflect() protoreflect.Message
- func (x *Notification) Reset()
- func (x *Notification) String() string
- type ProtoFileDescriptorRequest
- func (*ProtoFileDescriptorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ProtoFileDescriptorRequest) GetFullProtoFileName() string
- func (*ProtoFileDescriptorRequest) ProtoMessage()
- func (x *ProtoFileDescriptorRequest) ProtoReflect() protoreflect.Message
- func (x *ProtoFileDescriptorRequest) Reset()
- func (x *ProtoFileDescriptorRequest) String() string
- type ProtoFileDescriptorResponse
- func (*ProtoFileDescriptorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ProtoFileDescriptorResponse) GetFileDescriptor() *descriptorpb.FileDescriptorProto
- func (x *ProtoFileDescriptorResponse) GetFileImportDescriptors() *descriptorpb.FileDescriptorSet
- func (*ProtoFileDescriptorResponse) ProtoMessage()
- func (x *ProtoFileDescriptorResponse) ProtoReflect() protoreflect.Message
- func (x *ProtoFileDescriptorResponse) Reset()
- func (x *ProtoFileDescriptorResponse) String() string
- type SetConfigRequest
- func (*SetConfigRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetConfigRequest) GetOverwriteAll() bool
- func (x *SetConfigRequest) GetUpdates() []*UpdateItem
- func (*SetConfigRequest) ProtoMessage()
- func (x *SetConfigRequest) ProtoReflect() protoreflect.Message
- func (x *SetConfigRequest) Reset()
- func (x *SetConfigRequest) String() string
- type SetConfigResponse
- func (*SetConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SetConfigResponse) GetResults() []*UpdateResult
- func (*SetConfigResponse) ProtoMessage()
- func (x *SetConfigResponse) ProtoReflect() protoreflect.Message
- func (x *SetConfigResponse) Reset()
- func (x *SetConfigResponse) String() string
- type StateItem
- type SubscribeRequest
- func (*SubscribeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeRequest) GetSubscriptions() []*Subscription
- func (*SubscribeRequest) ProtoMessage()
- func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
- func (x *SubscribeRequest) Reset()
- func (x *SubscribeRequest) String() string
- type SubscribeResponse
- func (*SubscribeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeResponse) GetNotifications() []*Notification
- func (*SubscribeResponse) ProtoMessage()
- func (x *SubscribeResponse) ProtoReflect() protoreflect.Message
- func (x *SubscribeResponse) Reset()
- func (x *SubscribeResponse) String() string
- type Subscription
- type UnimplementedManagerServiceServer
- func (UnimplementedManagerServiceServer) DumpState(context.Context, *DumpStateRequest) (*DumpStateResponse, error)
- func (UnimplementedManagerServiceServer) GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
- func (UnimplementedManagerServiceServer) SetConfig(context.Context, *SetConfigRequest) (*SetConfigResponse, error)
- func (UnimplementedManagerServiceServer) Subscribe(*SubscribeRequest, ManagerService_SubscribeServer) error
- type UnimplementedMetaServiceServer
- type UnsafeManagerServiceServer
- type UnsafeMetaServiceServer
- type UpdateItem
- func (*UpdateItem) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateItem) GetItem() *Item
- func (x *UpdateItem) GetLabels() map[string]string
- func (*UpdateItem) ProtoMessage()
- func (x *UpdateItem) ProtoReflect() protoreflect.Message
- func (x *UpdateItem) Reset()
- func (x *UpdateItem) String() string
- type UpdateResult
- func (*UpdateResult) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateResult) GetId() *Item_ID
- func (x *UpdateResult) GetKey() string
- func (x *UpdateResult) GetOp() UpdateResult_Operation
- func (x *UpdateResult) GetStatus() *ItemStatus
- func (*UpdateResult) ProtoMessage()
- func (x *UpdateResult) ProtoReflect() protoreflect.Message
- func (x *UpdateResult) Reset()
- func (x *UpdateResult) String() string
- type UpdateResult_Operation
- func (UpdateResult_Operation) Descriptor() protoreflect.EnumDescriptor
- func (x UpdateResult_Operation) Enum() *UpdateResult_Operation
- func (UpdateResult_Operation) EnumDescriptor() ([]byte, []int)deprecated
- func (x UpdateResult_Operation) Number() protoreflect.EnumNumber
- func (x UpdateResult_Operation) String() string
- func (UpdateResult_Operation) Type() protoreflect.EnumType
Constants ¶
This section is empty.
Variables ¶
var ( UpdateResult_Operation_name = map[int32]string{ 0: "UNSPECIFIED", 1: "CREATE", 2: "UPDATE", 3: "DELETE", } UpdateResult_Operation_value = map[string]int32{ "UNSPECIFIED": 0, "CREATE": 1, "UPDATE": 2, "DELETE": 3, } )
Enum value maps for UpdateResult_Operation.
var (
// optional ligato.generic.ModelSpec model = 50222;
E_Model = &file_ligato_generic_options_proto_extTypes[0]
)
Extension fields to descriptorpb.MessageOptions.
var File_ligato_generic_manager_proto protoreflect.FileDescriptor
var File_ligato_generic_meta_proto protoreflect.FileDescriptor
var File_ligato_generic_model_proto protoreflect.FileDescriptor
var File_ligato_generic_options_proto protoreflect.FileDescriptor
var ManagerService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "ligato.generic.ManagerService", HandlerType: (*ManagerServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SetConfig", Handler: _ManagerService_SetConfig_Handler, }, { MethodName: "GetConfig", Handler: _ManagerService_GetConfig_Handler, }, { MethodName: "DumpState", Handler: _ManagerService_DumpState_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Subscribe", Handler: _ManagerService_Subscribe_Handler, ServerStreams: true, }, }, Metadata: "ligato/generic/manager.proto", }
ManagerService_ServiceDesc is the grpc.ServiceDesc for ManagerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var MetaService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "ligato.generic.MetaService", HandlerType: (*MetaServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "KnownModels", Handler: _MetaService_KnownModels_Handler, }, { MethodName: "ProtoFileDescriptor", Handler: _MetaService_ProtoFileDescriptor_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "ligato/generic/meta.proto", }
MetaService_ServiceDesc is the grpc.ServiceDesc for MetaService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterManagerServiceServer ¶
func RegisterManagerServiceServer(s grpc.ServiceRegistrar, srv ManagerServiceServer)
func RegisterMetaServiceServer ¶
func RegisterMetaServiceServer(s grpc.ServiceRegistrar, 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 */ // contains filtered or unexported fields }
func (*ConfigItem) Descriptor
deprecated
func (*ConfigItem) Descriptor() ([]byte, []int)
Deprecated: Use ConfigItem.ProtoReflect.Descriptor instead.
func (*ConfigItem) GetItem ¶
func (x *ConfigItem) GetItem() *Item
func (*ConfigItem) GetLabels ¶
func (x *ConfigItem) GetLabels() map[string]string
func (*ConfigItem) GetStatus ¶
func (x *ConfigItem) GetStatus() *ItemStatus
func (*ConfigItem) ProtoMessage ¶
func (*ConfigItem) ProtoMessage()
func (*ConfigItem) ProtoReflect ¶ added in v3.2.0
func (x *ConfigItem) ProtoReflect() protoreflect.Message
func (*ConfigItem) Reset ¶
func (x *ConfigItem) Reset()
func (*ConfigItem) String ¶
func (x *ConfigItem) String() string
type Data ¶
type Data struct { // Types that are assignable to Union: // *Data_Any Union isData_Union `protobuf_oneof:"union"` // contains filtered or unexported fields }
Data represents encoded data for an item.
func (*Data) Descriptor
deprecated
func (*Data) ProtoMessage ¶
func (*Data) ProtoMessage()
func (*Data) ProtoReflect ¶ added in v3.2.0
func (x *Data) ProtoReflect() protoreflect.Message
type DumpStateRequest ¶
type DumpStateRequest struct { Ids []*Item_ID `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"` // contains filtered or unexported fields }
func (*DumpStateRequest) Descriptor
deprecated
func (*DumpStateRequest) Descriptor() ([]byte, []int)
Deprecated: Use DumpStateRequest.ProtoReflect.Descriptor instead.
func (*DumpStateRequest) GetIds ¶
func (x *DumpStateRequest) GetIds() []*Item_ID
func (*DumpStateRequest) ProtoMessage ¶
func (*DumpStateRequest) ProtoMessage()
func (*DumpStateRequest) ProtoReflect ¶ added in v3.2.0
func (x *DumpStateRequest) ProtoReflect() protoreflect.Message
func (*DumpStateRequest) Reset ¶
func (x *DumpStateRequest) Reset()
func (*DumpStateRequest) String ¶
func (x *DumpStateRequest) String() string
type DumpStateResponse ¶
type DumpStateResponse struct { Items []*StateItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"` // contains filtered or unexported fields }
func (*DumpStateResponse) Descriptor
deprecated
func (*DumpStateResponse) Descriptor() ([]byte, []int)
Deprecated: Use DumpStateResponse.ProtoReflect.Descriptor instead.
func (*DumpStateResponse) GetItems ¶
func (x *DumpStateResponse) GetItems() []*StateItem
func (*DumpStateResponse) ProtoMessage ¶
func (*DumpStateResponse) ProtoMessage()
func (*DumpStateResponse) ProtoReflect ¶ added in v3.2.0
func (x *DumpStateResponse) ProtoReflect() protoreflect.Message
func (*DumpStateResponse) Reset ¶
func (x *DumpStateResponse) Reset()
func (*DumpStateResponse) String ¶
func (x *DumpStateResponse) String() string
type GetConfigRequest ¶
type GetConfigRequest struct { Ids []*Item_ID `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"` Labels map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetConfigRequest) Descriptor
deprecated
func (*GetConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetConfigRequest.ProtoReflect.Descriptor instead.
func (*GetConfigRequest) GetIds ¶
func (x *GetConfigRequest) GetIds() []*Item_ID
func (*GetConfigRequest) GetLabels ¶ added in v3.5.0
func (x *GetConfigRequest) GetLabels() map[string]string
func (*GetConfigRequest) ProtoMessage ¶
func (*GetConfigRequest) ProtoMessage()
func (*GetConfigRequest) ProtoReflect ¶ added in v3.2.0
func (x *GetConfigRequest) ProtoReflect() protoreflect.Message
func (*GetConfigRequest) Reset ¶
func (x *GetConfigRequest) Reset()
func (*GetConfigRequest) String ¶
func (x *GetConfigRequest) String() string
type GetConfigResponse ¶
type GetConfigResponse struct { Items []*ConfigItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"` // contains filtered or unexported fields }
func (*GetConfigResponse) Descriptor
deprecated
func (*GetConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetConfigResponse.ProtoReflect.Descriptor instead.
func (*GetConfigResponse) GetItems ¶
func (x *GetConfigResponse) GetItems() []*ConfigItem
func (*GetConfigResponse) ProtoMessage ¶
func (*GetConfigResponse) ProtoMessage()
func (*GetConfigResponse) ProtoReflect ¶ added in v3.2.0
func (x *GetConfigResponse) ProtoReflect() protoreflect.Message
func (*GetConfigResponse) Reset ¶
func (x *GetConfigResponse) Reset()
func (*GetConfigResponse) String ¶
func (x *GetConfigResponse) String() string
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"` // contains filtered or unexported fields }
Item represents single instance described by the Model.
func (*Item) Descriptor
deprecated
func (*Item) ProtoMessage ¶
func (*Item) ProtoMessage()
func (*Item) ProtoReflect ¶ added in v3.2.0
func (x *Item) ProtoReflect() protoreflect.Message
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"` // contains filtered or unexported fields }
Item status describes status of an item.
func (*ItemStatus) Descriptor
deprecated
func (*ItemStatus) Descriptor() ([]byte, []int)
Deprecated: Use ItemStatus.ProtoReflect.Descriptor instead.
func (*ItemStatus) GetMessage ¶
func (x *ItemStatus) GetMessage() string
func (*ItemStatus) GetStatus ¶
func (x *ItemStatus) GetStatus() string
func (*ItemStatus) ProtoMessage ¶
func (*ItemStatus) ProtoMessage()
func (*ItemStatus) ProtoReflect ¶ added in v3.2.0
func (x *ItemStatus) ProtoReflect() protoreflect.Message
func (*ItemStatus) Reset ¶
func (x *ItemStatus) Reset()
func (*ItemStatus) String ¶
func (x *ItemStatus) String() string
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"` // contains filtered or unexported fields }
ID represents identifier for distinguishing items.
func (*Item_ID) Descriptor
deprecated
func (*Item_ID) ProtoMessage ¶
func (*Item_ID) ProtoMessage()
func (*Item_ID) ProtoReflect ¶ added in v3.2.0
func (x *Item_ID) ProtoReflect() protoreflect.Message
type KnownModelsRequest ¶
type KnownModelsRequest struct { Class string `protobuf:"bytes,1,opt,name=class,proto3" json:"class,omitempty"` // contains filtered or unexported fields }
func (*KnownModelsRequest) Descriptor
deprecated
func (*KnownModelsRequest) Descriptor() ([]byte, []int)
Deprecated: Use KnownModelsRequest.ProtoReflect.Descriptor instead.
func (*KnownModelsRequest) GetClass ¶
func (x *KnownModelsRequest) GetClass() string
func (*KnownModelsRequest) ProtoMessage ¶
func (*KnownModelsRequest) ProtoMessage()
func (*KnownModelsRequest) ProtoReflect ¶ added in v3.2.0
func (x *KnownModelsRequest) ProtoReflect() protoreflect.Message
func (*KnownModelsRequest) Reset ¶
func (x *KnownModelsRequest) Reset()
func (*KnownModelsRequest) String ¶
func (x *KnownModelsRequest) String() string
type KnownModelsResponse ¶
type KnownModelsResponse struct { KnownModels []*ModelDetail `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"` // contains filtered or unexported fields }
func (*KnownModelsResponse) Descriptor
deprecated
func (*KnownModelsResponse) Descriptor() ([]byte, []int)
Deprecated: Use KnownModelsResponse.ProtoReflect.Descriptor instead.
func (*KnownModelsResponse) GetActiveModules ¶
func (x *KnownModelsResponse) GetActiveModules() []string
func (*KnownModelsResponse) GetKnownModels ¶
func (x *KnownModelsResponse) GetKnownModels() []*ModelDetail
func (*KnownModelsResponse) ProtoMessage ¶
func (*KnownModelsResponse) ProtoMessage()
func (*KnownModelsResponse) ProtoReflect ¶ added in v3.2.0
func (x *KnownModelsResponse) ProtoReflect() protoreflect.Message
func (*KnownModelsResponse) Reset ¶
func (x *KnownModelsResponse) Reset()
func (*KnownModelsResponse) String ¶
func (x *KnownModelsResponse) String() string
type ManagerServiceClient ¶
type ManagerServiceClient 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) (ManagerService_SubscribeClient, error) }
ManagerServiceClient is the client API for ManagerService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewManagerServiceClient ¶
func NewManagerServiceClient(cc grpc.ClientConnInterface) ManagerServiceClient
type ManagerServiceServer ¶
type ManagerServiceServer 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, ManagerService_SubscribeServer) error // contains filtered or unexported methods }
ManagerServiceServer is the server API for ManagerService service. All implementations must embed UnimplementedManagerServiceServer for forward compatibility
type ManagerService_SubscribeClient ¶
type ManagerService_SubscribeClient interface { Recv() (*SubscribeResponse, error) grpc.ClientStream }
type ManagerService_SubscribeServer ¶
type ManagerService_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) // ProtoFileDescriptor returns proto file descriptor for proto file identified by full name. // The proto file descriptor is in form of proto messages (file descriptor proto and // proto of its imports) so there are needed additional steps to join them into protoreflect.FileDescriptor // ("google.golang.org/protobuf/reflect/protodesc".NewFile(...)). // // This rpc can be used together with knownModels rpc to retrieve additional model information. // Message descriptor can be retrieved from file descriptor corresponding to knownModel message // and used with proto reflecting to get all kinds of information about the known model. // // Due to nature of data retrieval, it is expected that at least one message from that proto file // is registered as known model. ProtoFileDescriptor(ctx context.Context, in *ProtoFileDescriptorRequest, opts ...grpc.CallOption) (*ProtoFileDescriptorResponse, error) }
MetaServiceClient is the client API for MetaService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewMetaServiceClient ¶
func NewMetaServiceClient(cc grpc.ClientConnInterface) 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) // ProtoFileDescriptor returns proto file descriptor for proto file identified by full name. // The proto file descriptor is in form of proto messages (file descriptor proto and // proto of its imports) so there are needed additional steps to join them into protoreflect.FileDescriptor // ("google.golang.org/protobuf/reflect/protodesc".NewFile(...)). // // This rpc can be used together with knownModels rpc to retrieve additional model information. // Message descriptor can be retrieved from file descriptor corresponding to knownModel message // and used with proto reflecting to get all kinds of information about the known model. // // Due to nature of data retrieval, it is expected that at least one message from that proto file // is registered as known model. ProtoFileDescriptor(context.Context, *ProtoFileDescriptorRequest) (*ProtoFileDescriptorResponse, error) // contains filtered or unexported methods }
MetaServiceServer is the server API for MetaService service. All implementations must embed UnimplementedMetaServiceServer for forward compatibility
type ModelDetail ¶
type ModelDetail 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 []*ModelDetail_Option `protobuf:"bytes,3,rep,name=options,proto3" json:"options,omitempty"` // contains filtered or unexported fields }
ModelDetail represents info about model details.
func (*ModelDetail) Descriptor
deprecated
func (*ModelDetail) Descriptor() ([]byte, []int)
Deprecated: Use ModelDetail.ProtoReflect.Descriptor instead.
func (*ModelDetail) GetOptions ¶
func (x *ModelDetail) GetOptions() []*ModelDetail_Option
func (*ModelDetail) GetProtoName ¶
func (x *ModelDetail) GetProtoName() string
func (*ModelDetail) GetSpec ¶
func (x *ModelDetail) GetSpec() *ModelSpec
func (*ModelDetail) ProtoMessage ¶
func (*ModelDetail) ProtoMessage()
func (*ModelDetail) ProtoReflect ¶ added in v3.2.0
func (x *ModelDetail) ProtoReflect() protoreflect.Message
func (*ModelDetail) Reset ¶
func (x *ModelDetail) Reset()
func (*ModelDetail) String ¶
func (x *ModelDetail) String() string
type ModelDetail_Option ¶
type ModelDetail_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"` // contains filtered or unexported fields }
func (*ModelDetail_Option) Descriptor
deprecated
func (*ModelDetail_Option) Descriptor() ([]byte, []int)
Deprecated: Use ModelDetail_Option.ProtoReflect.Descriptor instead.
func (*ModelDetail_Option) GetKey ¶
func (x *ModelDetail_Option) GetKey() string
func (*ModelDetail_Option) GetValues ¶
func (x *ModelDetail_Option) GetValues() []string
func (*ModelDetail_Option) ProtoMessage ¶
func (*ModelDetail_Option) ProtoMessage()
func (*ModelDetail_Option) ProtoReflect ¶ added in v3.2.0
func (x *ModelDetail_Option) ProtoReflect() protoreflect.Message
func (*ModelDetail_Option) Reset ¶
func (x *ModelDetail_Option) Reset()
func (*ModelDetail_Option) String ¶
func (x *ModelDetail_Option) String() string
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"` // contains filtered or unexported fields }
ModelSpec defines a model specification to identify a model.
func (*ModelSpec) Descriptor
deprecated
func (*ModelSpec) GetVersion ¶
func (*ModelSpec) ProtoMessage ¶
func (*ModelSpec) ProtoMessage()
func (*ModelSpec) ProtoReflect ¶ added in v3.2.0
func (x *ModelSpec) ProtoReflect() protoreflect.Message
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"` // contains filtered or unexported fields }
func (*Notification) Descriptor
deprecated
func (*Notification) Descriptor() ([]byte, []int)
Deprecated: Use Notification.ProtoReflect.Descriptor instead.
func (*Notification) GetItem ¶
func (x *Notification) GetItem() *Item
func (*Notification) GetStatus ¶
func (x *Notification) GetStatus() *ItemStatus
func (*Notification) ProtoMessage ¶
func (*Notification) ProtoMessage()
func (*Notification) ProtoReflect ¶ added in v3.2.0
func (x *Notification) ProtoReflect() protoreflect.Message
func (*Notification) Reset ¶
func (x *Notification) Reset()
func (*Notification) String ¶
func (x *Notification) String() string
type ProtoFileDescriptorRequest ¶ added in v3.3.0
type ProtoFileDescriptorRequest struct { // full_proto_file_name is full name of proto file that is needed to identify it. It has the form // "<proto package name ('.' replaced with '/')>/<simple file name>" (i.e. for this proto model // it is "ligato/generic/meta.proto"). // If you are using rpc ProtoFileDescriptor for additional information retrieve for known models from // rpc KnownModels call, you can use usually present ModelDetail's generic.ModelDetail_Option for // key "protoFile" that is containing full proto file name in correct format. FullProtoFileName string `protobuf:"bytes,1,opt,name=full_proto_file_name,json=fullProtoFileName,proto3" json:"full_proto_file_name,omitempty"` // contains filtered or unexported fields }
func (*ProtoFileDescriptorRequest) Descriptor
deprecated
added in
v3.3.0
func (*ProtoFileDescriptorRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProtoFileDescriptorRequest.ProtoReflect.Descriptor instead.
func (*ProtoFileDescriptorRequest) GetFullProtoFileName ¶ added in v3.3.0
func (x *ProtoFileDescriptorRequest) GetFullProtoFileName() string
func (*ProtoFileDescriptorRequest) ProtoMessage ¶ added in v3.3.0
func (*ProtoFileDescriptorRequest) ProtoMessage()
func (*ProtoFileDescriptorRequest) ProtoReflect ¶ added in v3.3.0
func (x *ProtoFileDescriptorRequest) ProtoReflect() protoreflect.Message
func (*ProtoFileDescriptorRequest) Reset ¶ added in v3.3.0
func (x *ProtoFileDescriptorRequest) Reset()
func (*ProtoFileDescriptorRequest) String ¶ added in v3.3.0
func (x *ProtoFileDescriptorRequest) String() string
type ProtoFileDescriptorResponse ¶ added in v3.3.0
type ProtoFileDescriptorResponse struct { // file_descriptor is proto message representing proto file descriptor FileDescriptor *descriptorpb.FileDescriptorProto `protobuf:"bytes,1,opt,name=file_descriptor,json=fileDescriptor,proto3" json:"file_descriptor,omitempty"` // file_import_descriptors is set of file descriptors that the file_descriptor is using as import. This // is needed when converting file descriptor proto to protoreflect.FileDescriptor (using // "google.golang.org/protobuf/reflect/protodesc".NewFile(...) ) FileImportDescriptors *descriptorpb.FileDescriptorSet `` /* 126-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ProtoFileDescriptorResponse) Descriptor
deprecated
added in
v3.3.0
func (*ProtoFileDescriptorResponse) Descriptor() ([]byte, []int)
Deprecated: Use ProtoFileDescriptorResponse.ProtoReflect.Descriptor instead.
func (*ProtoFileDescriptorResponse) GetFileDescriptor ¶ added in v3.3.0
func (x *ProtoFileDescriptorResponse) GetFileDescriptor() *descriptorpb.FileDescriptorProto
func (*ProtoFileDescriptorResponse) GetFileImportDescriptors ¶ added in v3.3.0
func (x *ProtoFileDescriptorResponse) GetFileImportDescriptors() *descriptorpb.FileDescriptorSet
func (*ProtoFileDescriptorResponse) ProtoMessage ¶ added in v3.3.0
func (*ProtoFileDescriptorResponse) ProtoMessage()
func (*ProtoFileDescriptorResponse) ProtoReflect ¶ added in v3.3.0
func (x *ProtoFileDescriptorResponse) ProtoReflect() protoreflect.Message
func (*ProtoFileDescriptorResponse) Reset ¶ added in v3.3.0
func (x *ProtoFileDescriptorResponse) Reset()
func (*ProtoFileDescriptorResponse) String ¶ added in v3.3.0
func (x *ProtoFileDescriptorResponse) String() string
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"` // contains filtered or unexported fields }
func (*SetConfigRequest) Descriptor
deprecated
func (*SetConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetConfigRequest.ProtoReflect.Descriptor instead.
func (*SetConfigRequest) GetOverwriteAll ¶
func (x *SetConfigRequest) GetOverwriteAll() bool
func (*SetConfigRequest) GetUpdates ¶
func (x *SetConfigRequest) GetUpdates() []*UpdateItem
func (*SetConfigRequest) ProtoMessage ¶
func (*SetConfigRequest) ProtoMessage()
func (*SetConfigRequest) ProtoReflect ¶ added in v3.2.0
func (x *SetConfigRequest) ProtoReflect() protoreflect.Message
func (*SetConfigRequest) Reset ¶
func (x *SetConfigRequest) Reset()
func (*SetConfigRequest) String ¶
func (x *SetConfigRequest) String() string
type SetConfigResponse ¶
type SetConfigResponse struct { Results []*UpdateResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"` // contains filtered or unexported fields }
func (*SetConfigResponse) Descriptor
deprecated
func (*SetConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use SetConfigResponse.ProtoReflect.Descriptor instead.
func (*SetConfigResponse) GetResults ¶
func (x *SetConfigResponse) GetResults() []*UpdateResult
func (*SetConfigResponse) ProtoMessage ¶
func (*SetConfigResponse) ProtoMessage()
func (*SetConfigResponse) ProtoReflect ¶ added in v3.2.0
func (x *SetConfigResponse) ProtoReflect() protoreflect.Message
func (*SetConfigResponse) Reset ¶
func (x *SetConfigResponse) Reset()
func (*SetConfigResponse) String ¶
func (x *SetConfigResponse) String() string
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 */ // contains filtered or unexported fields }
func (*StateItem) Descriptor
deprecated
func (*StateItem) GetMetadata ¶
func (*StateItem) ProtoMessage ¶
func (*StateItem) ProtoMessage()
func (*StateItem) ProtoReflect ¶ added in v3.2.0
func (x *StateItem) ProtoReflect() protoreflect.Message
type SubscribeRequest ¶
type SubscribeRequest struct { Subscriptions []*Subscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"` // contains filtered or unexported fields }
func (*SubscribeRequest) Descriptor
deprecated
func (*SubscribeRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.
func (*SubscribeRequest) GetSubscriptions ¶
func (x *SubscribeRequest) GetSubscriptions() []*Subscription
func (*SubscribeRequest) ProtoMessage ¶
func (*SubscribeRequest) ProtoMessage()
func (*SubscribeRequest) ProtoReflect ¶ added in v3.2.0
func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
func (*SubscribeRequest) Reset ¶
func (x *SubscribeRequest) Reset()
func (*SubscribeRequest) String ¶
func (x *SubscribeRequest) String() string
type SubscribeResponse ¶
type SubscribeResponse struct { Notifications []*Notification `protobuf:"bytes,1,rep,name=notifications,proto3" json:"notifications,omitempty"` // contains filtered or unexported fields }
func (*SubscribeResponse) Descriptor
deprecated
func (*SubscribeResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.
func (*SubscribeResponse) GetNotifications ¶
func (x *SubscribeResponse) GetNotifications() []*Notification
func (*SubscribeResponse) ProtoMessage ¶
func (*SubscribeResponse) ProtoMessage()
func (*SubscribeResponse) ProtoReflect ¶ added in v3.2.0
func (x *SubscribeResponse) ProtoReflect() protoreflect.Message
func (*SubscribeResponse) Reset ¶
func (x *SubscribeResponse) Reset()
func (*SubscribeResponse) String ¶
func (x *SubscribeResponse) String() string
type Subscription ¶
type Subscription struct { Id *Item_ID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*Subscription) Descriptor
deprecated
func (*Subscription) Descriptor() ([]byte, []int)
Deprecated: Use Subscription.ProtoReflect.Descriptor instead.
func (*Subscription) GetId ¶
func (x *Subscription) GetId() *Item_ID
func (*Subscription) ProtoMessage ¶
func (*Subscription) ProtoMessage()
func (*Subscription) ProtoReflect ¶ added in v3.2.0
func (x *Subscription) ProtoReflect() protoreflect.Message
func (*Subscription) Reset ¶
func (x *Subscription) Reset()
func (*Subscription) String ¶
func (x *Subscription) String() string
type UnimplementedManagerServiceServer ¶
type UnimplementedManagerServiceServer struct { }
UnimplementedManagerServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedManagerServiceServer) DumpState ¶
func (UnimplementedManagerServiceServer) DumpState(context.Context, *DumpStateRequest) (*DumpStateResponse, error)
func (UnimplementedManagerServiceServer) GetConfig ¶
func (UnimplementedManagerServiceServer) GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
func (UnimplementedManagerServiceServer) SetConfig ¶
func (UnimplementedManagerServiceServer) SetConfig(context.Context, *SetConfigRequest) (*SetConfigResponse, error)
func (UnimplementedManagerServiceServer) Subscribe ¶
func (UnimplementedManagerServiceServer) Subscribe(*SubscribeRequest, ManagerService_SubscribeServer) error
type UnimplementedMetaServiceServer ¶
type UnimplementedMetaServiceServer struct { }
UnimplementedMetaServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedMetaServiceServer) KnownModels ¶
func (UnimplementedMetaServiceServer) KnownModels(context.Context, *KnownModelsRequest) (*KnownModelsResponse, error)
func (UnimplementedMetaServiceServer) ProtoFileDescriptor ¶ added in v3.3.0
func (UnimplementedMetaServiceServer) ProtoFileDescriptor(context.Context, *ProtoFileDescriptorRequest) (*ProtoFileDescriptorResponse, error)
type UnsafeManagerServiceServer ¶ added in v3.3.0
type UnsafeManagerServiceServer interface {
// contains filtered or unexported methods
}
UnsafeManagerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ManagerServiceServer will result in compilation errors.
type UnsafeMetaServiceServer ¶ added in v3.3.0
type UnsafeMetaServiceServer interface {
// contains filtered or unexported methods
}
UnsafeMetaServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MetaServiceServer will result in compilation errors.
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. // Label is string key-value pair associated with configuration item. // Label key format guidelines: label key should be a lower-case alphanumeric // string which may contain periods and hyphens (but it should not contain // consecutive periods/hyphens and it should not start with period/hyphen). // Labels for configuration items should be prefixed with the reverse DNS // notation of a domain they originate from (with domain owner's permission) // for example: com.example.foo-bar-label. // The io.ligato.* and ligato.* prefixes are reserved by vpp-agent for internal use. Labels map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*UpdateItem) Descriptor
deprecated
func (*UpdateItem) Descriptor() ([]byte, []int)
Deprecated: Use UpdateItem.ProtoReflect.Descriptor instead.
func (*UpdateItem) GetItem ¶
func (x *UpdateItem) GetItem() *Item
func (*UpdateItem) GetLabels ¶
func (x *UpdateItem) GetLabels() map[string]string
func (*UpdateItem) ProtoMessage ¶
func (*UpdateItem) ProtoMessage()
func (*UpdateItem) ProtoReflect ¶ added in v3.2.0
func (x *UpdateItem) ProtoReflect() protoreflect.Message
func (*UpdateItem) Reset ¶
func (x *UpdateItem) Reset()
func (*UpdateItem) String ¶
func (x *UpdateItem) String() string
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=ligato.generic.UpdateResult_Operation" json:"op,omitempty"` Status *ItemStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*UpdateResult) Descriptor
deprecated
func (*UpdateResult) Descriptor() ([]byte, []int)
Deprecated: Use UpdateResult.ProtoReflect.Descriptor instead.
func (*UpdateResult) GetId ¶
func (x *UpdateResult) GetId() *Item_ID
func (*UpdateResult) GetKey ¶
func (x *UpdateResult) GetKey() string
func (*UpdateResult) GetOp ¶
func (x *UpdateResult) GetOp() UpdateResult_Operation
func (*UpdateResult) GetStatus ¶
func (x *UpdateResult) GetStatus() *ItemStatus
func (*UpdateResult) ProtoMessage ¶
func (*UpdateResult) ProtoMessage()
func (*UpdateResult) ProtoReflect ¶ added in v3.2.0
func (x *UpdateResult) ProtoReflect() protoreflect.Message
func (*UpdateResult) Reset ¶
func (x *UpdateResult) Reset()
func (*UpdateResult) String ¶
func (x *UpdateResult) String() string
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) Descriptor ¶ added in v3.2.0
func (UpdateResult_Operation) Descriptor() protoreflect.EnumDescriptor
func (UpdateResult_Operation) Enum ¶ added in v3.2.0
func (x UpdateResult_Operation) Enum() *UpdateResult_Operation
func (UpdateResult_Operation) EnumDescriptor
deprecated
func (UpdateResult_Operation) EnumDescriptor() ([]byte, []int)
Deprecated: Use UpdateResult_Operation.Descriptor instead.
func (UpdateResult_Operation) Number ¶ added in v3.2.0
func (x UpdateResult_Operation) Number() protoreflect.EnumNumber
func (UpdateResult_Operation) String ¶
func (x UpdateResult_Operation) String() string
func (UpdateResult_Operation) Type ¶ added in v3.2.0
func (UpdateResult_Operation) Type() protoreflect.EnumType