v0

package
v0.1.107 Latest Latest
Warning

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

 Go to latest Published: May 20, 2024 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Runtime_Load_FullMethodName        = "/services.runtime.v0.Runtime/Load"
	Runtime_Init_FullMethodName        = "/services.runtime.v0.Runtime/Init"
	Runtime_Start_FullMethodName       = "/services.runtime.v0.Runtime/Start"
	Runtime_Stop_FullMethodName        = "/services.runtime.v0.Runtime/Stop"
	Runtime_Destroy_FullMethodName     = "/services.runtime.v0.Runtime/Destroy"
	Runtime_Test_FullMethodName        = "/services.runtime.v0.Runtime/Test"
	Runtime_Information_FullMethodName = "/services.runtime.v0.Runtime/Information"
	Runtime_Communicate_FullMethodName = "/services.runtime.v0.Runtime/Communicate"
)

Variables

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

Enum value maps for LoadStatus_Status.

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

Enum value maps for InitStatus_Status.

View Source 
var (
	StartStatus_Status_name = map[int32]string{
		0: "UNKNOWN",
		1: "STARTED",
		2: "ERROR",
	}
	StartStatus_Status_value = map[string]int32{
		"UNKNOWN": 0,
		"STARTED": 1,
		"ERROR":   2,
	}
)

Enum value maps for StartStatus_Status.

View Source 
var (
	TestStatus_Status_name = map[int32]string{
		0: "UNKNOWN",
		1: "SUCCESS",
		2: "ERROR",
	}
	TestStatus_Status_value = map[string]int32{
		"UNKNOWN": 0,
		"SUCCESS": 1,
		"ERROR":   2,
	}
)

Enum value maps for TestStatus_Status.

View Source 
var (
	StopStatus_Status_name = map[int32]string{
		0: "UNKNOWN",
		1: "SUCCESS",
		2: "ERROR",
	}
	StopStatus_Status_value = map[string]int32{
		"UNKNOWN": 0,
		"SUCCESS": 1,
		"ERROR":   2,
	}
)

Enum value maps for StopStatus_Status.

View Source 
var (
	DestroyStatus_Status_name = map[int32]string{
		0: "UNKNOWN",
		1: "SUCCESS",
		2: "ERROR",
	}
	DestroyStatus_Status_value = map[string]int32{
		"UNKNOWN": 0,
		"SUCCESS": 1,
		"ERROR":   2,
	}
)

Enum value maps for DestroyStatus_Status.

View Source 
var (
	DesiredState_Stage_name = map[int32]string{
		0: "UNKNOWN",
		1: "NOOP",
		2: "LOAD",
		3: "INIT",
		4: "START",
	}
	DesiredState_Stage_value = map[string]int32{
		"UNKNOWN": 0,
		"NOOP":    1,
		"LOAD":    2,
		"INIT":    3,
		"START":   4,
	}
)

Enum value maps for DesiredState_Stage.

View Source 
var File_services_runtime_v0_runtime_proto protoreflect.FileDescriptor
View Source 
var Runtime_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "services.runtime.v0.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: "Destroy",
			Handler:    _Runtime_Destroy_Handler,
		},
		{
			MethodName: "Test",
			Handler:    _Runtime_Test_Handler,
		},
		{
			MethodName: "Information",
			Handler:    _Runtime_Information_Handler,
		},
		{
			MethodName: "Communicate",
			Handler:    _Runtime_Communicate_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "services/runtime/v0/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 DesiredState added in v0.1.20 

type DesiredState struct {
	Stage DesiredState_Stage `protobuf:"varint,1,opt,name=stage,proto3,enum=services.runtime.v0.DesiredState_Stage" json:"stage,omitempty"`
	// contains filtered or unexported fields
}

func (*DesiredState) Descriptor deprecated added in v0.1.20 

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

Deprecated: Use DesiredState.ProtoReflect.Descriptor instead.

func (*DesiredState) GetStage added in v0.1.20 

func (x *DesiredState) GetStage() DesiredState_Stage

func (*DesiredState) ProtoMessage added in v0.1.20 

func (*DesiredState) ProtoMessage()

func (*DesiredState) ProtoReflect added in v0.1.20 

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

func (*DesiredState) Reset added in v0.1.20 

func (x *DesiredState) Reset()

func (*DesiredState) String added in v0.1.20 

func (x *DesiredState) String() string

type DesiredState_Stage added in v0.1.20 

type DesiredState_Stage int32
const (
	DesiredState_UNKNOWN DesiredState_Stage = 0
	DesiredState_NOOP    DesiredState_Stage = 1
	DesiredState_LOAD    DesiredState_Stage = 2
	DesiredState_INIT    DesiredState_Stage = 3
	DesiredState_START   DesiredState_Stage = 4
)

func (DesiredState_Stage) Descriptor added in v0.1.20 

func (DesiredState_Stage) Descriptor() protoreflect.EnumDescriptor

func (DesiredState_Stage) Enum added in v0.1.20 

func (x DesiredState_Stage) Enum() *DesiredState_Stage

func (DesiredState_Stage) EnumDescriptor deprecated added in v0.1.20 

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

Deprecated: Use DesiredState_Stage.Descriptor instead.

func (DesiredState_Stage) Number added in v0.1.20 

func (x DesiredState_Stage) Number() protoreflect.EnumNumber

func (DesiredState_Stage) String added in v0.1.20 

func (x DesiredState_Stage) String() string

func (DesiredState_Stage) Type added in v0.1.20 

func (DesiredState_Stage) Type() protoreflect.EnumType

type DestroyRequest added in v0.1.89 

type DestroyRequest struct {
	// contains filtered or unexported fields
}

func (*DestroyRequest) Descriptor deprecated added in v0.1.89 

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

Deprecated: Use DestroyRequest.ProtoReflect.Descriptor instead.

func (*DestroyRequest) ProtoMessage added in v0.1.89 

func (*DestroyRequest) ProtoMessage()

func (*DestroyRequest) ProtoReflect added in v0.1.89 

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

func (*DestroyRequest) Reset added in v0.1.89 

func (x *DestroyRequest) Reset()

func (*DestroyRequest) String added in v0.1.89 

func (x *DestroyRequest) String() string

type DestroyResponse added in v0.1.89 

type DestroyResponse struct {
	Status *DestroyStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*DestroyResponse) Descriptor deprecated added in v0.1.89 

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

Deprecated: Use DestroyResponse.ProtoReflect.Descriptor instead.

func (*DestroyResponse) GetStatus added in v0.1.89 

func (x *DestroyResponse) GetStatus() *DestroyStatus

func (*DestroyResponse) ProtoMessage added in v0.1.89 

func (*DestroyResponse) ProtoMessage()

func (*DestroyResponse) ProtoReflect added in v0.1.89 

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

func (*DestroyResponse) Reset added in v0.1.89 

func (x *DestroyResponse) Reset()

func (*DestroyResponse) String added in v0.1.89 

func (x *DestroyResponse) String() string

type DestroyStatus added in v0.1.89 

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

func (*DestroyStatus) Descriptor deprecated added in v0.1.89 

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

Deprecated: Use DestroyStatus.ProtoReflect.Descriptor instead.

func (*DestroyStatus) GetMessage added in v0.1.89 

func (x *DestroyStatus) GetMessage() string

func (*DestroyStatus) GetState added in v0.1.89 

func (x *DestroyStatus) GetState() DestroyStatus_Status

func (*DestroyStatus) ProtoMessage added in v0.1.89 

func (*DestroyStatus) ProtoMessage()

func (*DestroyStatus) ProtoReflect added in v0.1.89 

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

func (*DestroyStatus) Reset added in v0.1.89 

func (x *DestroyStatus) Reset()

func (*DestroyStatus) String added in v0.1.89 

func (x *DestroyStatus) String() string

type DestroyStatus_Status added in v0.1.89 

type DestroyStatus_Status int32
const (
	DestroyStatus_UNKNOWN DestroyStatus_Status = 0
	DestroyStatus_SUCCESS DestroyStatus_Status = 1
	DestroyStatus_ERROR   DestroyStatus_Status = 2
)

func (DestroyStatus_Status) Descriptor added in v0.1.89 

func (DestroyStatus_Status) Descriptor() protoreflect.EnumDescriptor

func (DestroyStatus_Status) Enum added in v0.1.89 

func (x DestroyStatus_Status) Enum() *DestroyStatus_Status

func (DestroyStatus_Status) EnumDescriptor deprecated added in v0.1.89 

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

Deprecated: Use DestroyStatus_Status.Descriptor instead.

func (DestroyStatus_Status) Number added in v0.1.89 

func (x DestroyStatus_Status) Number() protoreflect.EnumNumber

func (DestroyStatus_Status) String added in v0.1.89 

func (x DestroyStatus_Status) String() string

func (DestroyStatus_Status) Type added in v0.1.89 

func (DestroyStatus_Status) Type() protoreflect.EnumType

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 {
	DesiredState  *DesiredState  `protobuf:"bytes,1,opt,name=desired_state,json=desiredState,proto3" json:"desired_state,omitempty"`
	LoadStatus    *LoadStatus    `protobuf:"bytes,2,opt,name=load_status,json=loadStatus,proto3" json:"load_status,omitempty"`
	InitStatus    *InitStatus    `protobuf:"bytes,3,opt,name=init_status,json=initStatus,proto3" json:"init_status,omitempty"`
	StartStatus   *StartStatus   `protobuf:"bytes,4,opt,name=start_status,json=startStatus,proto3" json:"start_status,omitempty"`
	StopStatus    *StopStatus    `protobuf:"bytes,5,opt,name=stop_status,json=stopStatus,proto3" json:"stop_status,omitempty"`
	DestroyStatus *DestroyStatus `protobuf:"bytes,6,opt,name=Destroy_status,json=DestroyStatus,proto3" json:"Destroy_status,omitempty"`
	TestStatus    *TestStatus    `protobuf:"bytes,7,opt,name=test_status,json=testStatus,proto3" json:"test_status,omitempty"`
	// contains filtered or unexported fields
}

InformationResponse represents the overall state of the service

func (*InformationResponse) Descriptor deprecated 

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

Deprecated: Use InformationResponse.ProtoReflect.Descriptor instead.

func (*InformationResponse) GetDesiredState 

func (x *InformationResponse) GetDesiredState() *DesiredState

func (*InformationResponse) GetDestroyStatus added in v0.1.89 

func (x *InformationResponse) GetDestroyStatus() *DestroyStatus

func (*InformationResponse) GetInitStatus added in v0.1.20 

func (x *InformationResponse) GetInitStatus() *InitStatus

func (*InformationResponse) GetLoadStatus added in v0.1.20 

func (x *InformationResponse) GetLoadStatus() *LoadStatus

func (*InformationResponse) GetStartStatus added in v0.1.20 

func (x *InformationResponse) GetStartStatus() *StartStatus

func (*InformationResponse) GetStopStatus added in v0.1.24 

func (x *InformationResponse) GetStopStatus() *StopStatus

func (*InformationResponse) GetTestStatus added in v0.1.89 

func (x *InformationResponse) GetTestStatus() *TestStatus

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 InitRequest 

type InitRequest struct {

	// RuntimeContext for the service
	RuntimeContext *v0.RuntimeContext `protobuf:"bytes,1,opt,name=runtime_context,json=runtimeContext,proto3" json:"runtime_context,omitempty"`
	// Configuration of the service
	Configuration *v0.Configuration `protobuf:"bytes,2,opt,name=configuration,proto3" json:"configuration,omitempty"`
	// Proposed Network mappings for the service
	ProposedNetworkMappings []*v0.NetworkMapping `` /* 132-byte string literal not displayed */
	// Endpoints for the dependencies
	DependenciesEndpoints []*v0.Endpoint `protobuf:"bytes,4,rep,name=dependencies_endpoints,json=dependenciesEndpoints,proto3" json:"dependencies_endpoints,omitempty"`
	// Configurations exposed by the dependencies
	DependenciesConfigurations []*v0.Configuration `` /* 139-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) GetConfiguration added in v0.1.62 

func (x *InitRequest) GetConfiguration() *v0.Configuration

func (*InitRequest) GetDependenciesConfigurations added in v0.1.62 

func (x *InitRequest) GetDependenciesConfigurations() []*v0.Configuration

func (*InitRequest) GetDependenciesEndpoints 

func (x *InitRequest) GetDependenciesEndpoints() []*v0.Endpoint

func (*InitRequest) GetProposedNetworkMappings added in v0.1.33 

func (x *InitRequest) GetProposedNetworkMappings() []*v0.NetworkMapping

func (*InitRequest) GetRuntimeContext added in v0.1.89 

func (x *InitRequest) GetRuntimeContext() *v0.RuntimeContext

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,1,opt,name=status,proto3" json:"status,omitempty"`
	RuntimeContext *v0.RuntimeContext `protobuf:"bytes,2,opt,name=runtime_context,json=runtimeContext,proto3" json:"runtime_context,omitempty"`
	// Actual Network mappings for the service
	NetworkMappings []*v0.NetworkMapping `protobuf:"bytes,3,rep,name=network_mappings,json=networkMappings,proto3" json:"network_mappings,omitempty"`
	// A service provides configurations for different runtime contexts to other services
	RuntimeConfigurations []*v0.Configuration `protobuf:"bytes,4,rep,name=runtime_configurations,json=runtimeConfigurations,proto3" json:"runtime_configurations,omitempty"`
	// contains filtered or unexported fields
}

func (*InitResponse) Descriptor deprecated 

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

Deprecated: Use InitResponse.ProtoReflect.Descriptor instead.

func (*InitResponse) GetNetworkMappings 

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

func (*InitResponse) GetRuntimeConfigurations added in v0.1.89 

func (x *InitResponse) GetRuntimeConfigurations() []*v0.Configuration

func (*InitResponse) GetRuntimeContext added in v0.1.89 

func (x *InitResponse) GetRuntimeContext() *v0.RuntimeContext

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_Status `protobuf:"varint,1,opt,name=state,proto3,enum=services.runtime.v0.InitStatus_Status" 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_Status

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_Status added in v0.1.24 

type InitStatus_Status int32
const (
	InitStatus_UNKNOWN InitStatus_Status = 0
	InitStatus_READY   InitStatus_Status = 1
	InitStatus_ERROR   InitStatus_Status = 2
)

func (InitStatus_Status) Descriptor added in v0.1.24 

func (InitStatus_Status) Descriptor() protoreflect.EnumDescriptor

func (InitStatus_Status) Enum added in v0.1.24 

func (x InitStatus_Status) Enum() *InitStatus_Status

func (InitStatus_Status) EnumDescriptor deprecated added in v0.1.24 

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

Deprecated: Use InitStatus_Status.Descriptor instead.

func (InitStatus_Status) Number added in v0.1.24 

func (x InitStatus_Status) Number() protoreflect.EnumNumber

func (InitStatus_Status) String added in v0.1.24 

func (x InitStatus_Status) String() string

func (InitStatus_Status) Type added in v0.1.24 

func (InitStatus_Status) Type() protoreflect.EnumType

type LoadRequest 

type LoadRequest struct {

	// Developer debug
	DeveloperDebug bool `protobuf:"varint,1,opt,name=developer_debug,json=developerDebug,proto3" json:"developer_debug,omitempty"`
	// Disable catch
	DisableCatch bool `protobuf:"varint,2,opt,name=disable_catch,json=disableCatch,proto3" json:"disable_catch,omitempty"`
	// Identity of the service
	Identity *v0.ServiceIdentity `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	// Environment
	Environment *v0.Environment `protobuf:"bytes,4,opt,name=environment,proto3" json:"environment,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadRequest) Descriptor deprecated 

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

Deprecated: Use LoadRequest.ProtoReflect.Descriptor instead.

func (*LoadRequest) GetDeveloperDebug added in v0.1.89 

func (x *LoadRequest) GetDeveloperDebug() bool

func (*LoadRequest) GetDisableCatch added in v0.1.89 

func (x *LoadRequest) GetDisableCatch() bool

func (*LoadRequest) GetEnvironment added in v0.1.25 

func (x *LoadRequest) GetEnvironment() *v0.Environment

func (*LoadRequest) GetIdentity 

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

func (*LoadRequest) ProtoMessage 

func (*LoadRequest) ProtoMessage()

func (*LoadRequest) ProtoReflect 

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

func (*LoadRequest) Reset 

func (x *LoadRequest) Reset()

func (*LoadRequest) String 

func (x *LoadRequest) String() string

type LoadResponse 

type LoadResponse struct {
	Version *v0.Version `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Status  *LoadStatus `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// Endpoints exposed by the service
	Endpoints []*v0.Endpoint `protobuf:"bytes,3,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadResponse) Descriptor deprecated 

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

Deprecated: Use LoadResponse.ProtoReflect.Descriptor instead.

func (*LoadResponse) GetEndpoints 

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

func (*LoadResponse) GetStatus 

func (x *LoadResponse) GetStatus() *LoadStatus

func (*LoadResponse) GetVersion 

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

func (*LoadResponse) ProtoMessage 

func (*LoadResponse) ProtoMessage()

func (*LoadResponse) ProtoReflect 

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

func (*LoadResponse) Reset 

func (x *LoadResponse) Reset()

func (*LoadResponse) String 

func (x *LoadResponse) String() string

type LoadStatus 

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

func (*LoadStatus) Descriptor deprecated 

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

Deprecated: Use LoadStatus.ProtoReflect.Descriptor instead.

func (*LoadStatus) GetMessage 

func (x *LoadStatus) GetMessage() string

func (*LoadStatus) GetState 

func (x *LoadStatus) GetState() LoadStatus_Status

func (*LoadStatus) ProtoMessage 

func (*LoadStatus) ProtoMessage()

func (*LoadStatus) ProtoReflect 

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

func (*LoadStatus) Reset 

func (x *LoadStatus) Reset()

func (*LoadStatus) String 

func (x *LoadStatus) String() string

type LoadStatus_Status added in v0.1.24 

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

func (LoadStatus_Status) Descriptor added in v0.1.24 

func (LoadStatus_Status) Descriptor() protoreflect.EnumDescriptor

func (LoadStatus_Status) Enum added in v0.1.24 

func (x LoadStatus_Status) Enum() *LoadStatus_Status

func (LoadStatus_Status) EnumDescriptor deprecated added in v0.1.24 

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

Deprecated: Use LoadStatus_Status.Descriptor instead.

func (LoadStatus_Status) Number added in v0.1.24 

func (x LoadStatus_Status) Number() protoreflect.EnumNumber

func (LoadStatus_Status) String added in v0.1.24 

func (x LoadStatus_Status) String() string

func (LoadStatus_Status) Type added in v0.1.24 

func (LoadStatus_Status) Type() protoreflect.EnumType

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
	Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
	// Destroy the underlying service
	Destroy(ctx context.Context, in *DestroyRequest, opts ...grpc.CallOption) (*DestroyResponse, error)
	// Test the service
	Test(ctx context.Context, in *TestRequest, opts ...grpc.CallOption) (*TestResponse, 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 *v0.Engage, opts ...grpc.CallOption) (*v0.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
	Stop(context.Context, *StopRequest) (*StopResponse, error)
	// Destroy the underlying service
	Destroy(context.Context, *DestroyRequest) (*DestroyResponse, error)
	// Test the service
	Test(context.Context, *TestRequest) (*TestResponse, error)
	// Information about the state of the service
	Information(context.Context, *InformationRequest) (*InformationResponse, error)
	// Communication helper
	Communicate(context.Context, *v0.Engage) (*v0.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 {

	// Specs affecting the runner
	Specs *v0.Specs `protobuf:"bytes,1,opt,name=specs,proto3" json:"specs,omitempty"`
	// Network mappings for the dependencies
	DependenciesNetworkMappings []*v0.NetworkMapping `` /* 144-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) GetDependenciesNetworkMappings added in v0.1.69 

func (x *StartRequest) GetDependenciesNetworkMappings() []*v0.NetworkMapping

func (*StartRequest) GetSpecs added in v0.1.89 

func (x *StartRequest) GetSpecs() *v0.Specs

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"`
	// 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) 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_Status `protobuf:"varint,1,opt,name=state,proto3,enum=services.runtime.v0.StartStatus_Status" 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_Status

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_Status added in v0.1.24 

type StartStatus_Status int32
const (
	StartStatus_UNKNOWN StartStatus_Status = 0
	StartStatus_STARTED StartStatus_Status = 1
	StartStatus_ERROR   StartStatus_Status = 2
)

func (StartStatus_Status) Descriptor added in v0.1.24 

func (StartStatus_Status) Descriptor() protoreflect.EnumDescriptor

func (StartStatus_Status) Enum added in v0.1.24 

func (x StartStatus_Status) Enum() *StartStatus_Status

func (StartStatus_Status) EnumDescriptor deprecated added in v0.1.24 

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

Deprecated: Use StartStatus_Status.Descriptor instead.

func (StartStatus_Status) Number added in v0.1.24 

func (x StartStatus_Status) Number() protoreflect.EnumNumber

func (StartStatus_Status) String added in v0.1.24 

func (x StartStatus_Status) String() string

func (StartStatus_Status) Type added in v0.1.24 

func (StartStatus_Status) 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 {
	Status *StopStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*StopResponse) Descriptor deprecated 

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

Deprecated: Use StopResponse.ProtoReflect.Descriptor instead.

func (*StopResponse) GetStatus added in v0.1.24 

func (x *StopResponse) GetStatus() *StopStatus

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 StopStatus added in v0.1.24 

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

func (*StopStatus) Descriptor deprecated added in v0.1.24 

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

Deprecated: Use StopStatus.ProtoReflect.Descriptor instead.

func (*StopStatus) GetMessage added in v0.1.24 

func (x *StopStatus) GetMessage() string

func (*StopStatus) GetState added in v0.1.24 

func (x *StopStatus) GetState() StopStatus_Status

func (*StopStatus) ProtoMessage added in v0.1.24 

func (*StopStatus) ProtoMessage()

func (*StopStatus) ProtoReflect added in v0.1.24 

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

func (*StopStatus) Reset added in v0.1.24 

func (x *StopStatus) Reset()

func (*StopStatus) String added in v0.1.24 

func (x *StopStatus) String() string

type StopStatus_Status added in v0.1.24 

type StopStatus_Status int32
const (
	StopStatus_UNKNOWN StopStatus_Status = 0
	StopStatus_SUCCESS StopStatus_Status = 1
	StopStatus_ERROR   StopStatus_Status = 2
)

func (StopStatus_Status) Descriptor added in v0.1.24 

func (StopStatus_Status) Descriptor() protoreflect.EnumDescriptor

func (StopStatus_Status) Enum added in v0.1.24 

func (x StopStatus_Status) Enum() *StopStatus_Status

func (StopStatus_Status) EnumDescriptor deprecated added in v0.1.24 

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

Deprecated: Use StopStatus_Status.Descriptor instead.

func (StopStatus_Status) Number added in v0.1.24 

func (x StopStatus_Status) Number() protoreflect.EnumNumber

func (StopStatus_Status) String added in v0.1.24 

func (x StopStatus_Status) String() string

func (StopStatus_Status) Type added in v0.1.24 

func (StopStatus_Status) Type() protoreflect.EnumType

type TestRequest added in v0.1.74 

type TestRequest struct {
	// contains filtered or unexported fields
}

func (*TestRequest) Descriptor deprecated added in v0.1.74 

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

Deprecated: Use TestRequest.ProtoReflect.Descriptor instead.

func (*TestRequest) ProtoMessage added in v0.1.74 

func (*TestRequest) ProtoMessage()

func (*TestRequest) ProtoReflect added in v0.1.74 

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

func (*TestRequest) Reset added in v0.1.74 

func (x *TestRequest) Reset()

func (*TestRequest) String added in v0.1.74 

func (x *TestRequest) String() string

type TestResponse added in v0.1.74 

type TestResponse struct {
	Status *TestStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*TestResponse) Descriptor deprecated added in v0.1.74 

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

Deprecated: Use TestResponse.ProtoReflect.Descriptor instead.

func (*TestResponse) GetStatus added in v0.1.74 

func (x *TestResponse) GetStatus() *TestStatus

func (*TestResponse) ProtoMessage added in v0.1.74 

func (*TestResponse) ProtoMessage()

func (*TestResponse) ProtoReflect added in v0.1.74 

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

func (*TestResponse) Reset added in v0.1.74 

func (x *TestResponse) Reset()

func (*TestResponse) String added in v0.1.74 

func (x *TestResponse) String() string

type TestStatus added in v0.1.74 

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

func (*TestStatus) Descriptor deprecated added in v0.1.74 

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

Deprecated: Use TestStatus.ProtoReflect.Descriptor instead.

func (*TestStatus) GetMessage added in v0.1.74 

func (x *TestStatus) GetMessage() string

func (*TestStatus) GetState added in v0.1.74 

func (x *TestStatus) GetState() TestStatus_Status

func (*TestStatus) ProtoMessage added in v0.1.74 

func (*TestStatus) ProtoMessage()

func (*TestStatus) ProtoReflect added in v0.1.74 

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

func (*TestStatus) Reset added in v0.1.74 

func (x *TestStatus) Reset()

func (*TestStatus) String added in v0.1.74 

func (x *TestStatus) String() string

type TestStatus_Status added in v0.1.74 

type TestStatus_Status int32
const (
	TestStatus_UNKNOWN TestStatus_Status = 0
	TestStatus_SUCCESS TestStatus_Status = 1
	TestStatus_ERROR   TestStatus_Status = 2
)

func (TestStatus_Status) Descriptor added in v0.1.74 

func (TestStatus_Status) Descriptor() protoreflect.EnumDescriptor

func (TestStatus_Status) Enum added in v0.1.74 

func (x TestStatus_Status) Enum() *TestStatus_Status

func (TestStatus_Status) EnumDescriptor deprecated added in v0.1.74 

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

Deprecated: Use TestStatus_Status.Descriptor instead.

func (TestStatus_Status) Number added in v0.1.74 

func (x TestStatus_Status) Number() protoreflect.EnumNumber

func (TestStatus_Status) String added in v0.1.74 

func (x TestStatus_Status) String() string

func (TestStatus_Status) Type added in v0.1.74 

func (TestStatus_Status) Type() protoreflect.EnumType

type UnimplementedRuntimeServer 

type UnimplementedRuntimeServer struct {
}

UnimplementedRuntimeServer must be embedded to have forward compatible implementations.

func (UnimplementedRuntimeServer) Communicate 

func (UnimplementedRuntimeServer) Communicate(context.Context, *v0.Engage) (*v0.InformationRequest, error)

func (UnimplementedRuntimeServer) Destroy added in v0.1.89 

func (UnimplementedRuntimeServer) Destroy(context.Context, *DestroyRequest) (*DestroyResponse, 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 

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)

func (UnimplementedRuntimeServer) Test added in v0.1.74 

func (UnimplementedRuntimeServer) Test(context.Context, *TestRequest) (*TestResponse, 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.