Versions in this module Expand all Collapse all v0 v0.3.0 Sep 3, 2024 Changes in this version + const ActuatorPlugin_Effect_FullMethodName + const ActuatorPlugin_NextState_FullMethodName + const ActuatorPlugin_Perform_FullMethodName + const Registration_Register_FullMethodName v0.2.0 Apr 12, 2023 Changes in this version + type ActuatorPlugin_NextStateClient interface + Recv func() (*NextStateResponse, error) + Send func(*NextStateRequest) error + type ActuatorPlugin_NextStateServer interface + Recv func() (*NextStateRequest, error) + Send func(*NextStateResponse) error type State + Annotations map[string]string + Resources map[string]string + func (x *State) GetAnnotations() map[string]string + func (x *State) GetResources() map[string]string v0.1.0 Oct 19, 2022 Changes in this version + var ActuatorPlugin_ServiceDesc = grpc.ServiceDesc + var File_pkg_api_plugins_v1alpha1_protobufs_api_proto protoreflect.FileDescriptor + var PluginType_name = map[int32]string + var PluginType_value = map[string]int32 + var ProfileType_name = map[int32]string + var ProfileType_value = map[string]int32 + var PropertyType_name = map[int32]string + var PropertyType_value = map[string]int32 + var Registration_ServiceDesc = grpc.ServiceDesc + func RegisterActuatorPluginServer(s grpc.ServiceRegistrar, srv ActuatorPluginServer) + func RegisterRegistrationServer(s grpc.ServiceRegistrar, srv RegistrationServer) + type Action struct + Name string + Properties *ActionProperties + func (*Action) Descriptor() ([]byte, []int) + func (*Action) ProtoMessage() + func (x *Action) GetName() string + func (x *Action) GetProperties() *ActionProperties + func (x *Action) ProtoReflect() protoreflect.Message + func (x *Action) Reset() + func (x *Action) String() string + type ActionProperties struct + IntProperties map[string]int32 + StrProperties map[string]string + Type PropertyType + func (*ActionProperties) Descriptor() ([]byte, []int) + func (*ActionProperties) ProtoMessage() + func (x *ActionProperties) GetIntProperties() map[string]int32 + func (x *ActionProperties) GetStrProperties() map[string]string + func (x *ActionProperties) GetType() PropertyType + func (x *ActionProperties) ProtoReflect() protoreflect.Message + func (x *ActionProperties) Reset() + func (x *ActionProperties) String() string + type ActuatorPluginClient interface + Effect func(ctx context.Context, in *EffectRequest, opts ...grpc.CallOption) (*Empty, error) + NextState func(ctx context.Context, in *NextStateRequest, opts ...grpc.CallOption) (*NextStateResponse, error) + Perform func(ctx context.Context, in *PerformRequest, opts ...grpc.CallOption) (*Empty, error) + func NewActuatorPluginClient(cc grpc.ClientConnInterface) ActuatorPluginClient + type ActuatorPluginServer interface + Effect func(context.Context, *EffectRequest) (*Empty, error) + NextState func(context.Context, *NextStateRequest) (*NextStateResponse, error) + Perform func(context.Context, *PerformRequest) (*Empty, error) + type DataEntry struct + Data map[string]float64 + func (*DataEntry) Descriptor() ([]byte, []int) + func (*DataEntry) ProtoMessage() + func (x *DataEntry) GetData() map[string]float64 + func (x *DataEntry) ProtoReflect() protoreflect.Message + func (x *DataEntry) Reset() + func (x *DataEntry) String() string + type EffectRequest struct + Profiles map[string]*Profile + State *State + func (*EffectRequest) Descriptor() ([]byte, []int) + func (*EffectRequest) ProtoMessage() + func (x *EffectRequest) GetProfiles() map[string]*Profile + func (x *EffectRequest) GetState() *State + func (x *EffectRequest) ProtoReflect() protoreflect.Message + func (x *EffectRequest) Reset() + func (x *EffectRequest) String() string + type Empty struct + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (x *Empty) ProtoReflect() protoreflect.Message + func (x *Empty) Reset() + func (x *Empty) String() string + type Intent struct + Key string + Objectives map[string]float64 + Priority float64 + TargetKey string + TargetKind string + func (*Intent) Descriptor() ([]byte, []int) + func (*Intent) ProtoMessage() + func (x *Intent) GetKey() string + func (x *Intent) GetObjectives() map[string]float64 + func (x *Intent) GetPriority() float64 + func (x *Intent) GetTargetKey() string + func (x *Intent) GetTargetKind() string + func (x *Intent) ProtoReflect() protoreflect.Message + func (x *Intent) Reset() + func (x *Intent) String() string + type NextStateRequest struct + Goal *State + Profiles map[string]*Profile + State *State + func (*NextStateRequest) Descriptor() ([]byte, []int) + func (*NextStateRequest) ProtoMessage() + func (x *NextStateRequest) GetGoal() *State + func (x *NextStateRequest) GetProfiles() map[string]*Profile + func (x *NextStateRequest) GetState() *State + func (x *NextStateRequest) ProtoReflect() protoreflect.Message + func (x *NextStateRequest) Reset() + func (x *NextStateRequest) String() string + type NextStateResponse struct + Actions []*Action + States []*State + Utilities []float64 + func (*NextStateResponse) Descriptor() ([]byte, []int) + func (*NextStateResponse) ProtoMessage() + func (x *NextStateResponse) GetActions() []*Action + func (x *NextStateResponse) GetStates() []*State + func (x *NextStateResponse) GetUtilities() []float64 + func (x *NextStateResponse) ProtoReflect() protoreflect.Message + func (x *NextStateResponse) Reset() + func (x *NextStateResponse) String() string + type PerformRequest struct + Plan []*Action + State *State + func (*PerformRequest) Descriptor() ([]byte, []int) + func (*PerformRequest) ProtoMessage() + func (x *PerformRequest) GetPlan() []*Action + func (x *PerformRequest) GetState() *State + func (x *PerformRequest) ProtoReflect() protoreflect.Message + func (x *PerformRequest) Reset() + func (x *PerformRequest) String() string + type PluginInfo struct + Endpoint string + Name string + SupportedVersions string + Type PluginType + func (*PluginInfo) Descriptor() ([]byte, []int) + func (*PluginInfo) ProtoMessage() + func (x *PluginInfo) GetEndpoint() string + func (x *PluginInfo) GetName() string + func (x *PluginInfo) GetSupportedVersions() string + func (x *PluginInfo) GetType() PluginType + func (x *PluginInfo) ProtoReflect() protoreflect.Message + func (x *PluginInfo) Reset() + func (x *PluginInfo) String() string + type PluginType int32 + const PluginType_ACTUATOR + const PluginType_PLANNER + func (PluginType) Descriptor() protoreflect.EnumDescriptor + func (PluginType) EnumDescriptor() ([]byte, []int) + func (PluginType) Type() protoreflect.EnumType + func (x PluginType) Enum() *PluginType + func (x PluginType) Number() protoreflect.EnumNumber + func (x PluginType) String() string + type PodState struct + Annotations map[string]string + Availability float64 + NodeName string + QosClass string + Resources map[string]string + State string + func (*PodState) Descriptor() ([]byte, []int) + func (*PodState) ProtoMessage() + func (x *PodState) GetAnnotations() map[string]string + func (x *PodState) GetAvailability() float64 + func (x *PodState) GetNodeName() string + func (x *PodState) GetQosClass() string + func (x *PodState) GetResources() map[string]string + func (x *PodState) GetState() string + func (x *PodState) ProtoReflect() protoreflect.Message + func (x *PodState) Reset() + func (x *PodState) String() string + type Profile struct + Address string + External bool + Key string + ProfileType ProfileType + Query string + func (*Profile) Descriptor() ([]byte, []int) + func (*Profile) ProtoMessage() + func (x *Profile) GetAddress() string + func (x *Profile) GetExternal() bool + func (x *Profile) GetKey() string + func (x *Profile) GetProfileType() ProfileType + func (x *Profile) GetQuery() string + func (x *Profile) ProtoReflect() protoreflect.Message + func (x *Profile) Reset() + func (x *Profile) String() string + type ProfileType int32 + const ProfileType_AVAILABILITY + const ProfileType_LATENCY + const ProfileType_OBSOLETE + const ProfileType_POWER + const ProfileType_THROUGHPUT + func (ProfileType) Descriptor() protoreflect.EnumDescriptor + func (ProfileType) EnumDescriptor() ([]byte, []int) + func (ProfileType) Type() protoreflect.EnumType + func (x ProfileType) Enum() *ProfileType + func (x ProfileType) Number() protoreflect.EnumNumber + func (x ProfileType) String() string + type PropertyType int32 + const PropertyType_INT_PROPERTY + const PropertyType_STRING_PROPERTY + func (PropertyType) Descriptor() protoreflect.EnumDescriptor + func (PropertyType) EnumDescriptor() ([]byte, []int) + func (PropertyType) Type() protoreflect.EnumType + func (x PropertyType) Enum() *PropertyType + func (x PropertyType) Number() protoreflect.EnumNumber + func (x PropertyType) String() string + type RegisterRequest struct + PInfo *PluginInfo + func (*RegisterRequest) Descriptor() ([]byte, []int) + func (*RegisterRequest) ProtoMessage() + func (x *RegisterRequest) GetPInfo() *PluginInfo + func (x *RegisterRequest) ProtoReflect() protoreflect.Message + func (x *RegisterRequest) Reset() + func (x *RegisterRequest) String() string + type RegistrationClient interface + Register func(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegistrationStatusResponse, error) + func NewRegistrationClient(cc grpc.ClientConnInterface) RegistrationClient + type RegistrationServer interface + Register func(context.Context, *RegisterRequest) (*RegistrationStatusResponse, error) + type RegistrationStatusResponse struct + Error string + PluginRegistered bool + func (*RegistrationStatusResponse) Descriptor() ([]byte, []int) + func (*RegistrationStatusResponse) ProtoMessage() + func (x *RegistrationStatusResponse) GetError() string + func (x *RegistrationStatusResponse) GetPluginRegistered() bool + func (x *RegistrationStatusResponse) ProtoReflect() protoreflect.Message + func (x *RegistrationStatusResponse) Reset() + func (x *RegistrationStatusResponse) String() string + type State struct + CurrentData map[string]*DataEntry + CurrentPods map[string]*PodState + Intent *Intent + func (*State) Descriptor() ([]byte, []int) + func (*State) ProtoMessage() + func (x *State) GetCurrentData() map[string]*DataEntry + func (x *State) GetCurrentPods() map[string]*PodState + func (x *State) GetIntent() *Intent + func (x *State) ProtoReflect() protoreflect.Message + func (x *State) Reset() + func (x *State) String() string + type UnimplementedActuatorPluginServer struct + func (UnimplementedActuatorPluginServer) Effect(context.Context, *EffectRequest) (*Empty, error) + func (UnimplementedActuatorPluginServer) NextState(context.Context, *NextStateRequest) (*NextStateResponse, error) + func (UnimplementedActuatorPluginServer) Perform(context.Context, *PerformRequest) (*Empty, error) + type UnimplementedRegistrationServer struct + func (UnimplementedRegistrationServer) Register(context.Context, *RegisterRequest) (*RegistrationStatusResponse, error) + type UnsafeActuatorPluginServer interface + type UnsafeRegistrationServer interface