pb_systemmanager_messages

package
v1.2.1 Latest Latest
Warning

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

Go to latest
Published: Jan 25, 2024 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ServiceStatus_Status_name = map[int32]string{
		0: "UNKNOWN",
		1: "RUNNING",
		2: "STOPPED",
		3: "NOT_REGISTERED",
	}
	ServiceStatus_Status_value = map[string]int32{
		"UNKNOWN":        0,
		"RUNNING":        1,
		"STOPPED":        2,
		"NOT_REGISTERED": 3,
	}
)

Enum value maps for ServiceStatus_Status.

View Source
var (
	ServiceOrder_OrderType_name = map[int32]string{
		0: "STOP",
		1: "KILL",
		2: "FORCE_RESTART",
	}
	ServiceOrder_OrderType_value = map[string]int32{
		"STOP":          0,
		"KILL":          1,
		"FORCE_RESTART": 2,
	}
)

Enum value maps for ServiceOrder_OrderType.

View Source
var File_systemmanager_servicediscovery_proto protoreflect.FileDescriptor
View Source
var File_systemmanager_tuningstate_proto protoreflect.FileDescriptor
View Source
var File_systemmanager_wrapper_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Service

type Service struct {
	Identifier *ServiceIdentifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	Endpoints  []*ServiceEndpoint `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	// contains filtered or unexported fields
}

A description of a service, sent by a service to register itself or broadcasted by the system manager

func (*Service) Descriptor deprecated

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

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetEndpoints

func (x *Service) GetEndpoints() []*ServiceEndpoint

func (*Service) GetIdentifier

func (x *Service) GetIdentifier() *ServiceIdentifier

func (*Service) ProtoMessage

func (*Service) ProtoMessage()

func (*Service) ProtoReflect

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

func (*Service) Reset

func (x *Service) Reset()

func (*Service) String

func (x *Service) String() string

type ServiceEndpoint

type ServiceEndpoint struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`       // the identifier to select this endpoint
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` // the zmq address to connect to
	// contains filtered or unexported fields
}

An endpoint that is made available by a service

func (*ServiceEndpoint) Descriptor deprecated

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

Deprecated: Use ServiceEndpoint.ProtoReflect.Descriptor instead.

func (*ServiceEndpoint) GetAddress

func (x *ServiceEndpoint) GetAddress() string

func (*ServiceEndpoint) GetName

func (x *ServiceEndpoint) GetName() string

func (*ServiceEndpoint) ProtoMessage

func (*ServiceEndpoint) ProtoMessage()

func (*ServiceEndpoint) ProtoReflect

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

func (*ServiceEndpoint) Reset

func (x *ServiceEndpoint) Reset()

func (*ServiceEndpoint) String

func (x *ServiceEndpoint) String() string

type ServiceIdentifier

type ServiceIdentifier struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Pid  int32  `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

Used to identify a service within the system

func (*ServiceIdentifier) Descriptor deprecated

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

Deprecated: Use ServiceIdentifier.ProtoReflect.Descriptor instead.

func (*ServiceIdentifier) GetName

func (x *ServiceIdentifier) GetName() string

func (*ServiceIdentifier) GetPid

func (x *ServiceIdentifier) GetPid() int32

func (*ServiceIdentifier) ProtoMessage

func (*ServiceIdentifier) ProtoMessage()

func (*ServiceIdentifier) ProtoReflect

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

func (*ServiceIdentifier) Reset

func (x *ServiceIdentifier) Reset()

func (*ServiceIdentifier) String

func (x *ServiceIdentifier) String() string

type ServiceInformationRequest

type ServiceInformationRequest struct {
	Requested *ServiceIdentifier `protobuf:"bytes,1,opt,name=requested,proto3" json:"requested,omitempty"`
	// contains filtered or unexported fields
}

When a service requests information about other services, it sends an InformationRequest message

func (*ServiceInformationRequest) Descriptor deprecated

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

Deprecated: Use ServiceInformationRequest.ProtoReflect.Descriptor instead.

func (*ServiceInformationRequest) GetRequested

func (x *ServiceInformationRequest) GetRequested() *ServiceIdentifier

func (*ServiceInformationRequest) ProtoMessage

func (*ServiceInformationRequest) ProtoMessage()

func (*ServiceInformationRequest) ProtoReflect

func (*ServiceInformationRequest) Reset

func (x *ServiceInformationRequest) Reset()

func (*ServiceInformationRequest) String

func (x *ServiceInformationRequest) String() string

type ServiceOrder

type ServiceOrder struct {

	// The service this order is for
	Service *ServiceIdentifier     `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Order   ServiceOrder_OrderType `protobuf:"varint,2,opt,name=order,proto3,enum=protobuf_msgs.ServiceOrder_OrderType" json:"order,omitempty"`
	// contains filtered or unexported fields
}

The system manager can order services to stop/restart by sending a service order

func (*ServiceOrder) Descriptor deprecated

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

Deprecated: Use ServiceOrder.ProtoReflect.Descriptor instead.

func (*ServiceOrder) GetOrder

func (x *ServiceOrder) GetOrder() ServiceOrder_OrderType

func (*ServiceOrder) GetService

func (x *ServiceOrder) GetService() *ServiceIdentifier

func (*ServiceOrder) ProtoMessage

func (*ServiceOrder) ProtoMessage()

func (*ServiceOrder) ProtoReflect

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

func (*ServiceOrder) Reset

func (x *ServiceOrder) Reset()

func (*ServiceOrder) String

func (x *ServiceOrder) String() string

type ServiceOrder_OrderType

type ServiceOrder_OrderType int32
const (
	ServiceOrder_STOP          ServiceOrder_OrderType = 0 // will attempt a graceful shutdown
	ServiceOrder_KILL          ServiceOrder_OrderType = 1 // will kill the service immediately
	ServiceOrder_FORCE_RESTART ServiceOrder_OrderType = 2 // will kill the service immediately and restart
)

func (ServiceOrder_OrderType) Descriptor

func (ServiceOrder_OrderType) Enum

func (ServiceOrder_OrderType) EnumDescriptor deprecated

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

Deprecated: Use ServiceOrder_OrderType.Descriptor instead.

func (ServiceOrder_OrderType) Number

func (ServiceOrder_OrderType) String

func (x ServiceOrder_OrderType) String() string

func (ServiceOrder_OrderType) Type

type ServiceStatus

type ServiceStatus struct {
	Service *Service             `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Status  ServiceStatus_Status `protobuf:"varint,2,opt,name=status,proto3,enum=protobuf_msgs.ServiceStatus_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

When the system manager sends information about a service, it sends an Information message Also used to broadcast registrations to all services

func (*ServiceStatus) Descriptor deprecated

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

Deprecated: Use ServiceStatus.ProtoReflect.Descriptor instead.

func (*ServiceStatus) GetService

func (x *ServiceStatus) GetService() *Service

func (*ServiceStatus) GetStatus

func (x *ServiceStatus) GetStatus() ServiceStatus_Status

func (*ServiceStatus) ProtoMessage

func (*ServiceStatus) ProtoMessage()

func (*ServiceStatus) ProtoReflect

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

func (*ServiceStatus) Reset

func (x *ServiceStatus) Reset()

func (*ServiceStatus) String

func (x *ServiceStatus) String() string

type ServiceStatus_Status

type ServiceStatus_Status int32
const (
	ServiceStatus_UNKNOWN        ServiceStatus_Status = 0
	ServiceStatus_RUNNING        ServiceStatus_Status = 1
	ServiceStatus_STOPPED        ServiceStatus_Status = 2
	ServiceStatus_NOT_REGISTERED ServiceStatus_Status = 3
)

func (ServiceStatus_Status) Descriptor

func (ServiceStatus_Status) Enum

func (ServiceStatus_Status) EnumDescriptor deprecated

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

Deprecated: Use ServiceStatus_Status.Descriptor instead.

func (ServiceStatus_Status) Number

func (ServiceStatus_Status) String

func (x ServiceStatus_Status) String() string

func (ServiceStatus_Status) Type

type SystemManagerMessage added in v0.2.5

type SystemManagerMessage struct {

	// Types that are assignable to Msg:
	//
	//	*SystemManagerMessage_Service
	//	*SystemManagerMessage_ServiceInformationRequest
	//	*SystemManagerMessage_ServiceStatus
	//	*SystemManagerMessage_ServiceOrder
	//	*SystemManagerMessage_TuningState
	//	*SystemManagerMessage_TuningStateRequest
	Msg isSystemManagerMessage_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

func (*SystemManagerMessage) Descriptor deprecated added in v0.2.5

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

Deprecated: Use SystemManagerMessage.ProtoReflect.Descriptor instead.

func (*SystemManagerMessage) GetMsg added in v0.2.5

func (m *SystemManagerMessage) GetMsg() isSystemManagerMessage_Msg

func (*SystemManagerMessage) GetService added in v0.2.5

func (x *SystemManagerMessage) GetService() *Service

func (*SystemManagerMessage) GetServiceInformationRequest added in v0.2.5

func (x *SystemManagerMessage) GetServiceInformationRequest() *ServiceInformationRequest

func (*SystemManagerMessage) GetServiceOrder added in v0.2.5

func (x *SystemManagerMessage) GetServiceOrder() *ServiceOrder

func (*SystemManagerMessage) GetServiceStatus added in v0.2.5

func (x *SystemManagerMessage) GetServiceStatus() *ServiceStatus

func (*SystemManagerMessage) GetTuningState added in v0.2.5

func (x *SystemManagerMessage) GetTuningState() *TuningState

func (*SystemManagerMessage) GetTuningStateRequest added in v0.2.5

func (x *SystemManagerMessage) GetTuningStateRequest() *TuningStateRequest

func (*SystemManagerMessage) ProtoMessage added in v0.2.5

func (*SystemManagerMessage) ProtoMessage()

func (*SystemManagerMessage) ProtoReflect added in v0.2.5

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

func (*SystemManagerMessage) Reset added in v0.2.5

func (x *SystemManagerMessage) Reset()

func (*SystemManagerMessage) String added in v0.2.5

func (x *SystemManagerMessage) String() string

type SystemManagerMessage_Service added in v0.2.5

type SystemManagerMessage_Service struct {
	Service *Service `protobuf:"bytes,1,opt,name=service,proto3,oneof"`
}

type SystemManagerMessage_ServiceInformationRequest added in v0.2.5

type SystemManagerMessage_ServiceInformationRequest struct {
	ServiceInformationRequest *ServiceInformationRequest `protobuf:"bytes,2,opt,name=serviceInformationRequest,proto3,oneof"`
}

type SystemManagerMessage_ServiceOrder added in v0.2.5

type SystemManagerMessage_ServiceOrder struct {
	ServiceOrder *ServiceOrder `protobuf:"bytes,4,opt,name=serviceOrder,proto3,oneof"`
}

type SystemManagerMessage_ServiceStatus added in v0.2.5

type SystemManagerMessage_ServiceStatus struct {
	ServiceStatus *ServiceStatus `protobuf:"bytes,3,opt,name=serviceStatus,proto3,oneof"`
}

type SystemManagerMessage_TuningState added in v0.2.5

type SystemManagerMessage_TuningState struct {
	TuningState *TuningState `protobuf:"bytes,5,opt,name=tuningState,proto3,oneof"`
}

type SystemManagerMessage_TuningStateRequest added in v0.2.5

type SystemManagerMessage_TuningStateRequest struct {
	TuningStateRequest *TuningStateRequest `protobuf:"bytes,6,opt,name=tuningStateRequest,proto3,oneof"`
}

type TuningState

type TuningState struct {
	Timestamp         uint64                   `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // increased when the state changes, used to prevent unnecessary updates
	DynamicParameters []*TuningState_Parameter `protobuf:"bytes,2,rep,name=dynamicParameters,proto3" json:"dynamicParameters,omitempty"`
	// contains filtered or unexported fields
}

func (*TuningState) Descriptor deprecated

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

Deprecated: Use TuningState.ProtoReflect.Descriptor instead.

func (*TuningState) GetDynamicParameters

func (x *TuningState) GetDynamicParameters() []*TuningState_Parameter

func (*TuningState) GetTimestamp

func (x *TuningState) GetTimestamp() uint64

func (*TuningState) ProtoMessage

func (*TuningState) ProtoMessage()

func (*TuningState) ProtoReflect

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

func (*TuningState) Reset

func (x *TuningState) Reset()

func (*TuningState) String

func (x *TuningState) String() string

type TuningStateRequest added in v0.2.5

type TuningStateRequest struct {
	Timestamp uint64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // the timestamp of the last received state, used to prevent unnecessary updates
	// contains filtered or unexported fields
}

func (*TuningStateRequest) Descriptor deprecated added in v0.2.5

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

Deprecated: Use TuningStateRequest.ProtoReflect.Descriptor instead.

func (*TuningStateRequest) GetTimestamp added in v0.2.5

func (x *TuningStateRequest) GetTimestamp() uint64

func (*TuningStateRequest) ProtoMessage added in v0.2.5

func (*TuningStateRequest) ProtoMessage()

func (*TuningStateRequest) ProtoReflect added in v0.2.5

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

func (*TuningStateRequest) Reset added in v0.2.5

func (x *TuningStateRequest) Reset()

func (*TuningStateRequest) String added in v0.2.5

func (x *TuningStateRequest) String() string

type TuningState_Parameter

type TuningState_Parameter struct {

	// Types that are assignable to Parameter:
	//
	//	*TuningState_Parameter_Float
	//	*TuningState_Parameter_Int
	//	*TuningState_Parameter_String_
	Parameter isTuningState_Parameter_Parameter `protobuf_oneof:"parameter"`
	// contains filtered or unexported fields
}

func (*TuningState_Parameter) Descriptor deprecated

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

Deprecated: Use TuningState_Parameter.ProtoReflect.Descriptor instead.

func (*TuningState_Parameter) GetFloat

func (*TuningState_Parameter) GetInt

func (*TuningState_Parameter) GetParameter

func (m *TuningState_Parameter) GetParameter() isTuningState_Parameter_Parameter

func (*TuningState_Parameter) GetString_

func (*TuningState_Parameter) ProtoMessage

func (*TuningState_Parameter) ProtoMessage()

func (*TuningState_Parameter) ProtoReflect

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

func (*TuningState_Parameter) Reset

func (x *TuningState_Parameter) Reset()

func (*TuningState_Parameter) String

func (x *TuningState_Parameter) String() string

type TuningState_Parameter_Float

type TuningState_Parameter_Float struct {
	Float *TuningState_Parameter_FloatParameter `protobuf:"bytes,1,opt,name=float,proto3,oneof"`
}

type TuningState_Parameter_FloatParameter

type TuningState_Parameter_FloatParameter struct {
	Key   string  `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value float32 `protobuf:"fixed32,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*TuningState_Parameter_FloatParameter) Descriptor deprecated

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

Deprecated: Use TuningState_Parameter_FloatParameter.ProtoReflect.Descriptor instead.

func (*TuningState_Parameter_FloatParameter) GetKey

func (*TuningState_Parameter_FloatParameter) GetValue

func (*TuningState_Parameter_FloatParameter) ProtoMessage

func (*TuningState_Parameter_FloatParameter) ProtoMessage()

func (*TuningState_Parameter_FloatParameter) ProtoReflect

func (*TuningState_Parameter_FloatParameter) Reset

func (*TuningState_Parameter_FloatParameter) String

type TuningState_Parameter_Int

type TuningState_Parameter_Int struct {
	Int *TuningState_Parameter_IntParameter `protobuf:"bytes,2,opt,name=int,proto3,oneof"`
}

type TuningState_Parameter_IntParameter

type TuningState_Parameter_IntParameter struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value int64  `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*TuningState_Parameter_IntParameter) Descriptor deprecated

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

Deprecated: Use TuningState_Parameter_IntParameter.ProtoReflect.Descriptor instead.

func (*TuningState_Parameter_IntParameter) GetKey

func (*TuningState_Parameter_IntParameter) GetValue

func (*TuningState_Parameter_IntParameter) ProtoMessage

func (*TuningState_Parameter_IntParameter) ProtoMessage()

func (*TuningState_Parameter_IntParameter) ProtoReflect

func (*TuningState_Parameter_IntParameter) Reset

func (*TuningState_Parameter_IntParameter) String

type TuningState_Parameter_StringParameter

type TuningState_Parameter_StringParameter struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*TuningState_Parameter_StringParameter) Descriptor deprecated

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

Deprecated: Use TuningState_Parameter_StringParameter.ProtoReflect.Descriptor instead.

func (*TuningState_Parameter_StringParameter) GetKey

func (*TuningState_Parameter_StringParameter) GetValue

func (*TuningState_Parameter_StringParameter) ProtoMessage

func (*TuningState_Parameter_StringParameter) ProtoMessage()

func (*TuningState_Parameter_StringParameter) ProtoReflect

func (*TuningState_Parameter_StringParameter) Reset

func (*TuningState_Parameter_StringParameter) String

type TuningState_Parameter_String_

type TuningState_Parameter_String_ struct {
	String_ *TuningState_Parameter_StringParameter `protobuf:"bytes,3,opt,name=string,proto3,oneof"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL