generic

package
v3.4.0-alpha Latest Latest
Warning

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

 Go to latest Published: Jan 27, 2022 License: Apache-2.0 Imports: 10 Imported by: 5

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",
	}
	UpdateResult_Operation_value = map[string]int32{
		"UNSPECIFIED": 0,
		"CREATE":      1,
		"UPDATE":      2,
		"DELETE":      3,
	}
)

Enum value maps for UpdateResult_Operation.

View Source 
var (
	// optional ligato.generic.ModelSpec model = 50222;
	E_Model = &file_ligato_generic_options_proto_extTypes[0]
)

Extension fields to descriptorpb.MessageOptions.

View Source 
var File_ligato_generic_manager_proto protoreflect.FileDescriptor
View Source 
var File_ligato_generic_meta_proto protoreflect.FileDescriptor
View Source 
var File_ligato_generic_model_proto protoreflect.FileDescriptor
View Source 
var File_ligato_generic_options_proto protoreflect.FileDescriptor

Functions

func RegisterManagerServiceServer 

func RegisterManagerServiceServer(s *grpc.Server, srv ManagerServiceServer)

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 */
	// 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) Descriptor() ([]byte, []int)

Deprecated: Use Data.ProtoReflect.Descriptor instead.

func (*Data) GetAny 

func (x *Data) GetAny() *anypb.Any

func (*Data) GetUnion 

func (m *Data) GetUnion() isData_Union

func (*Data) ProtoMessage 

func (*Data) ProtoMessage()

func (*Data) ProtoReflect added in v3.2.0 

func (x *Data) ProtoReflect() protoreflect.Message

func (*Data) Reset 

func (x *Data) Reset()

func (*Data) String 

func (x *Data) String() string

type Data_Any 

type Data_Any struct {
	Any *anypb.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"`
	// 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"`
	// 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) 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) Descriptor() ([]byte, []int)

Deprecated: Use Item.ProtoReflect.Descriptor instead.

func (*Item) GetData 

func (x *Item) GetData() *Data

func (*Item) GetId 

func (x *Item) GetId() *Item_ID

func (*Item) ProtoMessage 

func (*Item) ProtoMessage()

func (*Item) ProtoReflect added in v3.2.0 

func (x *Item) ProtoReflect() protoreflect.Message

func (*Item) Reset 

func (x *Item) Reset()

func (*Item) String 

func (x *Item) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Item_ID.ProtoReflect.Descriptor instead.

func (*Item_ID) GetModel 

func (x *Item_ID) GetModel() string

func (*Item_ID) GetName 

func (x *Item_ID) GetName() string

func (*Item_ID) ProtoMessage 

func (*Item_ID) ProtoMessage()

func (*Item_ID) ProtoReflect added in v3.2.0 

func (x *Item_ID) ProtoReflect() protoreflect.Message

func (*Item_ID) Reset 

func (x *Item_ID) Reset()

func (*Item_ID) String 

func (x *Item_ID) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use ModelSpec.ProtoReflect.Descriptor instead.

func (*ModelSpec) GetClass 

func (x *ModelSpec) GetClass() string

func (*ModelSpec) GetModule 

func (x *ModelSpec) GetModule() string

func (*ModelSpec) GetType 

func (x *ModelSpec) GetType() string

func (*ModelSpec) GetVersion 

func (x *ModelSpec) GetVersion() string

func (*ModelSpec) ProtoMessage 

func (*ModelSpec) ProtoMessage()

func (*ModelSpec) ProtoReflect added in v3.2.0 

func (x *ModelSpec) ProtoReflect() protoreflect.Message

func (*ModelSpec) Reset 

func (x *ModelSpec) Reset()

func (*ModelSpec) String 

func (x *ModelSpec) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use StateItem.ProtoReflect.Descriptor instead.

func (*StateItem) GetItem 

func (x *StateItem) GetItem() *Item

func (*StateItem) GetMetadata 

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

func (*StateItem) ProtoMessage 

func (*StateItem) ProtoMessage()

func (*StateItem) ProtoReflect added in v3.2.0 

func (x *StateItem) ProtoReflect() protoreflect.Message

func (*StateItem) Reset 

func (x *StateItem) Reset()

func (*StateItem) String 

func (x *StateItem) String() string

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.