kurtosis_core_rpc_api_bindings

package
v0.0.0-...-86958d0 Latest Latest
Warning

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

 Go to latest Published: Nov 4, 2021 License: Apache-2.0 Imports: 9 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ApiContainerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api_container_api.ApiContainerService",
	HandlerType: (*ApiContainerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StartExternalContainerRegistration",
			Handler:    _ApiContainerService_StartExternalContainerRegistration_Handler,
		},
		{
			MethodName: "FinishExternalContainerRegistration",
			Handler:    _ApiContainerService_FinishExternalContainerRegistration_Handler,
		},
		{
			MethodName: "LoadModule",
			Handler:    _ApiContainerService_LoadModule_Handler,
		},
		{
			MethodName: "UnloadModule",
			Handler:    _ApiContainerService_UnloadModule_Handler,
		},
		{
			MethodName: "ExecuteModule",
			Handler:    _ApiContainerService_ExecuteModule_Handler,
		},
		{
			MethodName: "GetModuleInfo",
			Handler:    _ApiContainerService_GetModuleInfo_Handler,
		},
		{
			MethodName: "RegisterFilesArtifacts",
			Handler:    _ApiContainerService_RegisterFilesArtifacts_Handler,
		},
		{
			MethodName: "RegisterService",
			Handler:    _ApiContainerService_RegisterService_Handler,
		},
		{
			MethodName: "StartService",
			Handler:    _ApiContainerService_StartService_Handler,
		},
		{
			MethodName: "GetServiceInfo",
			Handler:    _ApiContainerService_GetServiceInfo_Handler,
		},
		{
			MethodName: "RemoveService",
			Handler:    _ApiContainerService_RemoveService_Handler,
		},
		{
			MethodName: "Repartition",
			Handler:    _ApiContainerService_Repartition_Handler,
		},
		{
			MethodName: "ExecCommand",
			Handler:    _ApiContainerService_ExecCommand_Handler,
		},
		{
			MethodName: "WaitForHttpGetEndpointAvailability",
			Handler:    _ApiContainerService_WaitForHttpGetEndpointAvailability_Handler,
		},
		{
			MethodName: "WaitForHttpPostEndpointAvailability",
			Handler:    _ApiContainerService_WaitForHttpPostEndpointAvailability_Handler,
		},
		{
			MethodName: "ExecuteBulkCommands",
			Handler:    _ApiContainerService_ExecuteBulkCommands_Handler,
		},
		{
			MethodName: "GetServices",
			Handler:    _ApiContainerService_GetServices_Handler,
		},
		{
			MethodName: "GetModules",
			Handler:    _ApiContainerService_GetModules_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api_container_service.proto",
}

ApiContainerService_ServiceDesc is the grpc.ServiceDesc for ApiContainerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_api_container_service_proto protoreflect.FileDescriptor

Functions

func RegisterApiContainerServiceServer 

func RegisterApiContainerServiceServer(s grpc.ServiceRegistrar, srv ApiContainerServiceServer)

Types

type ApiContainerServiceClient 

type ApiContainerServiceClient interface {
	// Starts the registration of an external container (started by a third-party source, not the API container)
	StartExternalContainerRegistration(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*StartExternalContainerRegistrationResponse, error)
	// Finishes the registration of an container (started by a third-party source, not the API contianer) that was started previously
	// NOTE: It's important not to forget to finish this registration, else the external container won't be recognized by the API container!
	FinishExternalContainerRegistration(ctx context.Context, in *FinishExternalContainerRegistrationArgs, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Starts a module container in the enclave
	LoadModule(ctx context.Context, in *LoadModuleArgs, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Stop and remove a module from the enclave
	UnloadModule(ctx context.Context, in *UnloadModuleArgs, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Executes an executable module on the user's behalf
	ExecuteModule(ctx context.Context, in *ExecuteModuleArgs, opts ...grpc.CallOption) (*ExecuteModuleResponse, error)
	// Gets information about a loaded module
	GetModuleInfo(ctx context.Context, in *GetModuleInfoArgs, opts ...grpc.CallOption) (*GetModuleInfoResponse, error)
	// Tells the API container that the client has files artifacts from the web that it would like the API container to know about
	// The API container will download these artifacts locally, so they're available when launching services
	RegisterFilesArtifacts(ctx context.Context, in *RegisterFilesArtifactsArgs, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Registers a service with the API container but doesn't start the container for it
	RegisterService(ctx context.Context, in *RegisterServiceArgs, opts ...grpc.CallOption) (*RegisterServiceResponse, error)
	// Starts a previously-registered service by creating a Docker container for it
	StartService(ctx context.Context, in *StartServiceArgs, opts ...grpc.CallOption) (*StartServiceResponse, error)
	// Returns relevant information about the service
	GetServiceInfo(ctx context.Context, in *GetServiceInfoArgs, opts ...grpc.CallOption) (*GetServiceInfoResponse, error)
	// Instructs the API container to remove the given service
	RemoveService(ctx context.Context, in *RemoveServiceArgs, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Instructs the API container to repartition the enclave
	Repartition(ctx context.Context, in *RepartitionArgs, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Executes the given command inside a running container
	ExecCommand(ctx context.Context, in *ExecCommandArgs, opts ...grpc.CallOption) (*ExecCommandResponse, error)
	// Block until the given HTTP endpoint returns available, calling it through a HTTP Get request
	WaitForHttpGetEndpointAvailability(ctx context.Context, in *WaitForHttpGetEndpointAvailabilityArgs, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Block until the given HTTP endpoint returns available, calling it through a HTTP Post request
	WaitForHttpPostEndpointAvailability(ctx context.Context, in *WaitForHttpPostEndpointAvailabilityArgs, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Executes multiple commands at once
	ExecuteBulkCommands(ctx context.Context, in *ExecuteBulkCommandsArgs, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Returns the IDs of the current services in the enclave
	GetServices(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetServicesResponse, error)
	// Returns the IDs of the Kurtosis modules that have been loaded into the enclave
	GetModules(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetModulesResponse, error)
}

ApiContainerServiceClient is the client API for ApiContainerService 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 NewApiContainerServiceClient 

func NewApiContainerServiceClient(cc grpc.ClientConnInterface) ApiContainerServiceClient

type ApiContainerServiceServer 

type ApiContainerServiceServer interface {
	// Starts the registration of an external container (started by a third-party source, not the API container)
	StartExternalContainerRegistration(context.Context, *emptypb.Empty) (*StartExternalContainerRegistrationResponse, error)
	// Finishes the registration of an container (started by a third-party source, not the API contianer) that was started previously
	// NOTE: It's important not to forget to finish this registration, else the external container won't be recognized by the API container!
	FinishExternalContainerRegistration(context.Context, *FinishExternalContainerRegistrationArgs) (*emptypb.Empty, error)
	// Starts a module container in the enclave
	LoadModule(context.Context, *LoadModuleArgs) (*emptypb.Empty, error)
	// Stop and remove a module from the enclave
	UnloadModule(context.Context, *UnloadModuleArgs) (*emptypb.Empty, error)
	// Executes an executable module on the user's behalf
	ExecuteModule(context.Context, *ExecuteModuleArgs) (*ExecuteModuleResponse, error)
	// Gets information about a loaded module
	GetModuleInfo(context.Context, *GetModuleInfoArgs) (*GetModuleInfoResponse, error)
	// Tells the API container that the client has files artifacts from the web that it would like the API container to know about
	// The API container will download these artifacts locally, so they're available when launching services
	RegisterFilesArtifacts(context.Context, *RegisterFilesArtifactsArgs) (*emptypb.Empty, error)
	// Registers a service with the API container but doesn't start the container for it
	RegisterService(context.Context, *RegisterServiceArgs) (*RegisterServiceResponse, error)
	// Starts a previously-registered service by creating a Docker container for it
	StartService(context.Context, *StartServiceArgs) (*StartServiceResponse, error)
	// Returns relevant information about the service
	GetServiceInfo(context.Context, *GetServiceInfoArgs) (*GetServiceInfoResponse, error)
	// Instructs the API container to remove the given service
	RemoveService(context.Context, *RemoveServiceArgs) (*emptypb.Empty, error)
	// Instructs the API container to repartition the enclave
	Repartition(context.Context, *RepartitionArgs) (*emptypb.Empty, error)
	// Executes the given command inside a running container
	ExecCommand(context.Context, *ExecCommandArgs) (*ExecCommandResponse, error)
	// Block until the given HTTP endpoint returns available, calling it through a HTTP Get request
	WaitForHttpGetEndpointAvailability(context.Context, *WaitForHttpGetEndpointAvailabilityArgs) (*emptypb.Empty, error)
	// Block until the given HTTP endpoint returns available, calling it through a HTTP Post request
	WaitForHttpPostEndpointAvailability(context.Context, *WaitForHttpPostEndpointAvailabilityArgs) (*emptypb.Empty, error)
	// Executes multiple commands at once
	ExecuteBulkCommands(context.Context, *ExecuteBulkCommandsArgs) (*emptypb.Empty, error)
	// Returns the IDs of the current services in the enclave
	GetServices(context.Context, *emptypb.Empty) (*GetServicesResponse, error)
	// Returns the IDs of the Kurtosis modules that have been loaded into the enclave
	GetModules(context.Context, *emptypb.Empty) (*GetModulesResponse, error)
	// contains filtered or unexported methods
}

ApiContainerServiceServer is the server API for ApiContainerService service. All implementations must embed UnimplementedApiContainerServiceServer for forward compatibility

type ExecCommandArgs 

type ExecCommandArgs struct {

	// The service ID of the container that the command should be executed in
	ServiceId   string   `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	CommandArgs []string `protobuf:"bytes,2,rep,name=command_args,json=commandArgs,proto3" json:"command_args,omitempty"`
	// contains filtered or unexported fields
}

============================================================================================== 

Exec Command

==============================================================================================

func (*ExecCommandArgs) Descriptor deprecated 

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

Deprecated: Use ExecCommandArgs.ProtoReflect.Descriptor instead.

func (*ExecCommandArgs) GetCommandArgs 

func (x *ExecCommandArgs) GetCommandArgs() []string

func (*ExecCommandArgs) GetServiceId 

func (x *ExecCommandArgs) GetServiceId() string

func (*ExecCommandArgs) ProtoMessage 

func (*ExecCommandArgs) ProtoMessage()

func (*ExecCommandArgs) ProtoReflect 

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

func (*ExecCommandArgs) Reset 

func (x *ExecCommandArgs) Reset()

func (*ExecCommandArgs) String 

func (x *ExecCommandArgs) String() string

type ExecCommandResponse 

type ExecCommandResponse struct {
	ExitCode int32 `protobuf:"varint,1,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// Assumes UTF-8 encoding
	LogOutput string `protobuf:"bytes,2,opt,name=log_output,json=logOutput,proto3" json:"log_output,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecCommandResponse) Descriptor deprecated 

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

Deprecated: Use ExecCommandResponse.ProtoReflect.Descriptor instead.

func (*ExecCommandResponse) GetExitCode 

func (x *ExecCommandResponse) GetExitCode() int32

func (*ExecCommandResponse) GetLogOutput 

func (x *ExecCommandResponse) GetLogOutput() string

func (*ExecCommandResponse) ProtoMessage 

func (*ExecCommandResponse) ProtoMessage()

func (*ExecCommandResponse) ProtoReflect 

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

func (*ExecCommandResponse) Reset 

func (x *ExecCommandResponse) Reset()

func (*ExecCommandResponse) String 

func (x *ExecCommandResponse) String() string

type ExecuteBulkCommandsArgs 

type ExecuteBulkCommandsArgs struct {

	// Commands, serialized as JSON
	SerializedCommands string `protobuf:"bytes,1,opt,name=serialized_commands,json=serializedCommands,proto3" json:"serialized_commands,omitempty"`
	// contains filtered or unexported fields
}

============================================================================================== 

Execute Bulk Commands

==============================================================================================

func (*ExecuteBulkCommandsArgs) Descriptor deprecated 

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

Deprecated: Use ExecuteBulkCommandsArgs.ProtoReflect.Descriptor instead.

func (*ExecuteBulkCommandsArgs) GetSerializedCommands 

func (x *ExecuteBulkCommandsArgs) GetSerializedCommands() string

func (*ExecuteBulkCommandsArgs) ProtoMessage 

func (*ExecuteBulkCommandsArgs) ProtoMessage()

func (*ExecuteBulkCommandsArgs) ProtoReflect 

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

func (*ExecuteBulkCommandsArgs) Reset 

func (x *ExecuteBulkCommandsArgs) Reset()

func (*ExecuteBulkCommandsArgs) String 

func (x *ExecuteBulkCommandsArgs) String() string

type ExecuteModuleArgs 

type ExecuteModuleArgs struct {
	ModuleId string `protobuf:"bytes,1,opt,name=module_id,json=moduleId,proto3" json:"module_id,omitempty"`
	// Serialized parameters data for the module's execute function
	// The serialization format is dependent on the Module
	SerializedParams string `protobuf:"bytes,2,opt,name=serialized_params,json=serializedParams,proto3" json:"serialized_params,omitempty"`
	// contains filtered or unexported fields
}

============================================================================================== 

Execute Module

==============================================================================================

func (*ExecuteModuleArgs) Descriptor deprecated 

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

Deprecated: Use ExecuteModuleArgs.ProtoReflect.Descriptor instead.

func (*ExecuteModuleArgs) GetModuleId 

func (x *ExecuteModuleArgs) GetModuleId() string

func (*ExecuteModuleArgs) GetSerializedParams 

func (x *ExecuteModuleArgs) GetSerializedParams() string

func (*ExecuteModuleArgs) ProtoMessage 

func (*ExecuteModuleArgs) ProtoMessage()

func (*ExecuteModuleArgs) ProtoReflect 

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

func (*ExecuteModuleArgs) Reset 

func (x *ExecuteModuleArgs) Reset()

func (*ExecuteModuleArgs) String 

func (x *ExecuteModuleArgs) String() string

type ExecuteModuleResponse 

type ExecuteModuleResponse struct {

	// Serialized result data from the module's execute function
	// The serialization format is dependent on the Module
	SerializedResult string `protobuf:"bytes,1,opt,name=serialized_result,json=serializedResult,proto3" json:"serialized_result,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteModuleResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteModuleResponse.ProtoReflect.Descriptor instead.

func (*ExecuteModuleResponse) GetSerializedResult 

func (x *ExecuteModuleResponse) GetSerializedResult() string

func (*ExecuteModuleResponse) ProtoMessage 

func (*ExecuteModuleResponse) ProtoMessage()

func (*ExecuteModuleResponse) ProtoReflect 

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

func (*ExecuteModuleResponse) Reset 

func (x *ExecuteModuleResponse) Reset()

func (*ExecuteModuleResponse) String 

func (x *ExecuteModuleResponse) String() string

type FinishExternalContainerRegistrationArgs 

type FinishExternalContainerRegistrationArgs struct {

	// The key that was returned from the call to start external container registration
	RegistrationKey string `protobuf:"bytes,1,opt,name=registration_key,json=registrationKey,proto3" json:"registration_key,omitempty"`
	// The container ID of the container that is now inside the enclave
	ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

============================================================================================== 

Finish External Container Registration

==============================================================================================

func (*FinishExternalContainerRegistrationArgs) Descriptor deprecated 

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

Deprecated: Use FinishExternalContainerRegistrationArgs.ProtoReflect.Descriptor instead.

func (*FinishExternalContainerRegistrationArgs) GetContainerId 

func (x *FinishExternalContainerRegistrationArgs) GetContainerId() string

func (*FinishExternalContainerRegistrationArgs) GetRegistrationKey 

func (x *FinishExternalContainerRegistrationArgs) GetRegistrationKey() string

func (*FinishExternalContainerRegistrationArgs) ProtoMessage 

func (*FinishExternalContainerRegistrationArgs) ProtoMessage()

func (*FinishExternalContainerRegistrationArgs) ProtoReflect 

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

func (*FinishExternalContainerRegistrationArgs) Reset 

func (x *FinishExternalContainerRegistrationArgs) Reset()

func (*FinishExternalContainerRegistrationArgs) String 

func (x *FinishExternalContainerRegistrationArgs) String() string

type GetModuleInfoArgs 

type GetModuleInfoArgs struct {
	ModuleId string `protobuf:"bytes,1,opt,name=module_id,json=moduleId,proto3" json:"module_id,omitempty"`
	// contains filtered or unexported fields
}

============================================================================================== 

Get Module Info

==============================================================================================

func (*GetModuleInfoArgs) Descriptor deprecated 

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

Deprecated: Use GetModuleInfoArgs.ProtoReflect.Descriptor instead.

func (*GetModuleInfoArgs) GetModuleId 

func (x *GetModuleInfoArgs) GetModuleId() string

func (*GetModuleInfoArgs) ProtoMessage 

func (*GetModuleInfoArgs) ProtoMessage()

func (*GetModuleInfoArgs) ProtoReflect 

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

func (*GetModuleInfoArgs) Reset 

func (x *GetModuleInfoArgs) Reset()

func (*GetModuleInfoArgs) String 

func (x *GetModuleInfoArgs) String() string

type GetModuleInfoResponse 

type GetModuleInfoResponse struct {
	IpAddr string `protobuf:"bytes,1,opt,name=ip_addr,json=ipAddr,proto3" json:"ip_addr,omitempty"`
	// contains filtered or unexported fields
}

func (*GetModuleInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetModuleInfoResponse.ProtoReflect.Descriptor instead.

func (*GetModuleInfoResponse) GetIpAddr 

func (x *GetModuleInfoResponse) GetIpAddr() string

func (*GetModuleInfoResponse) ProtoMessage 

func (*GetModuleInfoResponse) ProtoMessage()

func (*GetModuleInfoResponse) ProtoReflect 

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

func (*GetModuleInfoResponse) Reset 

func (x *GetModuleInfoResponse) Reset()

func (*GetModuleInfoResponse) String 

func (x *GetModuleInfoResponse) String() string

type GetModulesResponse 

type GetModulesResponse struct {

	// "Set" of current Kurtosis module IDs loaded in the enclave
	ModuleIds map[string]bool `` /* 177-byte string literal not displayed */
	// contains filtered or unexported fields
}

============================================================================================== 

Get Modules

==============================================================================================

func (*GetModulesResponse) Descriptor deprecated 

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

Deprecated: Use GetModulesResponse.ProtoReflect.Descriptor instead.

func (*GetModulesResponse) GetModuleIds 

func (x *GetModulesResponse) GetModuleIds() map[string]bool

func (*GetModulesResponse) ProtoMessage 

func (*GetModulesResponse) ProtoMessage()

func (*GetModulesResponse) ProtoReflect 

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

func (*GetModulesResponse) Reset 

func (x *GetModulesResponse) Reset()

func (*GetModulesResponse) String 

func (x *GetModulesResponse) String() string

type GetServiceInfoArgs 

type GetServiceInfoArgs struct {

	//The service ID to get the info from
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// contains filtered or unexported fields
}

============================================================================================== 

Get Service Info

==============================================================================================

func (*GetServiceInfoArgs) Descriptor deprecated 

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

Deprecated: Use GetServiceInfoArgs.ProtoReflect.Descriptor instead.

func (*GetServiceInfoArgs) GetServiceId 

func (x *GetServiceInfoArgs) GetServiceId() string

func (*GetServiceInfoArgs) ProtoMessage 

func (*GetServiceInfoArgs) ProtoMessage()

func (*GetServiceInfoArgs) ProtoReflect 

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

func (*GetServiceInfoArgs) Reset 

func (x *GetServiceInfoArgs) Reset()

func (*GetServiceInfoArgs) String 

func (x *GetServiceInfoArgs) String() string

type GetServiceInfoResponse 

type GetServiceInfoResponse struct {

	// The IP address of the service
	IpAddr string `protobuf:"bytes,1,opt,name=ip_addr,json=ipAddr,proto3" json:"ip_addr,omitempty"`
	// The full path where the enclave data dir is mounted on the service
	EnclaveDataDirMountDirpath string `` /* 145-byte string literal not displayed */
	// The dirpath where the service's directory exists inside the enclave data directory, relative to the enclave data directory root
	RelativeServiceDirpath string `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetServiceInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetServiceInfoResponse.ProtoReflect.Descriptor instead.

func (*GetServiceInfoResponse) GetEnclaveDataDirMountDirpath 

func (x *GetServiceInfoResponse) GetEnclaveDataDirMountDirpath() string

func (*GetServiceInfoResponse) GetIpAddr 

func (x *GetServiceInfoResponse) GetIpAddr() string

func (*GetServiceInfoResponse) GetRelativeServiceDirpath 

func (x *GetServiceInfoResponse) GetRelativeServiceDirpath() string

func (*GetServiceInfoResponse) ProtoMessage 

func (*GetServiceInfoResponse) ProtoMessage()

func (*GetServiceInfoResponse) ProtoReflect 

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

func (*GetServiceInfoResponse) Reset 

func (x *GetServiceInfoResponse) Reset()

func (*GetServiceInfoResponse) String 

func (x *GetServiceInfoResponse) String() string

type GetServicesResponse 

type GetServicesResponse struct {

	// "Set" of current service IDs in the enclave
	ServiceIds map[string]bool `` /* 180-byte string literal not displayed */
	// contains filtered or unexported fields
}

============================================================================================== 

Get Services

==============================================================================================

func (*GetServicesResponse) Descriptor deprecated 

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

Deprecated: Use GetServicesResponse.ProtoReflect.Descriptor instead.

func (*GetServicesResponse) GetServiceIds 

func (x *GetServicesResponse) GetServiceIds() map[string]bool

func (*GetServicesResponse) ProtoMessage 

func (*GetServicesResponse) ProtoMessage()

func (*GetServicesResponse) ProtoReflect 

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

func (*GetServicesResponse) Reset 

func (x *GetServicesResponse) Reset()

func (*GetServicesResponse) String 

func (x *GetServicesResponse) String() string

type LoadModuleArgs 

type LoadModuleArgs struct {
	ModuleId       string `protobuf:"bytes,1,opt,name=module_id,json=moduleId,proto3" json:"module_id,omitempty"`
	ContainerImage string `protobuf:"bytes,2,opt,name=container_image,json=containerImage,proto3" json:"container_image,omitempty"`
	// The serialized params object that will be passed, as-is, to the module for starting
	// The serialization format is dependent on the module
	SerializedParams string `protobuf:"bytes,3,opt,name=serialized_params,json=serializedParams,proto3" json:"serialized_params,omitempty"`
	// contains filtered or unexported fields
}

============================================================================================== 

Load Module

==============================================================================================

func (*LoadModuleArgs) Descriptor deprecated 

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

Deprecated: Use LoadModuleArgs.ProtoReflect.Descriptor instead.

func (*LoadModuleArgs) GetContainerImage 

func (x *LoadModuleArgs) GetContainerImage() string

func (*LoadModuleArgs) GetModuleId 

func (x *LoadModuleArgs) GetModuleId() string

func (*LoadModuleArgs) GetSerializedParams 

func (x *LoadModuleArgs) GetSerializedParams() string

func (*LoadModuleArgs) ProtoMessage 

func (*LoadModuleArgs) ProtoMessage()

func (*LoadModuleArgs) ProtoReflect 

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

func (*LoadModuleArgs) Reset 

func (x *LoadModuleArgs) Reset()

func (*LoadModuleArgs) String 

func (x *LoadModuleArgs) String() string

type PartitionConnectionInfo 

type PartitionConnectionInfo struct {

	// Whether network traffic is allowed between the two partitions
	IsBlocked bool `protobuf:"varint,1,opt,name=is_blocked,json=isBlocked,proto3" json:"is_blocked,omitempty"`
	// contains filtered or unexported fields
}

func (*PartitionConnectionInfo) Descriptor deprecated 

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

Deprecated: Use PartitionConnectionInfo.ProtoReflect.Descriptor instead.

func (*PartitionConnectionInfo) GetIsBlocked 

func (x *PartitionConnectionInfo) GetIsBlocked() bool

func (*PartitionConnectionInfo) ProtoMessage 

func (*PartitionConnectionInfo) ProtoMessage()

func (*PartitionConnectionInfo) ProtoReflect 

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

func (*PartitionConnectionInfo) Reset 

func (x *PartitionConnectionInfo) Reset()

func (*PartitionConnectionInfo) String 

func (x *PartitionConnectionInfo) String() string

type PartitionConnections 

type PartitionConnections struct {
	ConnectionInfo map[string]*PartitionConnectionInfo `` /* 191-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PartitionConnections) Descriptor deprecated 

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

Deprecated: Use PartitionConnections.ProtoReflect.Descriptor instead.

func (*PartitionConnections) GetConnectionInfo 

func (x *PartitionConnections) GetConnectionInfo() map[string]*PartitionConnectionInfo

func (*PartitionConnections) ProtoMessage 

func (*PartitionConnections) ProtoMessage()

func (*PartitionConnections) ProtoReflect 

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

func (*PartitionConnections) Reset 

func (x *PartitionConnections) Reset()

func (*PartitionConnections) String 

func (x *PartitionConnections) String() string

type PartitionServices 

type PartitionServices struct {

	// "Set" of service IDs in partition
	ServiceIdSet map[string]bool `` /* 188-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PartitionServices) Descriptor deprecated 

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

Deprecated: Use PartitionServices.ProtoReflect.Descriptor instead.

func (*PartitionServices) GetServiceIdSet 

func (x *PartitionServices) GetServiceIdSet() map[string]bool

func (*PartitionServices) ProtoMessage 

func (*PartitionServices) ProtoMessage()

func (*PartitionServices) ProtoReflect 

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

func (*PartitionServices) Reset 

func (x *PartitionServices) Reset()

func (*PartitionServices) String 

func (x *PartitionServices) String() string

type PortBinding 

type PortBinding struct {
	InterfaceIp   string `protobuf:"bytes,1,opt,name=interface_ip,json=interfaceIp,proto3" json:"interface_ip,omitempty"`
	InterfacePort string `protobuf:"bytes,2,opt,name=interface_port,json=interfacePort,proto3" json:"interface_port,omitempty"`
	// contains filtered or unexported fields
}

func (*PortBinding) Descriptor deprecated 

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

Deprecated: Use PortBinding.ProtoReflect.Descriptor instead.

func (*PortBinding) GetInterfaceIp 

func (x *PortBinding) GetInterfaceIp() string

func (*PortBinding) GetInterfacePort 

func (x *PortBinding) GetInterfacePort() string

func (*PortBinding) ProtoMessage 

func (*PortBinding) ProtoMessage()

func (*PortBinding) ProtoReflect 

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

func (*PortBinding) Reset 

func (x *PortBinding) Reset()

func (*PortBinding) String 

func (x *PortBinding) String() string

type RegisterFilesArtifactsArgs 

type RegisterFilesArtifactsArgs struct {

	// A mapping of user_defined_id -> url_of_file_artifact
	FilesArtifactUrls map[string]string `` /* 202-byte string literal not displayed */
	// contains filtered or unexported fields
}

============================================================================================== 

Register Files Artifacts

==============================================================================================

func (*RegisterFilesArtifactsArgs) Descriptor deprecated 

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

Deprecated: Use RegisterFilesArtifactsArgs.ProtoReflect.Descriptor instead.

func (*RegisterFilesArtifactsArgs) GetFilesArtifactUrls 

func (x *RegisterFilesArtifactsArgs) GetFilesArtifactUrls() map[string]string

func (*RegisterFilesArtifactsArgs) ProtoMessage 

func (*RegisterFilesArtifactsArgs) ProtoMessage()

func (*RegisterFilesArtifactsArgs) ProtoReflect 

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

func (*RegisterFilesArtifactsArgs) Reset 

func (x *RegisterFilesArtifactsArgs) Reset()

func (*RegisterFilesArtifactsArgs) String 

func (x *RegisterFilesArtifactsArgs) String() string

type RegisterServiceArgs 

type RegisterServiceArgs struct {

	// ID that will be used to identify the service going forward
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// If emptystring, the default partition ID will be used
	PartitionId string `protobuf:"bytes,2,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	// contains filtered or unexported fields
}

============================================================================================== 

Register Service

==============================================================================================

func (*RegisterServiceArgs) Descriptor deprecated 

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

Deprecated: Use RegisterServiceArgs.ProtoReflect.Descriptor instead.

func (*RegisterServiceArgs) GetPartitionId 

func (x *RegisterServiceArgs) GetPartitionId() string

func (*RegisterServiceArgs) GetServiceId 

func (x *RegisterServiceArgs) GetServiceId() string

func (*RegisterServiceArgs) ProtoMessage 

func (*RegisterServiceArgs) ProtoMessage()

func (*RegisterServiceArgs) ProtoReflect 

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

func (*RegisterServiceArgs) Reset 

func (x *RegisterServiceArgs) Reset()

func (*RegisterServiceArgs) String 

func (x *RegisterServiceArgs) String() string

type RegisterServiceResponse 

type RegisterServiceResponse struct {

	// The IP address that the service will receive when it starts
	IpAddr string `protobuf:"bytes,1,opt,name=ip_addr,json=ipAddr,proto3" json:"ip_addr,omitempty"`
	// The dirpath where the service's directory exists inside the enclave data directory, relative to the enclave data dir root
	RelativeServiceDirpath string `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RegisterServiceResponse) Descriptor deprecated 

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

Deprecated: Use RegisterServiceResponse.ProtoReflect.Descriptor instead.

func (*RegisterServiceResponse) GetIpAddr 

func (x *RegisterServiceResponse) GetIpAddr() string

func (*RegisterServiceResponse) GetRelativeServiceDirpath 

func (x *RegisterServiceResponse) GetRelativeServiceDirpath() string

func (*RegisterServiceResponse) ProtoMessage 

func (*RegisterServiceResponse) ProtoMessage()

func (*RegisterServiceResponse) ProtoReflect 

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

func (*RegisterServiceResponse) Reset 

func (x *RegisterServiceResponse) Reset()

func (*RegisterServiceResponse) String 

func (x *RegisterServiceResponse) String() string

type RemoveServiceArgs 

type RemoveServiceArgs struct {
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// How long to wait for the service to gracefully stop before hard killing it
	ContainerStopTimeoutSeconds uint64 `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

============================================================================================== 

Remove Service

==============================================================================================

func (*RemoveServiceArgs) Descriptor deprecated 

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

Deprecated: Use RemoveServiceArgs.ProtoReflect.Descriptor instead.

func (*RemoveServiceArgs) GetContainerStopTimeoutSeconds 

func (x *RemoveServiceArgs) GetContainerStopTimeoutSeconds() uint64

func (*RemoveServiceArgs) GetServiceId 

func (x *RemoveServiceArgs) GetServiceId() string

func (*RemoveServiceArgs) ProtoMessage 

func (*RemoveServiceArgs) ProtoMessage()

func (*RemoveServiceArgs) ProtoReflect 

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

func (*RemoveServiceArgs) Reset 

func (x *RemoveServiceArgs) Reset()

func (*RemoveServiceArgs) String 

func (x *RemoveServiceArgs) String() string

type RepartitionArgs 

type RepartitionArgs struct {

	// Definition of partitionId -> services that should be inside the partition after repartitioning
	PartitionServices map[string]*PartitionServices `` /* 200-byte string literal not displayed */
	// Definition of partitionIdA -> partitionIdB -> information defining the connection between A <-> B
	PartitionConnections map[string]*PartitionConnections `` /* 209-byte string literal not displayed */
	// Information about the default inter-partition connection to set up if one is not defined in the
	//  partition connections map
	DefaultConnection *PartitionConnectionInfo `protobuf:"bytes,3,opt,name=default_connection,json=defaultConnection,proto3" json:"default_connection,omitempty"`
	// contains filtered or unexported fields
}

============================================================================================== 

Repartition

==============================================================================================

func (*RepartitionArgs) Descriptor deprecated 

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

Deprecated: Use RepartitionArgs.ProtoReflect.Descriptor instead.

func (*RepartitionArgs) GetDefaultConnection 

func (x *RepartitionArgs) GetDefaultConnection() *PartitionConnectionInfo

func (*RepartitionArgs) GetPartitionConnections 

func (x *RepartitionArgs) GetPartitionConnections() map[string]*PartitionConnections

func (*RepartitionArgs) GetPartitionServices 

func (x *RepartitionArgs) GetPartitionServices() map[string]*PartitionServices

func (*RepartitionArgs) ProtoMessage 

func (*RepartitionArgs) ProtoMessage()

func (*RepartitionArgs) ProtoReflect 

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

func (*RepartitionArgs) Reset 

func (x *RepartitionArgs) Reset()

func (*RepartitionArgs) String 

func (x *RepartitionArgs) String() string

type StartExternalContainerRegistrationResponse 

type StartExternalContainerRegistrationResponse struct {

	// A key that should be passed to the call to finish external container registration
	RegistrationKey string `protobuf:"bytes,1,opt,name=registration_key,json=registrationKey,proto3" json:"registration_key,omitempty"`
	// The IP address that the API container has set aside for the container-to-be-registered
	IpAddr string `protobuf:"bytes,2,opt,name=ip_addr,json=ipAddr,proto3" json:"ip_addr,omitempty"`
	// contains filtered or unexported fields
}

============================================================================================== 

Start External Container Registration

==============================================================================================

func (*StartExternalContainerRegistrationResponse) Descriptor deprecated 

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

Deprecated: Use StartExternalContainerRegistrationResponse.ProtoReflect.Descriptor instead.

func (*StartExternalContainerRegistrationResponse) GetIpAddr 

func (x *StartExternalContainerRegistrationResponse) GetIpAddr() string

func (*StartExternalContainerRegistrationResponse) GetRegistrationKey 

func (x *StartExternalContainerRegistrationResponse) GetRegistrationKey() string

func (*StartExternalContainerRegistrationResponse) ProtoMessage 

func (*StartExternalContainerRegistrationResponse) ProtoMessage()

func (*StartExternalContainerRegistrationResponse) ProtoReflect 

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

func (*StartExternalContainerRegistrationResponse) Reset 

func (x *StartExternalContainerRegistrationResponse) Reset()

func (*StartExternalContainerRegistrationResponse) String 

func (x *StartExternalContainerRegistrationResponse) String() string

type StartServiceArgs 

type StartServiceArgs struct {

	// ID of the previously-registered service that should be started
	ServiceId   string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	DockerImage string `protobuf:"bytes,2,opt,name=docker_image,json=dockerImage,proto3" json:"docker_image,omitempty"`
	// "Set" of ports that the running service will listen on
	// This is a string because it's Docker port specification syntax, e.g. "80" (default TCP) or "80/udp"
	UsedPorts map[string]bool `` /* 177-byte string literal not displayed */
	// Corresponds to a Dockerfile's ENTRYPOINT directive; leave blank to do no overriding
	EntrypointArgs []string `protobuf:"bytes,4,rep,name=entrypoint_args,json=entrypointArgs,proto3" json:"entrypoint_args,omitempty"`
	// Corresponds to a Dockerfile's CMD directive; leave blank to do no overriding
	CmdArgs []string `protobuf:"bytes,5,rep,name=cmd_args,json=cmdArgs,proto3" json:"cmd_args,omitempty"`
	// Docker environment variables that should be set in the service's container
	DockerEnvVars map[string]string `` /* 190-byte string literal not displayed */
	// The full path where the API container should mount the enclave data directory on the service container
	EnclaveDataDirMntDirpath string `` /* 139-byte string literal not displayed */
	// Mapping of files_artifact_id -> filepath_on_container_to_mount_artifact_contents
	FilesArtifactMountDirpaths map[string]string `` /* 231-byte string literal not displayed */
	// contains filtered or unexported fields
}

============================================================================================== 

Start Service

==============================================================================================

func (*StartServiceArgs) Descriptor deprecated 

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

Deprecated: Use StartServiceArgs.ProtoReflect.Descriptor instead.

func (*StartServiceArgs) GetCmdArgs 

func (x *StartServiceArgs) GetCmdArgs() []string

func (*StartServiceArgs) GetDockerEnvVars 

func (x *StartServiceArgs) GetDockerEnvVars() map[string]string

func (*StartServiceArgs) GetDockerImage 

func (x *StartServiceArgs) GetDockerImage() string

func (*StartServiceArgs) GetEnclaveDataDirMntDirpath 

func (x *StartServiceArgs) GetEnclaveDataDirMntDirpath() string

func (*StartServiceArgs) GetEntrypointArgs 

func (x *StartServiceArgs) GetEntrypointArgs() []string

func (*StartServiceArgs) GetFilesArtifactMountDirpaths 

func (x *StartServiceArgs) GetFilesArtifactMountDirpaths() map[string]string

func (*StartServiceArgs) GetServiceId 

func (x *StartServiceArgs) GetServiceId() string

func (*StartServiceArgs) GetUsedPorts 

func (x *StartServiceArgs) GetUsedPorts() map[string]bool

func (*StartServiceArgs) ProtoMessage 

func (*StartServiceArgs) ProtoMessage()

func (*StartServiceArgs) ProtoReflect 

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

func (*StartServiceArgs) Reset 

func (x *StartServiceArgs) Reset()

func (*StartServiceArgs) String 

func (x *StartServiceArgs) String() string

type StartServiceResponse 

type StartServiceResponse struct {

	// Mapping of used_ports_provided_in_input_args -> ip_and_port_on_host_where_port_is_bound (in ip:port form)
	// Ports will only be in this map if they were successfully bound to a host port; if no ports were bound, then
	// this map will be empty
	UsedPortsHostPortBindings map[string]*PortBinding `` /* 230-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StartServiceResponse) Descriptor deprecated 

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

Deprecated: Use StartServiceResponse.ProtoReflect.Descriptor instead.

func (*StartServiceResponse) GetUsedPortsHostPortBindings 

func (x *StartServiceResponse) GetUsedPortsHostPortBindings() map[string]*PortBinding

func (*StartServiceResponse) ProtoMessage 

func (*StartServiceResponse) ProtoMessage()

func (*StartServiceResponse) ProtoReflect 

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

func (*StartServiceResponse) Reset 

func (x *StartServiceResponse) Reset()

func (*StartServiceResponse) String 

func (x *StartServiceResponse) String() string

type UnimplementedApiContainerServiceServer 

type UnimplementedApiContainerServiceServer struct {
}

UnimplementedApiContainerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedApiContainerServiceServer) ExecCommand 

func (UnimplementedApiContainerServiceServer) ExecCommand(context.Context, *ExecCommandArgs) (*ExecCommandResponse, error)

func (UnimplementedApiContainerServiceServer) ExecuteBulkCommands 

func (UnimplementedApiContainerServiceServer) ExecuteBulkCommands(context.Context, *ExecuteBulkCommandsArgs) (*emptypb.Empty, error)

func (UnimplementedApiContainerServiceServer) ExecuteModule 

func (UnimplementedApiContainerServiceServer) ExecuteModule(context.Context, *ExecuteModuleArgs) (*ExecuteModuleResponse, error)

func (UnimplementedApiContainerServiceServer) FinishExternalContainerRegistration 

func (UnimplementedApiContainerServiceServer) FinishExternalContainerRegistration(context.Context, *FinishExternalContainerRegistrationArgs) (*emptypb.Empty, error)

func (UnimplementedApiContainerServiceServer) GetModuleInfo 

func (UnimplementedApiContainerServiceServer) GetModuleInfo(context.Context, *GetModuleInfoArgs) (*GetModuleInfoResponse, error)

func (UnimplementedApiContainerServiceServer) GetModules 

func (UnimplementedApiContainerServiceServer) GetModules(context.Context, *emptypb.Empty) (*GetModulesResponse, error)

func (UnimplementedApiContainerServiceServer) GetServiceInfo 

func (UnimplementedApiContainerServiceServer) GetServiceInfo(context.Context, *GetServiceInfoArgs) (*GetServiceInfoResponse, error)

func (UnimplementedApiContainerServiceServer) GetServices 

func (UnimplementedApiContainerServiceServer) GetServices(context.Context, *emptypb.Empty) (*GetServicesResponse, error)

func (UnimplementedApiContainerServiceServer) LoadModule 

func (UnimplementedApiContainerServiceServer) LoadModule(context.Context, *LoadModuleArgs) (*emptypb.Empty, error)

func (UnimplementedApiContainerServiceServer) RegisterFilesArtifacts 

func (UnimplementedApiContainerServiceServer) RegisterFilesArtifacts(context.Context, *RegisterFilesArtifactsArgs) (*emptypb.Empty, error)

func (UnimplementedApiContainerServiceServer) RegisterService 

func (UnimplementedApiContainerServiceServer) RegisterService(context.Context, *RegisterServiceArgs) (*RegisterServiceResponse, error)

func (UnimplementedApiContainerServiceServer) RemoveService 

func (UnimplementedApiContainerServiceServer) RemoveService(context.Context, *RemoveServiceArgs) (*emptypb.Empty, error)

func (UnimplementedApiContainerServiceServer) Repartition 

func (UnimplementedApiContainerServiceServer) Repartition(context.Context, *RepartitionArgs) (*emptypb.Empty, error)

func (UnimplementedApiContainerServiceServer) StartExternalContainerRegistration 

func (UnimplementedApiContainerServiceServer) StartExternalContainerRegistration(context.Context, *emptypb.Empty) (*StartExternalContainerRegistrationResponse, error)

func (UnimplementedApiContainerServiceServer) StartService 

func (UnimplementedApiContainerServiceServer) StartService(context.Context, *StartServiceArgs) (*StartServiceResponse, error)

func (UnimplementedApiContainerServiceServer) UnloadModule 

func (UnimplementedApiContainerServiceServer) UnloadModule(context.Context, *UnloadModuleArgs) (*emptypb.Empty, error)

func (UnimplementedApiContainerServiceServer) WaitForHttpGetEndpointAvailability 

func (UnimplementedApiContainerServiceServer) WaitForHttpGetEndpointAvailability(context.Context, *WaitForHttpGetEndpointAvailabilityArgs) (*emptypb.Empty, error)

func (UnimplementedApiContainerServiceServer) WaitForHttpPostEndpointAvailability 

func (UnimplementedApiContainerServiceServer) WaitForHttpPostEndpointAvailability(context.Context, *WaitForHttpPostEndpointAvailabilityArgs) (*emptypb.Empty, error)

type UnloadModuleArgs 

type UnloadModuleArgs struct {
	ModuleId string `protobuf:"bytes,1,opt,name=module_id,json=moduleId,proto3" json:"module_id,omitempty"`
	// contains filtered or unexported fields
}

============================================================================================== 

Unload Module

==============================================================================================

func (*UnloadModuleArgs) Descriptor deprecated 

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

Deprecated: Use UnloadModuleArgs.ProtoReflect.Descriptor instead.

func (*UnloadModuleArgs) GetModuleId 

func (x *UnloadModuleArgs) GetModuleId() string

func (*UnloadModuleArgs) ProtoMessage 

func (*UnloadModuleArgs) ProtoMessage()

func (*UnloadModuleArgs) ProtoReflect 

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

func (*UnloadModuleArgs) Reset 

func (x *UnloadModuleArgs) Reset()

func (*UnloadModuleArgs) String 

func (x *UnloadModuleArgs) String() string

type UnsafeApiContainerServiceServer 

type UnsafeApiContainerServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeApiContainerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ApiContainerServiceServer will result in compilation errors.

type WaitForHttpGetEndpointAvailabilityArgs 

type WaitForHttpGetEndpointAvailabilityArgs struct {

	//The ID of the service to check.
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	//The port of the service to check. For instance 8080
	Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	//The path of the service to check. It mustn't start with the first slash. For instance `service/health`
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	//The number of milliseconds to wait until executing the first HTTP call
	InitialDelayMilliseconds uint32 `` /* 136-byte string literal not displayed */
	//Max number of HTTP call attempts that this will execute until giving up and returning an error
	Retries uint32 `protobuf:"varint,5,opt,name=retries,proto3" json:"retries,omitempty"`
	//Number of milliseconds to wait between retries
	RetriesDelayMilliseconds uint32 `` /* 136-byte string literal not displayed */
	//If the endpoint returns this value, the service will be marked as available (e.g. Hello World).
	BodyText string `protobuf:"bytes,7,opt,name=body_text,json=bodyText,proto3" json:"body_text,omitempty"`
	// contains filtered or unexported fields
}

============================================================================================== 

Wait For HTTP Get Endpoint Availability

==============================================================================================

func (*WaitForHttpGetEndpointAvailabilityArgs) Descriptor deprecated 

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

Deprecated: Use WaitForHttpGetEndpointAvailabilityArgs.ProtoReflect.Descriptor instead.

func (*WaitForHttpGetEndpointAvailabilityArgs) GetBodyText 

func (x *WaitForHttpGetEndpointAvailabilityArgs) GetBodyText() string

func (*WaitForHttpGetEndpointAvailabilityArgs) GetInitialDelayMilliseconds 

func (x *WaitForHttpGetEndpointAvailabilityArgs) GetInitialDelayMilliseconds() uint32

func (*WaitForHttpGetEndpointAvailabilityArgs) GetPath 

func (x *WaitForHttpGetEndpointAvailabilityArgs) GetPath() string

func (*WaitForHttpGetEndpointAvailabilityArgs) GetPort 

func (x *WaitForHttpGetEndpointAvailabilityArgs) GetPort() uint32

func (*WaitForHttpGetEndpointAvailabilityArgs) GetRetries 

func (x *WaitForHttpGetEndpointAvailabilityArgs) GetRetries() uint32

func (*WaitForHttpGetEndpointAvailabilityArgs) GetRetriesDelayMilliseconds 

func (x *WaitForHttpGetEndpointAvailabilityArgs) GetRetriesDelayMilliseconds() uint32

func (*WaitForHttpGetEndpointAvailabilityArgs) GetServiceId 

func (x *WaitForHttpGetEndpointAvailabilityArgs) GetServiceId() string

func (*WaitForHttpGetEndpointAvailabilityArgs) ProtoMessage 

func (*WaitForHttpGetEndpointAvailabilityArgs) ProtoMessage()

func (*WaitForHttpGetEndpointAvailabilityArgs) ProtoReflect 

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

func (*WaitForHttpGetEndpointAvailabilityArgs) Reset 

func (x *WaitForHttpGetEndpointAvailabilityArgs) Reset()

func (*WaitForHttpGetEndpointAvailabilityArgs) String 

func (x *WaitForHttpGetEndpointAvailabilityArgs) String() string

type WaitForHttpPostEndpointAvailabilityArgs 

type WaitForHttpPostEndpointAvailabilityArgs struct {

	//The ID of the service to check.
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	//The port of the service to check. For instance 8080
	Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	//The path of the service to check. It mustn't start with the first slash. For instance `service/health`
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	//The content of the request body.
	RequestBody string `protobuf:"bytes,4,opt,name=request_body,json=requestBody,proto3" json:"request_body,omitempty"`
	//The number of milliseconds to wait until executing the first HTTP call
	InitialDelayMilliseconds uint32 `` /* 136-byte string literal not displayed */
	//Max number of HTTP call attempts that this will execute until giving up and returning an error
	Retries uint32 `protobuf:"varint,6,opt,name=retries,proto3" json:"retries,omitempty"`
	//Number of milliseconds to wait between retries
	RetriesDelayMilliseconds uint32 `` /* 136-byte string literal not displayed */
	//If the endpoint returns this value, the service will be marked as available (e.g. Hello World).
	BodyText string `protobuf:"bytes,8,opt,name=body_text,json=bodyText,proto3" json:"body_text,omitempty"`
	// contains filtered or unexported fields
}

============================================================================================== 

Wait For HTTP Post Endpoint Availability

==============================================================================================

func (*WaitForHttpPostEndpointAvailabilityArgs) Descriptor deprecated 

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

Deprecated: Use WaitForHttpPostEndpointAvailabilityArgs.ProtoReflect.Descriptor instead.

func (*WaitForHttpPostEndpointAvailabilityArgs) GetBodyText 

func (x *WaitForHttpPostEndpointAvailabilityArgs) GetBodyText() string

func (*WaitForHttpPostEndpointAvailabilityArgs) GetInitialDelayMilliseconds 

func (x *WaitForHttpPostEndpointAvailabilityArgs) GetInitialDelayMilliseconds() uint32

func (*WaitForHttpPostEndpointAvailabilityArgs) GetPath 

func (x *WaitForHttpPostEndpointAvailabilityArgs) GetPath() string

func (*WaitForHttpPostEndpointAvailabilityArgs) GetPort 

func (x *WaitForHttpPostEndpointAvailabilityArgs) GetPort() uint32

func (*WaitForHttpPostEndpointAvailabilityArgs) GetRequestBody 

func (x *WaitForHttpPostEndpointAvailabilityArgs) GetRequestBody() string

func (*WaitForHttpPostEndpointAvailabilityArgs) GetRetries 

func (x *WaitForHttpPostEndpointAvailabilityArgs) GetRetries() uint32

func (*WaitForHttpPostEndpointAvailabilityArgs) GetRetriesDelayMilliseconds 

func (x *WaitForHttpPostEndpointAvailabilityArgs) GetRetriesDelayMilliseconds() uint32

func (*WaitForHttpPostEndpointAvailabilityArgs) GetServiceId 

func (x *WaitForHttpPostEndpointAvailabilityArgs) GetServiceId() string

func (*WaitForHttpPostEndpointAvailabilityArgs) ProtoMessage 

func (*WaitForHttpPostEndpointAvailabilityArgs) ProtoMessage()

func (*WaitForHttpPostEndpointAvailabilityArgs) ProtoReflect 

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

func (*WaitForHttpPostEndpointAvailabilityArgs) Reset 

func (x *WaitForHttpPostEndpointAvailabilityArgs) Reset()

func (*WaitForHttpPostEndpointAvailabilityArgs) String 

func (x *WaitForHttpPostEndpointAvailabilityArgs) String() string

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.