plugins

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Apr 12, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	PluginType_name = map[int32]string{
		0: "ACTUATOR",
		1: "PLANNER",
	}
	PluginType_value = map[string]int32{
		"ACTUATOR": 0,
		"PLANNER":  1,
	}
)

Enum value maps for PluginType.

View Source 
var (
	ProfileType_name = map[int32]string{
		0: "OBSOLETE",
		1: "LATENCY",
		2: "AVAILABILITY",
		3: "THROUGHPUT",
		4: "POWER",
	}
	ProfileType_value = map[string]int32{
		"OBSOLETE":     0,
		"LATENCY":      1,
		"AVAILABILITY": 2,
		"THROUGHPUT":   3,
		"POWER":        4,
	}
)

Enum value maps for ProfileType.

View Source 
var (
	PropertyType_name = map[int32]string{
		0: "INT_PROPERTY",
		1: "STRING_PROPERTY",
	}
	PropertyType_value = map[string]int32{
		"INT_PROPERTY":    0,
		"STRING_PROPERTY": 1,
	}
)

Enum value maps for PropertyType.

View Source 
var ActuatorPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "plugins.ActuatorPlugin",
	HandlerType: (*ActuatorPluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Perform",
			Handler:    _ActuatorPlugin_Perform_Handler,
		},
		{
			MethodName: "Effect",
			Handler:    _ActuatorPlugin_Effect_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "NextState",
			Handler:       _ActuatorPlugin_NextState_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "pkg/api/plugins/v1alpha1/protobufs/api.proto",
}

ActuatorPlugin_ServiceDesc is the grpc.ServiceDesc for ActuatorPlugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_pkg_api_plugins_v1alpha1_protobufs_api_proto protoreflect.FileDescriptor
View Source 
var Registration_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "plugins.Registration",
	HandlerType: (*RegistrationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Register",
			Handler:    _Registration_Register_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/api/plugins/v1alpha1/protobufs/api.proto",
}

Registration_ServiceDesc is the grpc.ServiceDesc for Registration service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterActuatorPluginServer 

func RegisterActuatorPluginServer(s grpc.ServiceRegistrar, srv ActuatorPluginServer)

func RegisterRegistrationServer 

func RegisterRegistrationServer(s grpc.ServiceRegistrar, srv RegistrationServer)

Types

type Action 

type Action struct {
	Name       string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Properties *ActionProperties `protobuf:"bytes,2,opt,name=properties,proto3" json:"properties,omitempty"`
	// contains filtered or unexported fields
}

Action action grpc type consisting of name and properties

func (*Action) Descriptor deprecated 

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

Deprecated: Use Action.ProtoReflect.Descriptor instead.

func (*Action) GetName 

func (x *Action) GetName() string

func (*Action) GetProperties 

func (x *Action) GetProperties() *ActionProperties

func (*Action) ProtoMessage 

func (*Action) ProtoMessage()

func (*Action) ProtoReflect 

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

func (*Action) Reset 

func (x *Action) Reset()

func (*Action) String 

func (x *Action) String() string

type ActionProperties 

type ActionProperties struct {
	Type          PropertyType      `protobuf:"varint,1,opt,name=type,proto3,enum=plugins.PropertyType" json:"type,omitempty"`
	IntProperties map[string]int32  `` /* 168-byte string literal not displayed */
	StrProperties map[string]string `` /* 167-byte string literal not displayed */
	// contains filtered or unexported fields
}

ActionProperties action properties

func (*ActionProperties) Descriptor deprecated 

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

Deprecated: Use ActionProperties.ProtoReflect.Descriptor instead.

func (*ActionProperties) GetIntProperties 

func (x *ActionProperties) GetIntProperties() map[string]int32

func (*ActionProperties) GetStrProperties 

func (x *ActionProperties) GetStrProperties() map[string]string

func (*ActionProperties) GetType 

func (x *ActionProperties) GetType() PropertyType

func (*ActionProperties) ProtoMessage 

func (*ActionProperties) ProtoMessage()

func (*ActionProperties) ProtoReflect 

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

func (*ActionProperties) Reset 

func (x *ActionProperties) Reset()

func (*ActionProperties) String 

func (x *ActionProperties) String() string

type ActuatorPluginClient 

type ActuatorPluginClient interface {
	// NextState should return a set of potential follow-up states for a given state if this actuator would potentially be used.
	NextState(ctx context.Context, opts ...grpc.CallOption) (ActuatorPlugin_NextStateClient, error)
	// Perform should perform those actions of the plan that it is in charge of
	Perform(ctx context.Context, in *PerformRequest, opts ...grpc.CallOption) (*Empty, error)
	// Effect should (optionally) recalculate the effect this actuator has for ALL objectives for this workload.
	Effect(ctx context.Context, in *EffectRequest, opts ...grpc.CallOption) (*Empty, error)
}

ActuatorPluginClient is the client API for ActuatorPlugin 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 NewActuatorPluginClient 

func NewActuatorPluginClient(cc grpc.ClientConnInterface) ActuatorPluginClient

type ActuatorPluginServer 

type ActuatorPluginServer interface {
	// NextState should return a set of potential follow-up states for a given state if this actuator would potentially be used.
	NextState(ActuatorPlugin_NextStateServer) error
	// Perform should perform those actions of the plan that it is in charge of
	Perform(context.Context, *PerformRequest) (*Empty, error)
	// Effect should (optionally) recalculate the effect this actuator has for ALL objectives for this workload.
	Effect(context.Context, *EffectRequest) (*Empty, error)
	// contains filtered or unexported methods
}

ActuatorPluginServer is the server API for ActuatorPlugin service. All implementations must embed UnimplementedActuatorPluginServer for forward compatibility

type ActuatorPlugin_NextStateClient added in v0.2.0 

type ActuatorPlugin_NextStateClient interface {
	Send(*NextStateRequest) error
	Recv() (*NextStateResponse, error)
	grpc.ClientStream
}

type ActuatorPlugin_NextStateServer added in v0.2.0 

type ActuatorPlugin_NextStateServer interface {
	Send(*NextStateResponse) error
	Recv() (*NextStateRequest, error)
	grpc.ServerStream
}

type DataEntry 

type DataEntry struct {
	Data map[string]float64 `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

DataEntry pod data

func (*DataEntry) Descriptor deprecated 

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

Deprecated: Use DataEntry.ProtoReflect.Descriptor instead.

func (*DataEntry) GetData 

func (x *DataEntry) GetData() map[string]float64

func (*DataEntry) ProtoMessage 

func (*DataEntry) ProtoMessage()

func (*DataEntry) ProtoReflect 

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

func (*DataEntry) Reset 

func (x *DataEntry) Reset()

func (*DataEntry) String 

func (x *DataEntry) String() string

type EffectRequest 

type EffectRequest struct {
	State    *State              `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	Profiles map[string]*Profile `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

PerformRequest effect request passed via grpc as input for remote actuators to trigger the effect function

func (*EffectRequest) Descriptor deprecated 

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

Deprecated: Use EffectRequest.ProtoReflect.Descriptor instead.

func (*EffectRequest) GetProfiles 

func (x *EffectRequest) GetProfiles() map[string]*Profile

func (*EffectRequest) GetState 

func (x *EffectRequest) GetState() *State

func (*EffectRequest) ProtoMessage 

func (*EffectRequest) ProtoMessage()

func (*EffectRequest) ProtoReflect 

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

func (*EffectRequest) Reset 

func (x *EffectRequest) Reset()

func (*EffectRequest) String 

func (x *EffectRequest) String() string

type Empty 

type Empty struct {
	// contains filtered or unexported fields
}

Empty empty response

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type Intent 

type Intent struct {
	Key        string             `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Priority   float64            `protobuf:"fixed64,2,opt,name=priority,proto3" json:"priority,omitempty"`
	TargetKey  string             `protobuf:"bytes,3,opt,name=target_key,json=targetKey,proto3" json:"target_key,omitempty"`
	TargetKind string             `protobuf:"bytes,4,opt,name=target_kind,json=targetKind,proto3" json:"target_kind,omitempty"`
	Objectives map[string]float64 `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

Intent holds information about an intent in the system. Intent struct

func (*Intent) Descriptor deprecated 

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

Deprecated: Use Intent.ProtoReflect.Descriptor instead.

func (*Intent) GetKey 

func (x *Intent) GetKey() string

func (*Intent) GetObjectives 

func (x *Intent) GetObjectives() map[string]float64

func (*Intent) GetPriority 

func (x *Intent) GetPriority() float64

func (*Intent) GetTargetKey 

func (x *Intent) GetTargetKey() string

func (*Intent) GetTargetKind 

func (x *Intent) GetTargetKind() string

func (*Intent) ProtoMessage 

func (*Intent) ProtoMessage()

func (*Intent) ProtoReflect 

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

func (*Intent) Reset 

func (x *Intent) Reset()

func (*Intent) String 

func (x *Intent) String() string

type NextStateRequest 

type NextStateRequest struct {
	State    *State              `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	Goal     *State              `protobuf:"bytes,2,opt,name=goal,proto3" json:"goal,omitempty"`
	Profiles map[string]*Profile `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

NextStateRequest next state request passed via grpc as input for remote actuators to trigger the next state function

func (*NextStateRequest) Descriptor deprecated 

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

Deprecated: Use NextStateRequest.ProtoReflect.Descriptor instead.

func (*NextStateRequest) GetGoal 

func (x *NextStateRequest) GetGoal() *State

func (*NextStateRequest) GetProfiles 

func (x *NextStateRequest) GetProfiles() map[string]*Profile

func (*NextStateRequest) GetState 

func (x *NextStateRequest) GetState() *State

func (*NextStateRequest) ProtoMessage 

func (*NextStateRequest) ProtoMessage()

func (*NextStateRequest) ProtoReflect 

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

func (*NextStateRequest) Reset 

func (x *NextStateRequest) Reset()

func (*NextStateRequest) String 

func (x *NextStateRequest) String() string

type NextStateResponse 

type NextStateResponse struct {
	States    []*State  `protobuf:"bytes,1,rep,name=states,proto3" json:"states,omitempty"`
	Utilities []float64 `protobuf:"fixed64,2,rep,packed,name=utilities,proto3" json:"utilities,omitempty"`
	Actions   []*Action `protobuf:"bytes,3,rep,name=actions,proto3" json:"actions,omitempty"`
	// contains filtered or unexported fields
}

NextStateResponse response of the remote actual grpc call

func (*NextStateResponse) Descriptor deprecated 

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

Deprecated: Use NextStateResponse.ProtoReflect.Descriptor instead.

func (*NextStateResponse) GetActions 

func (x *NextStateResponse) GetActions() []*Action

func (*NextStateResponse) GetStates 

func (x *NextStateResponse) GetStates() []*State

func (*NextStateResponse) GetUtilities 

func (x *NextStateResponse) GetUtilities() []float64

func (*NextStateResponse) ProtoMessage 

func (*NextStateResponse) ProtoMessage()

func (*NextStateResponse) ProtoReflect 

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

func (*NextStateResponse) Reset 

func (x *NextStateResponse) Reset()

func (*NextStateResponse) String 

func (x *NextStateResponse) String() string

type PerformRequest 

type PerformRequest struct {
	State *State    `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	Plan  []*Action `protobuf:"bytes,2,rep,name=plan,proto3" json:"plan,omitempty"`
	// contains filtered or unexported fields
}

PerformRequest perform request passed via grpc as input for remote actuators to trigger the perform function

func (*PerformRequest) Descriptor deprecated 

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

Deprecated: Use PerformRequest.ProtoReflect.Descriptor instead.

func (*PerformRequest) GetPlan 

func (x *PerformRequest) GetPlan() []*Action

func (*PerformRequest) GetState 

func (x *PerformRequest) GetState() *State

func (*PerformRequest) ProtoMessage 

func (*PerformRequest) ProtoMessage()

func (*PerformRequest) ProtoReflect 

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

func (*PerformRequest) Reset 

func (x *PerformRequest) Reset()

func (*PerformRequest) String 

func (x *PerformRequest) String() string

type PluginInfo 

type PluginInfo struct {

	// Type of the Plugin. Actuator Plugin or Planner Plugin
	Type PluginType `protobuf:"varint,1,opt,name=type,proto3,enum=plugins.PluginType" json:"type,omitempty"`
	// Plugin name that uniquely identifies the plugin for the given plugin type.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Mandatory endpoint location, it usually represents an internal ip to the pod
	// which will handle all plugin requests.
	Endpoint string `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// Plugin service API versions the plugin supports.
	SupportedVersions string `protobuf:"bytes,4,opt,name=supported_versions,json=supportedVersions,proto3" json:"supported_versions,omitempty"`
	// contains filtered or unexported fields
}

PluginInfo is the message sent from a plugin to the IDO pluginwatcher for plugin registration

func (*PluginInfo) Descriptor deprecated 

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

Deprecated: Use PluginInfo.ProtoReflect.Descriptor instead.

func (*PluginInfo) GetEndpoint 

func (x *PluginInfo) GetEndpoint() string

func (*PluginInfo) GetName 

func (x *PluginInfo) GetName() string

func (*PluginInfo) GetSupportedVersions 

func (x *PluginInfo) GetSupportedVersions() string

func (*PluginInfo) GetType 

func (x *PluginInfo) GetType() PluginType

func (*PluginInfo) ProtoMessage 

func (*PluginInfo) ProtoMessage()

func (*PluginInfo) ProtoReflect 

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

func (*PluginInfo) Reset 

func (x *PluginInfo) Reset()

func (*PluginInfo) String 

func (x *PluginInfo) String() string

type PluginType 

type PluginType int32

PluginType type of the plugin : can be actuator or planner plugin 

const (
	PluginType_ACTUATOR PluginType = 0
	PluginType_PLANNER  PluginType = 1
)

func (PluginType) Descriptor 

func (PluginType) Descriptor() protoreflect.EnumDescriptor

func (PluginType) Enum 

func (x PluginType) Enum() *PluginType

func (PluginType) EnumDescriptor deprecated 

func (PluginType) EnumDescriptor() ([]byte, []int)

Deprecated: Use PluginType.Descriptor instead.

func (PluginType) Number 

func (x PluginType) Number() protoreflect.EnumNumber

func (PluginType) String 

func (x PluginType) String() string

func (PluginType) Type 

func (PluginType) Type() protoreflect.EnumType

type PodState 

type PodState struct {
	Availability float64 `protobuf:"fixed64,1,opt,name=availability,proto3" json:"availability,omitempty"`
	NodeName     string  `protobuf:"bytes,2,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	State        string  `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	QosClass     string  `protobuf:"bytes,4,opt,name=qos_class,json=qosClass,proto3" json:"qos_class,omitempty"`
	// contains filtered or unexported fields
}

PodState the state of a pod

func (*PodState) Descriptor deprecated 

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

Deprecated: Use PodState.ProtoReflect.Descriptor instead.

func (*PodState) GetAvailability 

func (x *PodState) GetAvailability() float64

func (*PodState) GetNodeName 

func (x *PodState) GetNodeName() string

func (*PodState) GetQosClass 

func (x *PodState) GetQosClass() string

func (*PodState) GetState 

func (x *PodState) GetState() string

func (*PodState) ProtoMessage 

func (*PodState) ProtoMessage()

func (*PodState) ProtoReflect 

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

func (*PodState) Reset 

func (x *PodState) Reset()

func (*PodState) String 

func (x *PodState) String() string

type Profile 

type Profile struct {
	Key         string      `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	ProfileType ProfileType `protobuf:"varint,2,opt,name=profile_type,json=profileType,proto3,enum=plugins.ProfileType" json:"profile_type,omitempty"`
	// contains filtered or unexported fields
}

Profile holds information about valid objective profiles.

func (*Profile) Descriptor deprecated 

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

Deprecated: Use Profile.ProtoReflect.Descriptor instead.

func (*Profile) GetKey 

func (x *Profile) GetKey() string

func (*Profile) GetProfileType 

func (x *Profile) GetProfileType() ProfileType

func (*Profile) ProtoMessage 

func (*Profile) ProtoMessage()

func (*Profile) ProtoReflect 

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

func (*Profile) Reset 

func (x *Profile) Reset()

func (*Profile) String 

func (x *Profile) String() string

type ProfileType 

type ProfileType int32

ProfileType defines the type of KPI Profiles. 

const (
	ProfileType_OBSOLETE     ProfileType = 0
	ProfileType_LATENCY      ProfileType = 1
	ProfileType_AVAILABILITY ProfileType = 2
	ProfileType_THROUGHPUT   ProfileType = 3
	ProfileType_POWER        ProfileType = 4
)

func (ProfileType) Descriptor 

func (ProfileType) Descriptor() protoreflect.EnumDescriptor

func (ProfileType) Enum 

func (x ProfileType) Enum() *ProfileType

func (ProfileType) EnumDescriptor deprecated 

func (ProfileType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ProfileType.Descriptor instead.

func (ProfileType) Number 

func (x ProfileType) Number() protoreflect.EnumNumber

func (ProfileType) String 

func (x ProfileType) String() string

func (ProfileType) Type 

func (ProfileType) Type() protoreflect.EnumType

type PropertyType 

type PropertyType int32

PropertyType type of property: integer or string 

const (
	PropertyType_INT_PROPERTY    PropertyType = 0
	PropertyType_STRING_PROPERTY PropertyType = 1
)

func (PropertyType) Descriptor 

func (PropertyType) Descriptor() protoreflect.EnumDescriptor

func (PropertyType) Enum 

func (x PropertyType) Enum() *PropertyType

func (PropertyType) EnumDescriptor deprecated 

func (PropertyType) EnumDescriptor() ([]byte, []int)

Deprecated: Use PropertyType.Descriptor instead.

func (PropertyType) Number 

func (x PropertyType) Number() protoreflect.EnumNumber

func (PropertyType) String 

func (x PropertyType) String() string

func (PropertyType) Type 

func (PropertyType) Type() protoreflect.EnumType

type RegisterRequest 

type RegisterRequest struct {
	PInfo *PluginInfo `protobuf:"bytes,1,opt,name=pInfo,proto3" json:"pInfo,omitempty"`
	// contains filtered or unexported fields
}

RegisterRequest A request to register a new plugin with given plugin info struct

func (*RegisterRequest) Descriptor deprecated 

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

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetPInfo 

func (x *RegisterRequest) GetPInfo() *PluginInfo

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect 

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

func (*RegisterRequest) Reset 

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (x *RegisterRequest) String() string

type RegistrationClient 

type RegistrationClient interface {
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegistrationStatusResponse, error)
}

RegistrationClient is the client API for Registration 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 NewRegistrationClient 

func NewRegistrationClient(cc grpc.ClientConnInterface) RegistrationClient

type RegistrationServer 

type RegistrationServer interface {
	Register(context.Context, *RegisterRequest) (*RegistrationStatusResponse, error)
	// contains filtered or unexported methods
}

RegistrationServer is the server API for Registration service. All implementations must embed UnimplementedRegistrationServer for forward compatibility

type RegistrationStatusResponse 

type RegistrationStatusResponse struct {

	// True if plugin gets registered successfully at ido controller
	PluginRegistered bool `protobuf:"varint,1,opt,name=plugin_registered,json=pluginRegistered,proto3" json:"plugin_registered,omitempty"`
	// Error message in case plugin fails to register, empty string otherwise
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

RegistrationStatus is the message sent from IDO pluginwatcher to the plugin for notification on registration status

func (*RegistrationStatusResponse) Descriptor deprecated 

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

Deprecated: Use RegistrationStatusResponse.ProtoReflect.Descriptor instead.

func (*RegistrationStatusResponse) GetError 

func (x *RegistrationStatusResponse) GetError() string

func (*RegistrationStatusResponse) GetPluginRegistered 

func (x *RegistrationStatusResponse) GetPluginRegistered() bool

func (*RegistrationStatusResponse) ProtoMessage 

func (*RegistrationStatusResponse) ProtoMessage()

func (*RegistrationStatusResponse) ProtoReflect 

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

func (*RegistrationStatusResponse) Reset 

func (x *RegistrationStatusResponse) Reset()

func (*RegistrationStatusResponse) String 

func (x *RegistrationStatusResponse) String() string

type State 

type State struct {
	Intent      *Intent               `protobuf:"bytes,1,opt,name=intent,proto3" json:"intent,omitempty"`
	CurrentPods map[string]*PodState  `` /* 182-byte string literal not displayed */
	CurrentData map[string]*DataEntry `` /* 182-byte string literal not displayed */
	Resources   map[string]string     `` /* 159-byte string literal not displayed */
	Annotations map[string]string     `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

State IDO State representation

func (*State) Descriptor deprecated 

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

Deprecated: Use State.ProtoReflect.Descriptor instead.

func (*State) GetAnnotations added in v0.2.0 

func (x *State) GetAnnotations() map[string]string

func (*State) GetCurrentData 

func (x *State) GetCurrentData() map[string]*DataEntry

func (*State) GetCurrentPods 

func (x *State) GetCurrentPods() map[string]*PodState

func (*State) GetIntent 

func (x *State) GetIntent() *Intent

func (*State) GetResources added in v0.2.0 

func (x *State) GetResources() map[string]string

func (*State) ProtoMessage 

func (*State) ProtoMessage()

func (*State) ProtoReflect 

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

func (*State) Reset 

func (x *State) Reset()

func (*State) String 

func (x *State) String() string

type UnimplementedActuatorPluginServer 

type UnimplementedActuatorPluginServer struct {
}

UnimplementedActuatorPluginServer must be embedded to have forward compatible implementations.

func (UnimplementedActuatorPluginServer) Effect 

func (UnimplementedActuatorPluginServer) Effect(context.Context, *EffectRequest) (*Empty, error)

func (UnimplementedActuatorPluginServer) NextState 

func (UnimplementedActuatorPluginServer) NextState(ActuatorPlugin_NextStateServer) error

func (UnimplementedActuatorPluginServer) Perform 

func (UnimplementedActuatorPluginServer) Perform(context.Context, *PerformRequest) (*Empty, error)

type UnimplementedRegistrationServer 

type UnimplementedRegistrationServer struct {
}

UnimplementedRegistrationServer must be embedded to have forward compatible implementations.

func (UnimplementedRegistrationServer) Register 

func (UnimplementedRegistrationServer) Register(context.Context, *RegisterRequest) (*RegistrationStatusResponse, error)

type UnsafeActuatorPluginServer 

type UnsafeActuatorPluginServer interface {
	// contains filtered or unexported methods
}

UnsafeActuatorPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ActuatorPluginServer will result in compilation errors.

type UnsafeRegistrationServer 

type UnsafeRegistrationServer interface {
	// contains filtered or unexported methods
}

UnsafeRegistrationServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RegistrationServer will result in compilation errors.

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.