runtimev1

package
v0.0.77 Latest Latest
Warning

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

 Go to latest Published: Dec 27, 2023 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Runtime_Load_FullMethodName        = "/service.runtime.v1.Runtime/Load"
	Runtime_Init_FullMethodName        = "/service.runtime.v1.Runtime/Init"
	Runtime_Start_FullMethodName       = "/service.runtime.v1.Runtime/Start"
	Runtime_Stop_FullMethodName        = "/service.runtime.v1.Runtime/Stop"
	Runtime_Information_FullMethodName = "/service.runtime.v1.Runtime/Information"
	Runtime_Communicate_FullMethodName = "/service.runtime.v1.Runtime/Communicate"
)

Variables

View Source 
var (
	LoadStatus_State_name = map[int32]string{
		0: "UNKNOWN",
		1: "READY",
		2: "ERROR",
	}
	LoadStatus_State_value = map[string]int32{
		"UNKNOWN": 0,
		"READY":   1,
		"ERROR":   2,
	}
)

Enum value maps for LoadStatus_State.

View Source 
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.

View Source 
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.

View Source 
var (
	InformationResponse_Status_name = map[int32]string{
		0:  "UNKNOWN",
		1:  "LOAD_IN_PROGRESS",
		2:  "LOADED_SUCCESS",
		3:  "LOADED_FAILED",
		4:  "INIT_IN_PROGRESS",
		5:  "INIT_SUCCESS",
		6:  "INIT_FAILED",
		7:  "START_IN_PROGRESS",
		8:  "START_SUCCESS",
		9:  "START_FAILED",
		10: "STOP_IN_PROGRESS",
		11: "STOP_SUCCESS",
		12: "STOP_FAILED",
	}
	InformationResponse_Status_value = map[string]int32{
		"UNKNOWN":           0,
		"LOAD_IN_PROGRESS":  1,
		"LOADED_SUCCESS":    2,
		"LOADED_FAILED":     3,
		"INIT_IN_PROGRESS":  4,
		"INIT_SUCCESS":      5,
		"INIT_FAILED":       6,
		"START_IN_PROGRESS": 7,
		"START_SUCCESS":     8,
		"START_FAILED":      9,
		"STOP_IN_PROGRESS":  10,
		"STOP_SUCCESS":      11,
		"STOP_FAILED":       12,
	}
)

Enum value maps for InformationResponse_Status.

View Source 
var (
	InformationResponse_DesiredState_name = map[int32]string{
		0: "NOOP",
		1: "STARTED",
		2: "STOPPED",
		3: "RESTARTED",
	}
	InformationResponse_DesiredState_value = map[string]int32{
		"NOOP":      0,
		"STARTED":   1,
		"STOPPED":   2,
		"RESTARTED": 3,
	}
)

Enum value maps for InformationResponse_DesiredState.

View Source 
var File_services_runtime_v1_runtime_proto protoreflect.FileDescriptor
View Source 
var File_services_runtime_v1_tracker_proto protoreflect.FileDescriptor
View Source 
var Runtime_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "service.runtime.v1.Runtime",
	HandlerType: (*RuntimeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Load",
			Handler:    _Runtime_Load_Handler,
		},
		{
			MethodName: "Init",
			Handler:    _Runtime_Init_Handler,
		},
		{
			MethodName: "Start",
			Handler:    _Runtime_Start_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _Runtime_Stop_Handler,
		},
		{
			MethodName: "Information",
			Handler:    _Runtime_Information_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 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"`
	DesiredState InformationResponse_DesiredState `` /* 155-byte string literal not displayed */
	Message      string                           `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

InformationResponse represents the state of a service in different stages of its lifecycle The status is a list of statuses that are relevant

func (*InformationResponse) Descriptor deprecated 

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

Deprecated: Use InformationResponse.ProtoReflect.Descriptor instead.

func (*InformationResponse) GetDesiredState added in v0.0.72 

func (x *InformationResponse) GetDesiredState() InformationResponse_DesiredState

func (*InformationResponse) GetMessage added in v0.0.72 

func (x *InformationResponse) GetMessage() string

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_DesiredState added in v0.0.72 

type InformationResponse_DesiredState int32
const (
	InformationResponse_NOOP      InformationResponse_DesiredState = 0
	InformationResponse_STARTED   InformationResponse_DesiredState = 1
	InformationResponse_STOPPED   InformationResponse_DesiredState = 2
	InformationResponse_RESTARTED InformationResponse_DesiredState = 3
)

func (InformationResponse_DesiredState) Descriptor added in v0.0.72 

func (InformationResponse_DesiredState) Descriptor() protoreflect.EnumDescriptor

func (InformationResponse_DesiredState) Enum added in v0.0.72 

func (x InformationResponse_DesiredState) Enum() *InformationResponse_DesiredState

func (InformationResponse_DesiredState) EnumDescriptor deprecated added in v0.0.72 

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

Deprecated: Use InformationResponse_DesiredState.Descriptor instead.

func (InformationResponse_DesiredState) Number added in v0.0.72 

func (x InformationResponse_DesiredState) Number() protoreflect.EnumNumber

func (InformationResponse_DesiredState) String added in v0.0.72 

func (x InformationResponse_DesiredState) String() string

func (InformationResponse_DesiredState) Type added in v0.0.72 

func (InformationResponse_DesiredState) Type() protoreflect.EnumType

type InformationResponse_Status 

type InformationResponse_Status int32
const (
	InformationResponse_UNKNOWN           InformationResponse_Status = 0
	InformationResponse_LOAD_IN_PROGRESS  InformationResponse_Status = 1
	InformationResponse_LOADED_SUCCESS    InformationResponse_Status = 2
	InformationResponse_LOADED_FAILED     InformationResponse_Status = 3
	InformationResponse_INIT_IN_PROGRESS  InformationResponse_Status = 4
	InformationResponse_INIT_SUCCESS      InformationResponse_Status = 5
	InformationResponse_INIT_FAILED       InformationResponse_Status = 6
	InformationResponse_START_IN_PROGRESS InformationResponse_Status = 7
	InformationResponse_START_SUCCESS     InformationResponse_Status = 8
	InformationResponse_START_FAILED      InformationResponse_Status = 9
	InformationResponse_STOP_IN_PROGRESS  InformationResponse_Status = 10
	InformationResponse_STOP_SUCCESS      InformationResponse_Status = 11
	InformationResponse_STOP_FAILED       InformationResponse_Status = 12
)

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 {
	// contains filtered or unexported fields
}

func (*InitRequest) Descriptor deprecated 

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

Deprecated: Use InitRequest.ProtoReflect.Descriptor instead.

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 {
	Status          *InitStatus       `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 (*InitResponse) Descriptor deprecated 

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

Deprecated: Use InitResponse.ProtoReflect.Descriptor instead.

func (*InitResponse) GetNetworkMappings added in v0.0.72 

func (x *InitResponse) GetNetworkMappings() []*NetworkMapping

func (*InitResponse) GetStatus 

func (x *InitResponse) GetStatus() *InitStatus

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 LoadRequest added in v0.0.72 

type LoadRequest 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 (*LoadRequest) Descriptor deprecated added in v0.0.72 

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

Deprecated: Use LoadRequest.ProtoReflect.Descriptor instead.

func (*LoadRequest) GetDebug added in v0.0.72 

func (x *LoadRequest) GetDebug() bool

func (*LoadRequest) GetDependencyEndpointGroup added in v0.0.72 

func (x *LoadRequest) GetDependencyEndpointGroup() *v1.EndpointGroup

func (*LoadRequest) GetIdentity added in v0.0.72 

func (x *LoadRequest) GetIdentity() *v1.ServiceIdentity

func (*LoadRequest) ProtoMessage added in v0.0.72 

func (*LoadRequest) ProtoMessage()

func (*LoadRequest) ProtoReflect added in v0.0.72 

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

func (*LoadRequest) Reset added in v0.0.72 

func (x *LoadRequest) Reset()

func (*LoadRequest) String added in v0.0.72 

func (x *LoadRequest) String() string

type LoadResponse added in v0.0.72 

type LoadResponse 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    *LoadStatus    `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadResponse) Descriptor deprecated added in v0.0.72 

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

Deprecated: Use LoadResponse.ProtoReflect.Descriptor instead.

func (*LoadResponse) GetEndpoints added in v0.0.72 

func (x *LoadResponse) GetEndpoints() []*v1.Endpoint

func (*LoadResponse) GetStatus added in v0.0.72 

func (x *LoadResponse) GetStatus() *LoadStatus

func (*LoadResponse) GetVersion added in v0.0.72 

func (x *LoadResponse) GetVersion() *v1.Version

func (*LoadResponse) ProtoMessage added in v0.0.72 

func (*LoadResponse) ProtoMessage()

func (*LoadResponse) ProtoReflect added in v0.0.72 

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

func (*LoadResponse) Reset added in v0.0.72 

func (x *LoadResponse) Reset()

func (*LoadResponse) String added in v0.0.72 

func (x *LoadResponse) String() string

type LoadStatus added in v0.0.72 

type LoadStatus struct {
	State   LoadStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=service.runtime.v1.LoadStatus_State" json:"state,omitempty"`
	Message string           `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadStatus) Descriptor deprecated added in v0.0.72 

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

Deprecated: Use LoadStatus.ProtoReflect.Descriptor instead.

func (*LoadStatus) GetMessage added in v0.0.72 

func (x *LoadStatus) GetMessage() string

func (*LoadStatus) GetState added in v0.0.72 

func (x *LoadStatus) GetState() LoadStatus_State

func (*LoadStatus) ProtoMessage added in v0.0.72 

func (*LoadStatus) ProtoMessage()

func (*LoadStatus) ProtoReflect added in v0.0.72 

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

func (*LoadStatus) Reset added in v0.0.72 

func (x *LoadStatus) Reset()

func (*LoadStatus) String added in v0.0.72 

func (x *LoadStatus) String() string

type LoadStatus_State added in v0.0.72 

type LoadStatus_State int32
const (
	LoadStatus_UNKNOWN LoadStatus_State = 0
	LoadStatus_READY   LoadStatus_State = 1
	LoadStatus_ERROR   LoadStatus_State = 2
)

func (LoadStatus_State) Descriptor added in v0.0.72 

func (LoadStatus_State) Descriptor() protoreflect.EnumDescriptor

func (LoadStatus_State) Enum added in v0.0.72 

func (x LoadStatus_State) Enum() *LoadStatus_State

func (LoadStatus_State) EnumDescriptor deprecated added in v0.0.72 

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

Deprecated: Use LoadStatus_State.Descriptor instead.

func (LoadStatus_State) Number added in v0.0.72 

func (x LoadStatus_State) Number() protoreflect.EnumNumber

func (LoadStatus_State) String added in v0.0.72 

func (x LoadStatus_State) String() string

func (LoadStatus_State) Type added in v0.0.72 

func (LoadStatus_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 {
	// Load the Service Agent: this should be a NoOp and never fails
	Load(ctx context.Context, in *LoadRequest, opts ...grpc.CallOption) (*LoadResponse, error)
	// Init the Service Agent: could include steps like compilation, configuration, etc.
	// An important step of Initialization is to get the list of network mappings
	Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*InitResponse, error)
	// Start the underlying service
	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)
	// Stop the underlying service and cleanup
	Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
	// Information about the state of the service
	Information(ctx context.Context, in *InformationRequest, opts ...grpc.CallOption) (*InformationResponse, 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 {
	// Load the Service Agent: this should be a NoOp and never fails
	Load(context.Context, *LoadRequest) (*LoadResponse, error)
	// Init the Service Agent: could include steps like compilation, configuration, etc.
	// An important step of Initialization is to get the list of network mappings
	Init(context.Context, *InitRequest) (*InitResponse, error)
	// Start the underlying service
	Start(context.Context, *StartRequest) (*StartResponse, error)
	// Stop the underlying service and cleanup
	Stop(context.Context, *StopRequest) (*StopResponse, error)
	// Information about the state of the service
	Information(context.Context, *InformationRequest) (*InformationResponse, 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 {
	// contains filtered or unexported fields
}

func (*StopRequest) Descriptor deprecated 

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

Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.

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) Descriptor() ([]byte, []int)

Deprecated: Use Tracker.ProtoReflect.Descriptor instead.

func (*Tracker) GetDockerTracker 

func (x *Tracker) GetDockerTracker() *DockerTracker

func (*Tracker) GetName 

func (x *Tracker) GetName() string

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

func (*Tracker) Reset 

func (x *Tracker) Reset()

func (*Tracker) String 

func (x *Tracker) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Trackers.ProtoReflect.Descriptor instead.

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

func (*Trackers) Reset 

func (x *Trackers) Reset()

func (*Trackers) String 

func (x *Trackers) String() string

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) Information 

func (UnimplementedRuntimeServer) Information(context.Context, *InformationRequest) (*InformationResponse, error)

func (UnimplementedRuntimeServer) Init 

func (UnimplementedRuntimeServer) Init(context.Context, *InitRequest) (*InitResponse, error)

func (UnimplementedRuntimeServer) Load added in v0.0.72 

func (UnimplementedRuntimeServer) Load(context.Context, *LoadRequest) (*LoadResponse, 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.

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.