Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterRuntimeServer(s grpc.ServiceRegistrar, srv RuntimeServer)
- type ConfigureRequest
- type ConfigureResponse
- func (*ConfigureResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigureResponse) GetNetworkMappings() []*NetworkMapping
- func (x *ConfigureResponse) GetStatus() *ConfigureStatus
- func (*ConfigureResponse) ProtoMessage()
- func (x *ConfigureResponse) ProtoReflect() protoreflect.Message
- func (x *ConfigureResponse) Reset()
- func (x *ConfigureResponse) String() string
- type ConfigureStatus
- func (*ConfigureStatus) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigureStatus) GetMessage() string
- func (x *ConfigureStatus) GetState() ConfigureStatus_State
- func (*ConfigureStatus) ProtoMessage()
- func (x *ConfigureStatus) ProtoReflect() protoreflect.Message
- func (x *ConfigureStatus) Reset()
- func (x *ConfigureStatus) String() string
- type ConfigureStatus_State
- func (ConfigureStatus_State) Descriptor() protoreflect.EnumDescriptor
- func (x ConfigureStatus_State) Enum() *ConfigureStatus_State
- func (ConfigureStatus_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x ConfigureStatus_State) Number() protoreflect.EnumNumber
- func (x ConfigureStatus_State) String() string
- func (ConfigureStatus_State) Type() protoreflect.EnumType
- type DockerTracker
- type InformationRequest
- type InformationResponse
- func (*InformationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InformationResponse) GetStatus() InformationResponse_Status
- func (*InformationResponse) ProtoMessage()
- func (x *InformationResponse) ProtoReflect() protoreflect.Message
- func (x *InformationResponse) Reset()
- func (x *InformationResponse) String() string
- type InformationResponse_Status
- func (InformationResponse_Status) Descriptor() protoreflect.EnumDescriptor
- func (x InformationResponse_Status) Enum() *InformationResponse_Status
- func (InformationResponse_Status) EnumDescriptor() ([]byte, []int)deprecated
- func (x InformationResponse_Status) Number() protoreflect.EnumNumber
- func (x InformationResponse_Status) String() string
- func (InformationResponse_Status) Type() protoreflect.EnumType
- type InitRequest
- func (*InitRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InitRequest) GetDebug() bool
- func (x *InitRequest) GetDependencyEndpointGroup() *v1.EndpointGroup
- func (x *InitRequest) GetIdentity() *v1.ServiceIdentity
- func (*InitRequest) ProtoMessage()
- func (x *InitRequest) ProtoReflect() protoreflect.Message
- func (x *InitRequest) Reset()
- func (x *InitRequest) String() string
- type InitResponse
- func (*InitResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InitResponse) GetEndpoints() []*v1.Endpoint
- func (x *InitResponse) GetStatus() *InitStatus
- func (x *InitResponse) GetVersion() *v1.Version
- func (*InitResponse) ProtoMessage()
- func (x *InitResponse) ProtoReflect() protoreflect.Message
- func (x *InitResponse) Reset()
- func (x *InitResponse) String() string
- type InitStatus
- func (*InitStatus) Descriptor() ([]byte, []int)deprecated
- func (x *InitStatus) GetMessage() string
- func (x *InitStatus) GetState() InitStatus_State
- func (*InitStatus) ProtoMessage()
- func (x *InitStatus) ProtoReflect() protoreflect.Message
- func (x *InitStatus) Reset()
- func (x *InitStatus) String() string
- type InitStatus_State
- func (InitStatus_State) Descriptor() protoreflect.EnumDescriptor
- func (x InitStatus_State) Enum() *InitStatus_State
- func (InitStatus_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x InitStatus_State) Number() protoreflect.EnumNumber
- func (x InitStatus_State) String() string
- func (InitStatus_State) Type() protoreflect.EnumType
- type NetworkMapping
- func (*NetworkMapping) Descriptor() ([]byte, []int)deprecated
- func (x *NetworkMapping) GetAddresses() []string
- func (x *NetworkMapping) GetApplication() string
- func (x *NetworkMapping) GetEndpoint() *v1.Endpoint
- func (x *NetworkMapping) GetService() string
- func (*NetworkMapping) ProtoMessage()
- func (x *NetworkMapping) ProtoReflect() protoreflect.Message
- func (x *NetworkMapping) Reset()
- func (x *NetworkMapping) String() string
- type ProcessTracker
- func (*ProcessTracker) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessTracker) GetPID() int32
- func (x *ProcessTracker) GetType() string
- func (*ProcessTracker) ProtoMessage()
- func (x *ProcessTracker) ProtoReflect() protoreflect.Message
- func (x *ProcessTracker) Reset()
- func (x *ProcessTracker) String() string
- type RuntimeClient
- type RuntimeServer
- type StartRequest
- func (*StartRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartRequest) GetDependencyEndpointGroup() *v1.EndpointGroup
- func (x *StartRequest) GetNetworkMappings() []*NetworkMapping
- func (*StartRequest) ProtoMessage()
- func (x *StartRequest) ProtoReflect() protoreflect.Message
- func (x *StartRequest) Reset()
- func (x *StartRequest) String() string
- type StartResponse
- func (*StartResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StartResponse) GetStatus() *StartStatus
- func (x *StartResponse) GetTrackers() []*Tracker
- func (*StartResponse) ProtoMessage()
- func (x *StartResponse) ProtoReflect() protoreflect.Message
- func (x *StartResponse) Reset()
- func (x *StartResponse) String() string
- type StartStatus
- func (*StartStatus) Descriptor() ([]byte, []int)deprecated
- func (x *StartStatus) GetMessage() string
- func (x *StartStatus) GetState() StartStatus_State
- func (*StartStatus) ProtoMessage()
- func (x *StartStatus) ProtoReflect() protoreflect.Message
- func (x *StartStatus) Reset()
- func (x *StartStatus) String() string
- type StartStatus_State
- func (StartStatus_State) Descriptor() protoreflect.EnumDescriptor
- func (x StartStatus_State) Enum() *StartStatus_State
- func (StartStatus_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x StartStatus_State) Number() protoreflect.EnumNumber
- func (x StartStatus_State) String() string
- func (StartStatus_State) Type() protoreflect.EnumType
- type StopRequest
- type StopResponse
- type Tracker
- func (*Tracker) Descriptor() ([]byte, []int)deprecated
- func (x *Tracker) GetDockerTracker() *DockerTracker
- func (x *Tracker) GetName() string
- func (x *Tracker) GetProcessTracker() *ProcessTracker
- func (m *Tracker) GetTracker() isTracker_Tracker
- func (*Tracker) ProtoMessage()
- func (x *Tracker) ProtoReflect() protoreflect.Message
- func (x *Tracker) Reset()
- func (x *Tracker) String() string
- type TrackerList
- type Tracker_DockerTracker
- type Tracker_ProcessTracker
- type Trackers
- type UnimplementedRuntimeServer
- func (UnimplementedRuntimeServer) Communicate(context.Context, *v1.Engage) (*v1.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
Constants ¶
const ( Runtime_Init_FullMethodName = "/service.runtime.v1.Runtime/Init" Runtime_Configure_FullMethodName = "/service.runtime.v1.Runtime/Configure" Runtime_Start_FullMethodName = "/service.runtime.v1.Runtime/Start" Runtime_Information_FullMethodName = "/service.runtime.v1.Runtime/Information" Runtime_Stop_FullMethodName = "/service.runtime.v1.Runtime/Stop" Runtime_Communicate_FullMethodName = "/service.runtime.v1.Runtime/Communicate" )
Variables ¶
var ( InitStatus_State_name = map[int32]string{ 0: "UNKNOWN", 1: "READY", 2: "ERROR", } InitStatus_State_value = map[string]int32{ "UNKNOWN": 0, "READY": 1, "ERROR": 2, } )
Enum value maps for InitStatus_State.
var ( ConfigureStatus_State_name = map[int32]string{ 0: "UNKNOWN", 1: "READY", 2: "ERROR", } ConfigureStatus_State_value = map[string]int32{ "UNKNOWN": 0, "READY": 1, "ERROR": 2, } )
Enum value maps for ConfigureStatus_State.
var ( StartStatus_State_name = map[int32]string{ 0: "UNKNOWN", 1: "STARTED", 2: "ERROR", } StartStatus_State_value = map[string]int32{ "UNKNOWN": 0, "STARTED": 1, "ERROR": 2, } )
Enum value maps for StartStatus_State.
var ( InformationResponse_Status_name = map[int32]string{ 0: "UNKNOWN", 1: "INIT", 2: "STARTED", 3: "RESTART_WANTED", 4: "SYNC_WANTED", 5: "STOPPED", 6: "ERROR", } InformationResponse_Status_value = map[string]int32{ "UNKNOWN": 0, "INIT": 1, "STARTED": 2, "RESTART_WANTED": 3, "SYNC_WANTED": 4, "STOPPED": 5, "ERROR": 6, } )
Enum value maps for InformationResponse_Status.
var File_services_runtime_v1_runtime_proto protoreflect.FileDescriptor
var File_services_runtime_v1_tracker_proto protoreflect.FileDescriptor
var Runtime_ServiceDesc = grpc.ServiceDesc{ ServiceName: "service.runtime.v1.Runtime", HandlerType: (*RuntimeServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Init", Handler: _Runtime_Init_Handler, }, { MethodName: "Configure", Handler: _Runtime_Configure_Handler, }, { MethodName: "Start", Handler: _Runtime_Start_Handler, }, { MethodName: "Information", Handler: _Runtime_Information_Handler, }, { MethodName: "Stop", Handler: _Runtime_Stop_Handler, }, { MethodName: "Communicate", Handler: _Runtime_Communicate_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "services/runtime/v1/runtime.proto", }
Runtime_ServiceDesc is the grpc.ServiceDesc for Runtime service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRuntimeServer ¶
func RegisterRuntimeServer(s grpc.ServiceRegistrar, srv RuntimeServer)
Types ¶
type ConfigureRequest ¶
type ConfigureRequest struct {
// contains filtered or unexported fields
}
func (*ConfigureRequest) Descriptor
deprecated
func (*ConfigureRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConfigureRequest.ProtoReflect.Descriptor instead.
func (*ConfigureRequest) ProtoMessage ¶
func (*ConfigureRequest) ProtoMessage()
func (*ConfigureRequest) ProtoReflect ¶
func (x *ConfigureRequest) ProtoReflect() protoreflect.Message
func (*ConfigureRequest) Reset ¶
func (x *ConfigureRequest) Reset()
func (*ConfigureRequest) String ¶
func (x *ConfigureRequest) String() string
type ConfigureResponse ¶
type ConfigureResponse struct { Status *ConfigureStatus `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` NetworkMappings []*NetworkMapping `protobuf:"bytes,3,rep,name=network_mappings,json=networkMappings,proto3" json:"network_mappings,omitempty"` // contains filtered or unexported fields }
func (*ConfigureResponse) Descriptor
deprecated
func (*ConfigureResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConfigureResponse.ProtoReflect.Descriptor instead.
func (*ConfigureResponse) GetNetworkMappings ¶
func (x *ConfigureResponse) GetNetworkMappings() []*NetworkMapping
func (*ConfigureResponse) GetStatus ¶
func (x *ConfigureResponse) GetStatus() *ConfigureStatus
func (*ConfigureResponse) ProtoMessage ¶
func (*ConfigureResponse) ProtoMessage()
func (*ConfigureResponse) ProtoReflect ¶
func (x *ConfigureResponse) ProtoReflect() protoreflect.Message
func (*ConfigureResponse) Reset ¶
func (x *ConfigureResponse) Reset()
func (*ConfigureResponse) String ¶
func (x *ConfigureResponse) String() string
type ConfigureStatus ¶
type ConfigureStatus struct { State ConfigureStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=service.runtime.v1.ConfigureStatus_State" json:"state,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*ConfigureStatus) Descriptor
deprecated
func (*ConfigureStatus) Descriptor() ([]byte, []int)
Deprecated: Use ConfigureStatus.ProtoReflect.Descriptor instead.
func (*ConfigureStatus) GetMessage ¶
func (x *ConfigureStatus) GetMessage() string
func (*ConfigureStatus) GetState ¶
func (x *ConfigureStatus) GetState() ConfigureStatus_State
func (*ConfigureStatus) ProtoMessage ¶
func (*ConfigureStatus) ProtoMessage()
func (*ConfigureStatus) ProtoReflect ¶
func (x *ConfigureStatus) ProtoReflect() protoreflect.Message
func (*ConfigureStatus) Reset ¶
func (x *ConfigureStatus) Reset()
func (*ConfigureStatus) String ¶
func (x *ConfigureStatus) String() string
type ConfigureStatus_State ¶
type ConfigureStatus_State int32
const ( ConfigureStatus_UNKNOWN ConfigureStatus_State = 0 ConfigureStatus_READY ConfigureStatus_State = 1 ConfigureStatus_ERROR ConfigureStatus_State = 2 )
func (ConfigureStatus_State) Descriptor ¶
func (ConfigureStatus_State) Descriptor() protoreflect.EnumDescriptor
func (ConfigureStatus_State) Enum ¶
func (x ConfigureStatus_State) Enum() *ConfigureStatus_State
func (ConfigureStatus_State) EnumDescriptor
deprecated
func (ConfigureStatus_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use ConfigureStatus_State.Descriptor instead.
func (ConfigureStatus_State) Number ¶
func (x ConfigureStatus_State) Number() protoreflect.EnumNumber
func (ConfigureStatus_State) String ¶
func (x ConfigureStatus_State) String() string
func (ConfigureStatus_State) Type ¶
func (ConfigureStatus_State) Type() protoreflect.EnumType
type DockerTracker ¶
type DockerTracker struct { ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` // contains filtered or unexported fields }
func (*DockerTracker) Descriptor
deprecated
func (*DockerTracker) Descriptor() ([]byte, []int)
Deprecated: Use DockerTracker.ProtoReflect.Descriptor instead.
func (*DockerTracker) GetContainerId ¶
func (x *DockerTracker) GetContainerId() string
func (*DockerTracker) ProtoMessage ¶
func (*DockerTracker) ProtoMessage()
func (*DockerTracker) ProtoReflect ¶
func (x *DockerTracker) ProtoReflect() protoreflect.Message
func (*DockerTracker) Reset ¶
func (x *DockerTracker) Reset()
func (*DockerTracker) String ¶
func (x *DockerTracker) String() string
type InformationRequest ¶
type InformationRequest struct {
// contains filtered or unexported fields
}
func (*InformationRequest) Descriptor
deprecated
func (*InformationRequest) Descriptor() ([]byte, []int)
Deprecated: Use InformationRequest.ProtoReflect.Descriptor instead.
func (*InformationRequest) ProtoMessage ¶
func (*InformationRequest) ProtoMessage()
func (*InformationRequest) ProtoReflect ¶
func (x *InformationRequest) ProtoReflect() protoreflect.Message
func (*InformationRequest) Reset ¶
func (x *InformationRequest) Reset()
func (*InformationRequest) String ¶
func (x *InformationRequest) String() string
type InformationResponse ¶
type InformationResponse struct { Status InformationResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=service.runtime.v1.InformationResponse_Status" json:"status,omitempty"` // contains filtered or unexported fields }
func (*InformationResponse) Descriptor
deprecated
func (*InformationResponse) Descriptor() ([]byte, []int)
Deprecated: Use InformationResponse.ProtoReflect.Descriptor instead.
func (*InformationResponse) GetStatus ¶
func (x *InformationResponse) GetStatus() InformationResponse_Status
func (*InformationResponse) ProtoMessage ¶
func (*InformationResponse) ProtoMessage()
func (*InformationResponse) ProtoReflect ¶
func (x *InformationResponse) ProtoReflect() protoreflect.Message
func (*InformationResponse) Reset ¶
func (x *InformationResponse) Reset()
func (*InformationResponse) String ¶
func (x *InformationResponse) String() string
type InformationResponse_Status ¶
type InformationResponse_Status int32
const ( InformationResponse_UNKNOWN InformationResponse_Status = 0 InformationResponse_INIT InformationResponse_Status = 1 InformationResponse_STARTED InformationResponse_Status = 2 InformationResponse_RESTART_WANTED InformationResponse_Status = 3 InformationResponse_SYNC_WANTED InformationResponse_Status = 4 InformationResponse_STOPPED InformationResponse_Status = 5 InformationResponse_ERROR InformationResponse_Status = 6 )
func (InformationResponse_Status) Descriptor ¶
func (InformationResponse_Status) Descriptor() protoreflect.EnumDescriptor
func (InformationResponse_Status) Enum ¶
func (x InformationResponse_Status) Enum() *InformationResponse_Status
func (InformationResponse_Status) EnumDescriptor
deprecated
func (InformationResponse_Status) EnumDescriptor() ([]byte, []int)
Deprecated: Use InformationResponse_Status.Descriptor instead.
func (InformationResponse_Status) Number ¶
func (x InformationResponse_Status) Number() protoreflect.EnumNumber
func (InformationResponse_Status) String ¶
func (x InformationResponse_Status) String() string
func (InformationResponse_Status) Type ¶
func (InformationResponse_Status) Type() protoreflect.EnumType
type InitRequest ¶
type InitRequest struct { Debug bool `protobuf:"varint,1,opt,name=debug,proto3" json:"debug,omitempty"` // Developer debug // Identity of the service Identity *v1.ServiceIdentity `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"` // Dependency EndpointGroup DependencyEndpointGroup *v1.EndpointGroup `` /* 132-byte string literal not displayed */ // contains filtered or unexported fields }
func (*InitRequest) Descriptor
deprecated
func (*InitRequest) Descriptor() ([]byte, []int)
Deprecated: Use InitRequest.ProtoReflect.Descriptor instead.
func (*InitRequest) GetDebug ¶
func (x *InitRequest) GetDebug() bool
func (*InitRequest) GetDependencyEndpointGroup ¶
func (x *InitRequest) GetDependencyEndpointGroup() *v1.EndpointGroup
func (*InitRequest) GetIdentity ¶
func (x *InitRequest) GetIdentity() *v1.ServiceIdentity
func (*InitRequest) ProtoMessage ¶
func (*InitRequest) ProtoMessage()
func (*InitRequest) ProtoReflect ¶
func (x *InitRequest) ProtoReflect() protoreflect.Message
func (*InitRequest) Reset ¶
func (x *InitRequest) Reset()
func (*InitRequest) String ¶
func (x *InitRequest) String() string
type InitResponse ¶
type InitResponse struct { Version *v1.Version `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` Endpoints []*v1.Endpoint `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints,omitempty"` Status *InitStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*InitResponse) Descriptor
deprecated
func (*InitResponse) Descriptor() ([]byte, []int)
Deprecated: Use InitResponse.ProtoReflect.Descriptor instead.
func (*InitResponse) GetEndpoints ¶
func (x *InitResponse) GetEndpoints() []*v1.Endpoint
func (*InitResponse) GetStatus ¶
func (x *InitResponse) GetStatus() *InitStatus
func (*InitResponse) GetVersion ¶
func (x *InitResponse) GetVersion() *v1.Version
func (*InitResponse) ProtoMessage ¶
func (*InitResponse) ProtoMessage()
func (*InitResponse) ProtoReflect ¶
func (x *InitResponse) ProtoReflect() protoreflect.Message
func (*InitResponse) Reset ¶
func (x *InitResponse) Reset()
func (*InitResponse) String ¶
func (x *InitResponse) String() string
type InitStatus ¶
type InitStatus struct { State InitStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=service.runtime.v1.InitStatus_State" json:"state,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*InitStatus) Descriptor
deprecated
func (*InitStatus) Descriptor() ([]byte, []int)
Deprecated: Use InitStatus.ProtoReflect.Descriptor instead.
func (*InitStatus) GetMessage ¶
func (x *InitStatus) GetMessage() string
func (*InitStatus) GetState ¶
func (x *InitStatus) GetState() InitStatus_State
func (*InitStatus) ProtoMessage ¶
func (*InitStatus) ProtoMessage()
func (*InitStatus) ProtoReflect ¶
func (x *InitStatus) ProtoReflect() protoreflect.Message
func (*InitStatus) Reset ¶
func (x *InitStatus) Reset()
func (*InitStatus) String ¶
func (x *InitStatus) String() string
type InitStatus_State ¶
type InitStatus_State int32
const ( InitStatus_UNKNOWN InitStatus_State = 0 InitStatus_READY InitStatus_State = 1 InitStatus_ERROR InitStatus_State = 2 )
func (InitStatus_State) Descriptor ¶
func (InitStatus_State) Descriptor() protoreflect.EnumDescriptor
func (InitStatus_State) Enum ¶
func (x InitStatus_State) Enum() *InitStatus_State
func (InitStatus_State) EnumDescriptor
deprecated
func (InitStatus_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use InitStatus_State.Descriptor instead.
func (InitStatus_State) Number ¶
func (x InitStatus_State) Number() protoreflect.EnumNumber
func (InitStatus_State) String ¶
func (x InitStatus_State) String() string
func (InitStatus_State) Type ¶
func (InitStatus_State) Type() protoreflect.EnumType
type NetworkMapping ¶
type NetworkMapping struct { Application string `protobuf:"bytes,1,opt,name=application,proto3" json:"application,omitempty"` // Application name Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"` // Service name Endpoint *v1.Endpoint `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"` Addresses []string `protobuf:"bytes,4,rep,name=addresses,proto3" json:"addresses,omitempty"` // List of addresses to map to // contains filtered or unexported fields }
func (*NetworkMapping) Descriptor
deprecated
func (*NetworkMapping) Descriptor() ([]byte, []int)
Deprecated: Use NetworkMapping.ProtoReflect.Descriptor instead.
func (*NetworkMapping) GetAddresses ¶
func (x *NetworkMapping) GetAddresses() []string
func (*NetworkMapping) GetApplication ¶
func (x *NetworkMapping) GetApplication() string
func (*NetworkMapping) GetEndpoint ¶
func (x *NetworkMapping) GetEndpoint() *v1.Endpoint
func (*NetworkMapping) GetService ¶
func (x *NetworkMapping) GetService() string
func (*NetworkMapping) ProtoMessage ¶
func (*NetworkMapping) ProtoMessage()
func (*NetworkMapping) ProtoReflect ¶
func (x *NetworkMapping) ProtoReflect() protoreflect.Message
func (*NetworkMapping) Reset ¶
func (x *NetworkMapping) Reset()
func (*NetworkMapping) String ¶
func (x *NetworkMapping) String() string
type ProcessTracker ¶
type ProcessTracker struct { PID int32 `protobuf:"varint,1,opt,name=PID,proto3" json:"PID,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
func (*ProcessTracker) Descriptor
deprecated
func (*ProcessTracker) Descriptor() ([]byte, []int)
Deprecated: Use ProcessTracker.ProtoReflect.Descriptor instead.
func (*ProcessTracker) GetPID ¶
func (x *ProcessTracker) GetPID() int32
func (*ProcessTracker) GetType ¶
func (x *ProcessTracker) GetType() string
func (*ProcessTracker) ProtoMessage ¶
func (*ProcessTracker) ProtoMessage()
func (*ProcessTracker) ProtoReflect ¶
func (x *ProcessTracker) ProtoReflect() protoreflect.Message
func (*ProcessTracker) Reset ¶
func (x *ProcessTracker) Reset()
func (*ProcessTracker) String ¶
func (x *ProcessTracker) String() string
type RuntimeClient ¶
type RuntimeClient interface { Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*InitResponse, error) Configure(ctx context.Context, in *ConfigureRequest, opts ...grpc.CallOption) (*ConfigureResponse, error) Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error) Information(ctx context.Context, in *InformationRequest, opts ...grpc.CallOption) (*InformationResponse, error) Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error) // Communication helper Communicate(ctx context.Context, in *v1.Engage, opts ...grpc.CallOption) (*v1.InformationRequest, error) }
RuntimeClient is the client API for Runtime 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 NewRuntimeClient ¶
func NewRuntimeClient(cc grpc.ClientConnInterface) RuntimeClient
type RuntimeServer ¶
type RuntimeServer interface { Init(context.Context, *InitRequest) (*InitResponse, error) Configure(context.Context, *ConfigureRequest) (*ConfigureResponse, error) Start(context.Context, *StartRequest) (*StartResponse, error) Information(context.Context, *InformationRequest) (*InformationResponse, error) Stop(context.Context, *StopRequest) (*StopResponse, error) // Communication helper Communicate(context.Context, *v1.Engage) (*v1.InformationRequest, error) // contains filtered or unexported methods }
RuntimeServer is the server API for Runtime service. All implementations must embed UnimplementedRuntimeServer for forward compatibility
type StartRequest ¶
type StartRequest struct { NetworkMappings []*NetworkMapping `protobuf:"bytes,1,rep,name=network_mappings,json=networkMappings,proto3" json:"network_mappings,omitempty"` DependencyEndpointGroup *v1.EndpointGroup `` /* 132-byte string literal not displayed */ // contains filtered or unexported fields }
func (*StartRequest) Descriptor
deprecated
func (*StartRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartRequest.ProtoReflect.Descriptor instead.
func (*StartRequest) GetDependencyEndpointGroup ¶
func (x *StartRequest) GetDependencyEndpointGroup() *v1.EndpointGroup
func (*StartRequest) GetNetworkMappings ¶
func (x *StartRequest) GetNetworkMappings() []*NetworkMapping
func (*StartRequest) ProtoMessage ¶
func (*StartRequest) ProtoMessage()
func (*StartRequest) ProtoReflect ¶
func (x *StartRequest) ProtoReflect() protoreflect.Message
func (*StartRequest) Reset ¶
func (x *StartRequest) Reset()
func (*StartRequest) String ¶
func (x *StartRequest) String() string
type StartResponse ¶
type StartResponse struct { Status *StartStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` Trackers []*Tracker `protobuf:"bytes,2,rep,name=trackers,proto3" json:"trackers,omitempty"` // contains filtered or unexported fields }
func (*StartResponse) Descriptor
deprecated
func (*StartResponse) Descriptor() ([]byte, []int)
Deprecated: Use StartResponse.ProtoReflect.Descriptor instead.
func (*StartResponse) GetStatus ¶
func (x *StartResponse) GetStatus() *StartStatus
func (*StartResponse) GetTrackers ¶
func (x *StartResponse) GetTrackers() []*Tracker
func (*StartResponse) ProtoMessage ¶
func (*StartResponse) ProtoMessage()
func (*StartResponse) ProtoReflect ¶
func (x *StartResponse) ProtoReflect() protoreflect.Message
func (*StartResponse) Reset ¶
func (x *StartResponse) Reset()
func (*StartResponse) String ¶
func (x *StartResponse) String() string
type StartStatus ¶
type StartStatus struct { State StartStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=service.runtime.v1.StartStatus_State" json:"state,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*StartStatus) Descriptor
deprecated
func (*StartStatus) Descriptor() ([]byte, []int)
Deprecated: Use StartStatus.ProtoReflect.Descriptor instead.
func (*StartStatus) GetMessage ¶
func (x *StartStatus) GetMessage() string
func (*StartStatus) GetState ¶
func (x *StartStatus) GetState() StartStatus_State
func (*StartStatus) ProtoMessage ¶
func (*StartStatus) ProtoMessage()
func (*StartStatus) ProtoReflect ¶
func (x *StartStatus) ProtoReflect() protoreflect.Message
func (*StartStatus) Reset ¶
func (x *StartStatus) Reset()
func (*StartStatus) String ¶
func (x *StartStatus) String() string
type StartStatus_State ¶
type StartStatus_State int32
const ( StartStatus_UNKNOWN StartStatus_State = 0 StartStatus_STARTED StartStatus_State = 1 StartStatus_ERROR StartStatus_State = 2 )
func (StartStatus_State) Descriptor ¶
func (StartStatus_State) Descriptor() protoreflect.EnumDescriptor
func (StartStatus_State) Enum ¶
func (x StartStatus_State) Enum() *StartStatus_State
func (StartStatus_State) EnumDescriptor
deprecated
func (StartStatus_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use StartStatus_State.Descriptor instead.
func (StartStatus_State) Number ¶
func (x StartStatus_State) Number() protoreflect.EnumNumber
func (StartStatus_State) String ¶
func (x StartStatus_State) String() string
func (StartStatus_State) Type ¶
func (StartStatus_State) Type() protoreflect.EnumType
type StopRequest ¶
type StopRequest struct { Persist bool `protobuf:"varint,1,opt,name=persist,proto3" json:"persist,omitempty"` // Persist the service instance // contains filtered or unexported fields }
func (*StopRequest) Descriptor
deprecated
func (*StopRequest) Descriptor() ([]byte, []int)
Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.
func (*StopRequest) GetPersist ¶
func (x *StopRequest) GetPersist() bool
func (*StopRequest) ProtoMessage ¶
func (*StopRequest) ProtoMessage()
func (*StopRequest) ProtoReflect ¶
func (x *StopRequest) ProtoReflect() protoreflect.Message
func (*StopRequest) Reset ¶
func (x *StopRequest) Reset()
func (*StopRequest) String ¶
func (x *StopRequest) String() string
type StopResponse ¶
type StopResponse struct {
// contains filtered or unexported fields
}
func (*StopResponse) Descriptor
deprecated
func (*StopResponse) Descriptor() ([]byte, []int)
Deprecated: Use StopResponse.ProtoReflect.Descriptor instead.
func (*StopResponse) ProtoMessage ¶
func (*StopResponse) ProtoMessage()
func (*StopResponse) ProtoReflect ¶
func (x *StopResponse) ProtoReflect() protoreflect.Message
func (*StopResponse) Reset ¶
func (x *StopResponse) Reset()
func (*StopResponse) String ¶
func (x *StopResponse) String() string
type Tracker ¶
type Tracker struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Types that are assignable to Tracker: // // *Tracker_ProcessTracker // *Tracker_DockerTracker Tracker isTracker_Tracker `protobuf_oneof:"tracker"` // contains filtered or unexported fields }
func (*Tracker) Descriptor
deprecated
func (*Tracker) GetDockerTracker ¶
func (x *Tracker) GetDockerTracker() *DockerTracker
func (*Tracker) GetProcessTracker ¶
func (x *Tracker) GetProcessTracker() *ProcessTracker
func (*Tracker) GetTracker ¶
func (m *Tracker) GetTracker() isTracker_Tracker
func (*Tracker) ProtoMessage ¶
func (*Tracker) ProtoMessage()
func (*Tracker) ProtoReflect ¶
func (x *Tracker) ProtoReflect() protoreflect.Message
type TrackerList ¶
type TrackerList struct { Trackers []*Tracker `protobuf:"bytes,1,rep,name=trackers,proto3" json:"trackers,omitempty"` // contains filtered or unexported fields }
func (*TrackerList) Descriptor
deprecated
func (*TrackerList) Descriptor() ([]byte, []int)
Deprecated: Use TrackerList.ProtoReflect.Descriptor instead.
func (*TrackerList) GetTrackers ¶
func (x *TrackerList) GetTrackers() []*Tracker
func (*TrackerList) ProtoMessage ¶
func (*TrackerList) ProtoMessage()
func (*TrackerList) ProtoReflect ¶
func (x *TrackerList) ProtoReflect() protoreflect.Message
func (*TrackerList) Reset ¶
func (x *TrackerList) Reset()
func (*TrackerList) String ¶
func (x *TrackerList) String() string
type Tracker_DockerTracker ¶
type Tracker_DockerTracker struct {
DockerTracker *DockerTracker `protobuf:"bytes,5,opt,name=docker_tracker,json=dockerTracker,proto3,oneof"`
}
type Tracker_ProcessTracker ¶
type Tracker_ProcessTracker struct {
ProcessTracker *ProcessTracker `protobuf:"bytes,4,opt,name=process_tracker,json=processTracker,proto3,oneof"`
}
type Trackers ¶
type Trackers struct { Trackers map[string]*TrackerList `` /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Trackers) Descriptor
deprecated
func (*Trackers) GetTrackers ¶
func (x *Trackers) GetTrackers() map[string]*TrackerList
func (*Trackers) ProtoMessage ¶
func (*Trackers) ProtoMessage()
func (*Trackers) ProtoReflect ¶
func (x *Trackers) ProtoReflect() protoreflect.Message
type UnimplementedRuntimeServer ¶
type UnimplementedRuntimeServer struct { }
UnimplementedRuntimeServer must be embedded to have forward compatible implementations.
func (UnimplementedRuntimeServer) Communicate ¶
func (UnimplementedRuntimeServer) Communicate(context.Context, *v1.Engage) (*v1.InformationRequest, error)
func (UnimplementedRuntimeServer) Configure ¶
func (UnimplementedRuntimeServer) Configure(context.Context, *ConfigureRequest) (*ConfigureResponse, error)
func (UnimplementedRuntimeServer) Information ¶
func (UnimplementedRuntimeServer) Information(context.Context, *InformationRequest) (*InformationResponse, error)
func (UnimplementedRuntimeServer) Init ¶
func (UnimplementedRuntimeServer) Init(context.Context, *InitRequest) (*InitResponse, error)
func (UnimplementedRuntimeServer) Start ¶
func (UnimplementedRuntimeServer) Start(context.Context, *StartRequest) (*StartResponse, error)
func (UnimplementedRuntimeServer) Stop ¶
func (UnimplementedRuntimeServer) Stop(context.Context, *StopRequest) (*StopResponse, error)
type UnsafeRuntimeServer ¶
type UnsafeRuntimeServer interface {
// contains filtered or unexported methods
}
UnsafeRuntimeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RuntimeServer will result in compilation errors.