Documentation
¶
Index ¶
- Variables
- type Service
- func (*Service) Descriptor() ([]byte, []int)deprecated
- func (x *Service) GetEndpoints() []*ServiceEndpoint
- func (x *Service) GetIdentifier() *ServiceIdentifier
- func (*Service) ProtoMessage()
- func (x *Service) ProtoReflect() protoreflect.Message
- func (x *Service) Reset()
- func (x *Service) String() string
- type ServiceEndpoint
- func (*ServiceEndpoint) Descriptor() ([]byte, []int)deprecated
- func (x *ServiceEndpoint) GetAddress() string
- func (x *ServiceEndpoint) GetName() string
- func (*ServiceEndpoint) ProtoMessage()
- func (x *ServiceEndpoint) ProtoReflect() protoreflect.Message
- func (x *ServiceEndpoint) Reset()
- func (x *ServiceEndpoint) String() string
- type ServiceIdentifier
- func (*ServiceIdentifier) Descriptor() ([]byte, []int)deprecated
- func (x *ServiceIdentifier) GetName() string
- func (x *ServiceIdentifier) GetPid() int32
- func (*ServiceIdentifier) ProtoMessage()
- func (x *ServiceIdentifier) ProtoReflect() protoreflect.Message
- func (x *ServiceIdentifier) Reset()
- func (x *ServiceIdentifier) String() string
- type ServiceInformationRequest
- func (*ServiceInformationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ServiceInformationRequest) GetRequested() *ServiceIdentifier
- func (*ServiceInformationRequest) ProtoMessage()
- func (x *ServiceInformationRequest) ProtoReflect() protoreflect.Message
- func (x *ServiceInformationRequest) Reset()
- func (x *ServiceInformationRequest) String() string
- type ServiceOrder
- func (*ServiceOrder) Descriptor() ([]byte, []int)deprecated
- func (x *ServiceOrder) GetOrder() ServiceOrder_OrderType
- func (x *ServiceOrder) GetService() *ServiceIdentifier
- func (*ServiceOrder) ProtoMessage()
- func (x *ServiceOrder) ProtoReflect() protoreflect.Message
- func (x *ServiceOrder) Reset()
- func (x *ServiceOrder) String() string
- type ServiceOrder_OrderType
- func (ServiceOrder_OrderType) Descriptor() protoreflect.EnumDescriptor
- func (x ServiceOrder_OrderType) Enum() *ServiceOrder_OrderType
- func (ServiceOrder_OrderType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ServiceOrder_OrderType) Number() protoreflect.EnumNumber
- func (x ServiceOrder_OrderType) String() string
- func (ServiceOrder_OrderType) Type() protoreflect.EnumType
- type ServiceStatus
- func (*ServiceStatus) Descriptor() ([]byte, []int)deprecated
- func (x *ServiceStatus) GetService() *Service
- func (x *ServiceStatus) GetStatus() ServiceStatus_Status
- func (*ServiceStatus) ProtoMessage()
- func (x *ServiceStatus) ProtoReflect() protoreflect.Message
- func (x *ServiceStatus) Reset()
- func (x *ServiceStatus) String() string
- type ServiceStatus_Status
- func (ServiceStatus_Status) Descriptor() protoreflect.EnumDescriptor
- func (x ServiceStatus_Status) Enum() *ServiceStatus_Status
- func (ServiceStatus_Status) EnumDescriptor() ([]byte, []int)deprecated
- func (x ServiceStatus_Status) Number() protoreflect.EnumNumber
- func (x ServiceStatus_Status) String() string
- func (ServiceStatus_Status) Type() protoreflect.EnumType
- type TuningState
- func (*TuningState) Descriptor() ([]byte, []int)deprecated
- func (x *TuningState) GetDynamicParameters() []*TuningState_Parameter
- func (x *TuningState) GetTimestamp() uint64
- func (*TuningState) ProtoMessage()
- func (x *TuningState) ProtoReflect() protoreflect.Message
- func (x *TuningState) Reset()
- func (x *TuningState) String() string
- type TuningState_Parameter
- func (*TuningState_Parameter) Descriptor() ([]byte, []int)deprecated
- func (x *TuningState_Parameter) GetFloat() *TuningState_Parameter_FloatParameter
- func (x *TuningState_Parameter) GetInt() *TuningState_Parameter_IntParameter
- func (m *TuningState_Parameter) GetParameter() isTuningState_Parameter_Parameter
- func (x *TuningState_Parameter) GetString_() *TuningState_Parameter_StringParameter
- func (*TuningState_Parameter) ProtoMessage()
- func (x *TuningState_Parameter) ProtoReflect() protoreflect.Message
- func (x *TuningState_Parameter) Reset()
- func (x *TuningState_Parameter) String() string
- type TuningState_Parameter_Float
- type TuningState_Parameter_FloatParameter
- func (*TuningState_Parameter_FloatParameter) Descriptor() ([]byte, []int)deprecated
- func (x *TuningState_Parameter_FloatParameter) GetKey() string
- func (x *TuningState_Parameter_FloatParameter) GetValue() float32
- func (*TuningState_Parameter_FloatParameter) ProtoMessage()
- func (x *TuningState_Parameter_FloatParameter) ProtoReflect() protoreflect.Message
- func (x *TuningState_Parameter_FloatParameter) Reset()
- func (x *TuningState_Parameter_FloatParameter) String() string
- type TuningState_Parameter_Int
- type TuningState_Parameter_IntParameter
- func (*TuningState_Parameter_IntParameter) Descriptor() ([]byte, []int)deprecated
- func (x *TuningState_Parameter_IntParameter) GetKey() string
- func (x *TuningState_Parameter_IntParameter) GetValue() int64
- func (*TuningState_Parameter_IntParameter) ProtoMessage()
- func (x *TuningState_Parameter_IntParameter) ProtoReflect() protoreflect.Message
- func (x *TuningState_Parameter_IntParameter) Reset()
- func (x *TuningState_Parameter_IntParameter) String() string
- type TuningState_Parameter_StringParameter
- func (*TuningState_Parameter_StringParameter) Descriptor() ([]byte, []int)deprecated
- func (x *TuningState_Parameter_StringParameter) GetKey() string
- func (x *TuningState_Parameter_StringParameter) GetValue() string
- func (*TuningState_Parameter_StringParameter) ProtoMessage()
- func (x *TuningState_Parameter_StringParameter) ProtoReflect() protoreflect.Message
- func (x *TuningState_Parameter_StringParameter) Reset()
- func (x *TuningState_Parameter_StringParameter) String() string
- type TuningState_Parameter_String_
Constants ¶
This section is empty.
Variables ¶
var ( ServiceStatus_Status_name = map[int32]string{ 0: "UNKNOWN", 1: "RUNNING", 2: "STOPPED", } ServiceStatus_Status_value = map[string]int32{ "UNKNOWN": 0, "RUNNING": 1, "STOPPED": 2, } )
Enum value maps for ServiceStatus_Status.
var ( ServiceOrder_OrderType_name = map[int32]string{ 0: "STOP", 1: "RESTART", 2: "KILL", 3: "FORCE_RESTART", } ServiceOrder_OrderType_value = map[string]int32{ "STOP": 0, "RESTART": 1, "KILL": 2, "FORCE_RESTART": 3, } )
Enum value maps for ServiceOrder_OrderType.
var File_servicediscovery_proto protoreflect.FileDescriptor
var File_tuningstate_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) 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
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 (x *ServiceInformationRequest) ProtoReflect() protoreflect.Message
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_RESTART ServiceOrder_OrderType = 1 // will attempt a graceful shutdown and restart ServiceOrder_KILL ServiceOrder_OrderType = 2 // will kill the service immediately ServiceOrder_FORCE_RESTART ServiceOrder_OrderType = 3 // will kill the service immediately and restart )
func (ServiceOrder_OrderType) Descriptor ¶
func (ServiceOrder_OrderType) Descriptor() protoreflect.EnumDescriptor
func (ServiceOrder_OrderType) Enum ¶
func (x ServiceOrder_OrderType) Enum() *ServiceOrder_OrderType
func (ServiceOrder_OrderType) EnumDescriptor
deprecated
func (ServiceOrder_OrderType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ServiceOrder_OrderType.Descriptor instead.
func (ServiceOrder_OrderType) Number ¶
func (x ServiceOrder_OrderType) Number() protoreflect.EnumNumber
func (ServiceOrder_OrderType) String ¶
func (x ServiceOrder_OrderType) String() string
func (ServiceOrder_OrderType) Type ¶
func (ServiceOrder_OrderType) Type() protoreflect.EnumType
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 )
func (ServiceStatus_Status) Descriptor ¶
func (ServiceStatus_Status) Descriptor() protoreflect.EnumDescriptor
func (ServiceStatus_Status) Enum ¶
func (x ServiceStatus_Status) Enum() *ServiceStatus_Status
func (ServiceStatus_Status) EnumDescriptor
deprecated
func (ServiceStatus_Status) EnumDescriptor() ([]byte, []int)
Deprecated: Use ServiceStatus_Status.Descriptor instead.
func (ServiceStatus_Status) Number ¶
func (x ServiceStatus_Status) Number() protoreflect.EnumNumber
func (ServiceStatus_Status) String ¶
func (x ServiceStatus_Status) String() string
func (ServiceStatus_Status) Type ¶
func (ServiceStatus_Status) Type() protoreflect.EnumType
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 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 (x *TuningState_Parameter) GetFloat() *TuningState_Parameter_FloatParameter
func (*TuningState_Parameter) GetInt ¶
func (x *TuningState_Parameter) GetInt() *TuningState_Parameter_IntParameter
func (*TuningState_Parameter) GetParameter ¶
func (m *TuningState_Parameter) GetParameter() isTuningState_Parameter_Parameter
func (*TuningState_Parameter) GetString_ ¶
func (x *TuningState_Parameter) GetString_() *TuningState_Parameter_StringParameter
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 (x *TuningState_Parameter_FloatParameter) GetKey() string
func (*TuningState_Parameter_FloatParameter) GetValue ¶
func (x *TuningState_Parameter_FloatParameter) GetValue() float32
func (*TuningState_Parameter_FloatParameter) ProtoMessage ¶
func (*TuningState_Parameter_FloatParameter) ProtoMessage()
func (*TuningState_Parameter_FloatParameter) ProtoReflect ¶
func (x *TuningState_Parameter_FloatParameter) ProtoReflect() protoreflect.Message
func (*TuningState_Parameter_FloatParameter) Reset ¶
func (x *TuningState_Parameter_FloatParameter) Reset()
func (*TuningState_Parameter_FloatParameter) String ¶
func (x *TuningState_Parameter_FloatParameter) String() 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 (x *TuningState_Parameter_IntParameter) GetKey() string
func (*TuningState_Parameter_IntParameter) GetValue ¶
func (x *TuningState_Parameter_IntParameter) GetValue() int64
func (*TuningState_Parameter_IntParameter) ProtoMessage ¶
func (*TuningState_Parameter_IntParameter) ProtoMessage()
func (*TuningState_Parameter_IntParameter) ProtoReflect ¶
func (x *TuningState_Parameter_IntParameter) ProtoReflect() protoreflect.Message
func (*TuningState_Parameter_IntParameter) Reset ¶
func (x *TuningState_Parameter_IntParameter) Reset()
func (*TuningState_Parameter_IntParameter) String ¶
func (x *TuningState_Parameter_IntParameter) String() 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 (x *TuningState_Parameter_StringParameter) GetKey() string
func (*TuningState_Parameter_StringParameter) GetValue ¶
func (x *TuningState_Parameter_StringParameter) GetValue() string
func (*TuningState_Parameter_StringParameter) ProtoMessage ¶
func (*TuningState_Parameter_StringParameter) ProtoMessage()
func (*TuningState_Parameter_StringParameter) ProtoReflect ¶
func (x *TuningState_Parameter_StringParameter) ProtoReflect() protoreflect.Message
func (*TuningState_Parameter_StringParameter) Reset ¶
func (x *TuningState_Parameter_StringParameter) Reset()
func (*TuningState_Parameter_StringParameter) String ¶
func (x *TuningState_Parameter_StringParameter) String() string
type TuningState_Parameter_String_ ¶
type TuningState_Parameter_String_ struct {
String_ *TuningState_Parameter_StringParameter `protobuf:"bytes,3,opt,name=string,proto3,oneof"`
}