Versions in this module Expand all Collapse all v0 v0.1.0 Dec 14, 2023 v0.0.51 Dec 15, 2023 Changes in this version + const Runtime_Communicate_FullMethodName + const Runtime_Configure_FullMethodName + const Runtime_Information_FullMethodName + const Runtime_Init_FullMethodName + const Runtime_Start_FullMethodName + const Runtime_Stop_FullMethodName + var ConfigureStatus_State_name = map[int32]string + var ConfigureStatus_State_value = map[string]int32 + var File_proto_services_runtime_runtime_proto protoreflect.FileDescriptor + var File_proto_services_runtime_tracker_proto protoreflect.FileDescriptor + var InformationResponse_Status_name = map[int32]string + var InformationResponse_Status_value = map[string]int32 + var InitStatus_State_name = map[int32]string + var InitStatus_State_value = map[string]int32 + var Runtime_ServiceDesc = grpc.ServiceDesc + var StartStatus_State_name = map[int32]string + var StartStatus_State_value = map[string]int32 + func RegisterRuntimeServer(s grpc.ServiceRegistrar, srv RuntimeServer) + type ConfigureRequest struct + func (*ConfigureRequest) Descriptor() ([]byte, []int) + func (*ConfigureRequest) ProtoMessage() + func (x *ConfigureRequest) ProtoReflect() protoreflect.Message + func (x *ConfigureRequest) Reset() + func (x *ConfigureRequest) String() string + type ConfigureResponse struct + NetworkMappings []*NetworkMapping + Status *ConfigureStatus + func (*ConfigureResponse) Descriptor() ([]byte, []int) + func (*ConfigureResponse) ProtoMessage() + func (x *ConfigureResponse) GetNetworkMappings() []*NetworkMapping + func (x *ConfigureResponse) GetStatus() *ConfigureStatus + func (x *ConfigureResponse) ProtoReflect() protoreflect.Message + func (x *ConfigureResponse) Reset() + func (x *ConfigureResponse) String() string + type ConfigureStatus struct + Message string + State ConfigureStatus_State + func (*ConfigureStatus) Descriptor() ([]byte, []int) + func (*ConfigureStatus) ProtoMessage() + func (x *ConfigureStatus) GetMessage() string + func (x *ConfigureStatus) GetState() ConfigureStatus_State + func (x *ConfigureStatus) ProtoReflect() protoreflect.Message + func (x *ConfigureStatus) Reset() + func (x *ConfigureStatus) String() string + type ConfigureStatus_State int32 + const ConfigureStatus_ERROR + const ConfigureStatus_READY + const ConfigureStatus_UNKNOWN + func (ConfigureStatus_State) Descriptor() protoreflect.EnumDescriptor + func (ConfigureStatus_State) EnumDescriptor() ([]byte, []int) + func (ConfigureStatus_State) Type() protoreflect.EnumType + func (x ConfigureStatus_State) Enum() *ConfigureStatus_State + func (x ConfigureStatus_State) Number() protoreflect.EnumNumber + func (x ConfigureStatus_State) String() string + type DockerTracker struct + ContainerId string + func (*DockerTracker) Descriptor() ([]byte, []int) + func (*DockerTracker) ProtoMessage() + func (x *DockerTracker) GetContainerId() string + func (x *DockerTracker) ProtoReflect() protoreflect.Message + func (x *DockerTracker) Reset() + func (x *DockerTracker) String() string + type InformationRequest struct + func (*InformationRequest) Descriptor() ([]byte, []int) + func (*InformationRequest) ProtoMessage() + func (x *InformationRequest) ProtoReflect() protoreflect.Message + func (x *InformationRequest) Reset() + func (x *InformationRequest) String() string + type InformationResponse struct + Status InformationResponse_Status + func (*InformationResponse) Descriptor() ([]byte, []int) + func (*InformationResponse) ProtoMessage() + func (x *InformationResponse) GetStatus() InformationResponse_Status + func (x *InformationResponse) ProtoReflect() protoreflect.Message + func (x *InformationResponse) Reset() + func (x *InformationResponse) String() string + type InformationResponse_Status int32 + const InformationResponse_ERROR + const InformationResponse_INIT + const InformationResponse_RESTART_WANTED + const InformationResponse_STARTED + const InformationResponse_STOPPED + const InformationResponse_SYNC_WANTED + const InformationResponse_UNKNOWN + func (InformationResponse_Status) Descriptor() protoreflect.EnumDescriptor + func (InformationResponse_Status) EnumDescriptor() ([]byte, []int) + func (InformationResponse_Status) Type() protoreflect.EnumType + func (x InformationResponse_Status) Enum() *InformationResponse_Status + func (x InformationResponse_Status) Number() protoreflect.EnumNumber + func (x InformationResponse_Status) String() string + type InitRequest struct + Debug bool + DependencyEndpointGroup *base.EndpointGroup + Identity *base.ServiceIdentity + func (*InitRequest) Descriptor() ([]byte, []int) + func (*InitRequest) ProtoMessage() + func (x *InitRequest) GetDebug() bool + func (x *InitRequest) GetDependencyEndpointGroup() *base.EndpointGroup + func (x *InitRequest) GetIdentity() *base.ServiceIdentity + func (x *InitRequest) ProtoReflect() protoreflect.Message + func (x *InitRequest) Reset() + func (x *InitRequest) String() string + type InitResponse struct + Endpoints []*base.Endpoint + Status *InitStatus + Version *base.Version + func (*InitResponse) Descriptor() ([]byte, []int) + func (*InitResponse) ProtoMessage() + func (x *InitResponse) GetEndpoints() []*base.Endpoint + func (x *InitResponse) GetStatus() *InitStatus + func (x *InitResponse) GetVersion() *base.Version + func (x *InitResponse) ProtoReflect() protoreflect.Message + func (x *InitResponse) Reset() + func (x *InitResponse) String() string + type InitStatus struct + Message string + State InitStatus_State + func (*InitStatus) Descriptor() ([]byte, []int) + func (*InitStatus) ProtoMessage() + func (x *InitStatus) GetMessage() string + func (x *InitStatus) GetState() InitStatus_State + func (x *InitStatus) ProtoReflect() protoreflect.Message + func (x *InitStatus) Reset() + func (x *InitStatus) String() string + type InitStatus_State int32 + const InitStatus_ERROR + const InitStatus_READY + const InitStatus_UNKNOWN + func (InitStatus_State) Descriptor() protoreflect.EnumDescriptor + func (InitStatus_State) EnumDescriptor() ([]byte, []int) + func (InitStatus_State) Type() protoreflect.EnumType + func (x InitStatus_State) Enum() *InitStatus_State + func (x InitStatus_State) Number() protoreflect.EnumNumber + func (x InitStatus_State) String() string + type NetworkMapping struct + Addresses []string + Application string + Endpoint *base.Endpoint + Service string + func (*NetworkMapping) Descriptor() ([]byte, []int) + func (*NetworkMapping) ProtoMessage() + func (x *NetworkMapping) GetAddresses() []string + func (x *NetworkMapping) GetApplication() string + func (x *NetworkMapping) GetEndpoint() *base.Endpoint + func (x *NetworkMapping) GetService() string + func (x *NetworkMapping) ProtoReflect() protoreflect.Message + func (x *NetworkMapping) Reset() + func (x *NetworkMapping) String() string + type ProcessTracker struct + PID int32 + Type string + func (*ProcessTracker) Descriptor() ([]byte, []int) + func (*ProcessTracker) ProtoMessage() + func (x *ProcessTracker) GetPID() int32 + func (x *ProcessTracker) GetType() string + func (x *ProcessTracker) ProtoReflect() protoreflect.Message + func (x *ProcessTracker) Reset() + func (x *ProcessTracker) String() string + type RuntimeClient interface + Communicate func(ctx context.Context, in *agents.Engage, opts ...grpc.CallOption) (*agents.InformationRequest, error) + Configure func(ctx context.Context, in *ConfigureRequest, opts ...grpc.CallOption) (*ConfigureResponse, error) + Information func(ctx context.Context, in *InformationRequest, opts ...grpc.CallOption) (*InformationResponse, error) + Init func(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*InitResponse, error) + Start func(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error) + Stop func(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error) + func NewRuntimeClient(cc grpc.ClientConnInterface) RuntimeClient + type RuntimeServer interface + Communicate func(context.Context, *agents.Engage) (*agents.InformationRequest, error) + Configure func(context.Context, *ConfigureRequest) (*ConfigureResponse, error) + Information func(context.Context, *InformationRequest) (*InformationResponse, error) + Init func(context.Context, *InitRequest) (*InitResponse, error) + Start func(context.Context, *StartRequest) (*StartResponse, error) + Stop func(context.Context, *StopRequest) (*StopResponse, error) + type StartRequest struct + DependencyEndpointGroup *base.EndpointGroup + NetworkMappings []*NetworkMapping + func (*StartRequest) Descriptor() ([]byte, []int) + func (*StartRequest) ProtoMessage() + func (x *StartRequest) GetDependencyEndpointGroup() *base.EndpointGroup + func (x *StartRequest) GetNetworkMappings() []*NetworkMapping + func (x *StartRequest) ProtoReflect() protoreflect.Message + func (x *StartRequest) Reset() + func (x *StartRequest) String() string + type StartResponse struct + Status *StartStatus + Trackers []*Tracker + func (*StartResponse) Descriptor() ([]byte, []int) + func (*StartResponse) ProtoMessage() + func (x *StartResponse) GetStatus() *StartStatus + func (x *StartResponse) GetTrackers() []*Tracker + func (x *StartResponse) ProtoReflect() protoreflect.Message + func (x *StartResponse) Reset() + func (x *StartResponse) String() string + type StartStatus struct + Message string + State StartStatus_State + func (*StartStatus) Descriptor() ([]byte, []int) + func (*StartStatus) ProtoMessage() + func (x *StartStatus) GetMessage() string + func (x *StartStatus) GetState() StartStatus_State + func (x *StartStatus) ProtoReflect() protoreflect.Message + func (x *StartStatus) Reset() + func (x *StartStatus) String() string + type StartStatus_State int32 + const StartStatus_ERROR + const StartStatus_STARTED + const StartStatus_UNKNOWN + func (StartStatus_State) Descriptor() protoreflect.EnumDescriptor + func (StartStatus_State) EnumDescriptor() ([]byte, []int) + func (StartStatus_State) Type() protoreflect.EnumType + func (x StartStatus_State) Enum() *StartStatus_State + func (x StartStatus_State) Number() protoreflect.EnumNumber + func (x StartStatus_State) String() string + type StopRequest struct + Persist bool + func (*StopRequest) Descriptor() ([]byte, []int) + func (*StopRequest) ProtoMessage() + func (x *StopRequest) GetPersist() bool + func (x *StopRequest) ProtoReflect() protoreflect.Message + func (x *StopRequest) Reset() + func (x *StopRequest) String() string + type StopResponse struct + func (*StopResponse) Descriptor() ([]byte, []int) + func (*StopResponse) ProtoMessage() + func (x *StopResponse) ProtoReflect() protoreflect.Message + func (x *StopResponse) Reset() + func (x *StopResponse) String() string + type Tracker struct + Name string + Tracker isTracker_Tracker + func (*Tracker) Descriptor() ([]byte, []int) + func (*Tracker) ProtoMessage() + func (m *Tracker) GetTracker() isTracker_Tracker + func (x *Tracker) GetDockerTracker() *DockerTracker + func (x *Tracker) GetName() string + func (x *Tracker) GetProcessTracker() *ProcessTracker + func (x *Tracker) ProtoReflect() protoreflect.Message + func (x *Tracker) Reset() + func (x *Tracker) String() string + type TrackerList struct + Trackers []*Tracker + func (*TrackerList) Descriptor() ([]byte, []int) + func (*TrackerList) ProtoMessage() + func (x *TrackerList) GetTrackers() []*Tracker + func (x *TrackerList) ProtoReflect() protoreflect.Message + func (x *TrackerList) Reset() + func (x *TrackerList) String() string + type Tracker_DockerTracker struct + DockerTracker *DockerTracker + type Tracker_ProcessTracker struct + ProcessTracker *ProcessTracker + type Trackers struct + Trackers map[string]*TrackerList + func (*Trackers) Descriptor() ([]byte, []int) + func (*Trackers) ProtoMessage() + func (x *Trackers) GetTrackers() map[string]*TrackerList + func (x *Trackers) ProtoReflect() protoreflect.Message + func (x *Trackers) Reset() + func (x *Trackers) String() string + type UnimplementedRuntimeServer struct + func (UnimplementedRuntimeServer) Communicate(context.Context, *agents.Engage) (*agents.InformationRequest, error) + func (UnimplementedRuntimeServer) Configure(context.Context, *ConfigureRequest) (*ConfigureResponse, error) + func (UnimplementedRuntimeServer) Information(context.Context, *InformationRequest) (*InformationResponse, error) + func (UnimplementedRuntimeServer) Init(context.Context, *InitRequest) (*InitResponse, error) + func (UnimplementedRuntimeServer) Start(context.Context, *StartRequest) (*StartResponse, error) + func (UnimplementedRuntimeServer) Stop(context.Context, *StopRequest) (*StopResponse, error) + type UnsafeRuntimeServer interface