pb

package
v0.12.0 Latest Latest
Warning

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

Go to latest
Published: Aug 28, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Cluster_AddMachine_FullMethodName          = "/api.Cluster/AddMachine"
	Cluster_ListMachines_FullMethodName        = "/api.Cluster/ListMachines"
	Cluster_UpdateMachine_FullMethodName       = "/api.Cluster/UpdateMachine"
	Cluster_RemoveMachine_FullMethodName       = "/api.Cluster/RemoveMachine"
	Cluster_ReserveDomain_FullMethodName       = "/api.Cluster/ReserveDomain"
	Cluster_GetDomain_FullMethodName           = "/api.Cluster/GetDomain"
	Cluster_ReleaseDomain_FullMethodName       = "/api.Cluster/ReleaseDomain"
	Cluster_CreateDomainRecords_FullMethodName = "/api.Cluster/CreateDomainRecords"
)
View Source
const (
	Docker_CreateContainer_FullMethodName         = "/api.Docker/CreateContainer"
	Docker_InspectContainer_FullMethodName        = "/api.Docker/InspectContainer"
	Docker_StartContainer_FullMethodName          = "/api.Docker/StartContainer"
	Docker_StopContainer_FullMethodName           = "/api.Docker/StopContainer"
	Docker_ListContainers_FullMethodName          = "/api.Docker/ListContainers"
	Docker_RemoveContainer_FullMethodName         = "/api.Docker/RemoveContainer"
	Docker_PullImage_FullMethodName               = "/api.Docker/PullImage"
	Docker_InspectImage_FullMethodName            = "/api.Docker/InspectImage"
	Docker_InspectRemoteImage_FullMethodName      = "/api.Docker/InspectRemoteImage"
	Docker_CreateVolume_FullMethodName            = "/api.Docker/CreateVolume"
	Docker_ListVolumes_FullMethodName             = "/api.Docker/ListVolumes"
	Docker_RemoveVolume_FullMethodName            = "/api.Docker/RemoveVolume"
	Docker_CreateServiceContainer_FullMethodName  = "/api.Docker/CreateServiceContainer"
	Docker_InspectServiceContainer_FullMethodName = "/api.Docker/InspectServiceContainer"
	Docker_ListServiceContainers_FullMethodName   = "/api.Docker/ListServiceContainers"
	Docker_RemoveServiceContainer_FullMethodName  = "/api.Docker/RemoveServiceContainer"
)
View Source
const (
	Machine_CheckPrerequisites_FullMethodName = "/api.Machine/CheckPrerequisites"
	Machine_InitCluster_FullMethodName        = "/api.Machine/InitCluster"
	Machine_JoinCluster_FullMethodName        = "/api.Machine/JoinCluster"
	Machine_Token_FullMethodName              = "/api.Machine/Token"
	Machine_Inspect_FullMethodName            = "/api.Machine/Inspect"
	Machine_Reset_FullMethodName              = "/api.Machine/Reset"
	Machine_InspectService_FullMethodName     = "/api.Machine/InspectService"
)
View Source
const (
	Caddy_GetConfig_FullMethodName = "/api.Caddy/GetConfig"
)
View Source
const KeyLen = 32

KeyLen is the expected key length for a WireGuard public or private key.

Variables

View Source
var (
	MachineMember_MembershipState_name = map[int32]string{
		0: "UNKNOWN",
		1: "UP",
		2: "SUSPECT",
		3: "DOWN",
	}
	MachineMember_MembershipState_value = map[string]int32{
		"UNKNOWN": 0,
		"UP":      1,
		"SUSPECT": 2,
		"DOWN":    3,
	}
)

Enum value maps for MachineMember_MembershipState.

View Source
var (
	DNSRecord_RecordType_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "A",
		2: "AAAA",
	}
	DNSRecord_RecordType_value = map[string]int32{
		"UNSPECIFIED": 0,
		"A":           1,
		"AAAA":        2,
	}
)

Enum value maps for DNSRecord_RecordType.

View Source
var Caddy_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.Caddy",
	HandlerType: (*CaddyServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetConfig",
			Handler:    _Caddy_GetConfig_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/machine/api/pb/caddy.proto",
}

Caddy_ServiceDesc is the grpc.ServiceDesc for Caddy 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 Cluster_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.Cluster",
	HandlerType: (*ClusterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddMachine",
			Handler:    _Cluster_AddMachine_Handler,
		},
		{
			MethodName: "ListMachines",
			Handler:    _Cluster_ListMachines_Handler,
		},
		{
			MethodName: "UpdateMachine",
			Handler:    _Cluster_UpdateMachine_Handler,
		},
		{
			MethodName: "RemoveMachine",
			Handler:    _Cluster_RemoveMachine_Handler,
		},
		{
			MethodName: "ReserveDomain",
			Handler:    _Cluster_ReserveDomain_Handler,
		},
		{
			MethodName: "GetDomain",
			Handler:    _Cluster_GetDomain_Handler,
		},
		{
			MethodName: "ReleaseDomain",
			Handler:    _Cluster_ReleaseDomain_Handler,
		},
		{
			MethodName: "CreateDomainRecords",
			Handler:    _Cluster_CreateDomainRecords_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/machine/api/pb/cluster.proto",
}

Cluster_ServiceDesc is the grpc.ServiceDesc for Cluster 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 Docker_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.Docker",
	HandlerType: (*DockerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateContainer",
			Handler:    _Docker_CreateContainer_Handler,
		},
		{
			MethodName: "InspectContainer",
			Handler:    _Docker_InspectContainer_Handler,
		},
		{
			MethodName: "StartContainer",
			Handler:    _Docker_StartContainer_Handler,
		},
		{
			MethodName: "StopContainer",
			Handler:    _Docker_StopContainer_Handler,
		},
		{
			MethodName: "ListContainers",
			Handler:    _Docker_ListContainers_Handler,
		},
		{
			MethodName: "RemoveContainer",
			Handler:    _Docker_RemoveContainer_Handler,
		},
		{
			MethodName: "InspectImage",
			Handler:    _Docker_InspectImage_Handler,
		},
		{
			MethodName: "InspectRemoteImage",
			Handler:    _Docker_InspectRemoteImage_Handler,
		},
		{
			MethodName: "CreateVolume",
			Handler:    _Docker_CreateVolume_Handler,
		},
		{
			MethodName: "ListVolumes",
			Handler:    _Docker_ListVolumes_Handler,
		},
		{
			MethodName: "RemoveVolume",
			Handler:    _Docker_RemoveVolume_Handler,
		},
		{
			MethodName: "CreateServiceContainer",
			Handler:    _Docker_CreateServiceContainer_Handler,
		},
		{
			MethodName: "InspectServiceContainer",
			Handler:    _Docker_InspectServiceContainer_Handler,
		},
		{
			MethodName: "ListServiceContainers",
			Handler:    _Docker_ListServiceContainers_Handler,
		},
		{
			MethodName: "RemoveServiceContainer",
			Handler:    _Docker_RemoveServiceContainer_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PullImage",
			Handler:       _Docker_PullImage_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "internal/machine/api/pb/docker.proto",
}

Docker_ServiceDesc is the grpc.ServiceDesc for Docker 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_internal_machine_api_pb_caddy_proto protoreflect.FileDescriptor
View Source
var File_internal_machine_api_pb_cluster_proto protoreflect.FileDescriptor
View Source
var File_internal_machine_api_pb_common_proto protoreflect.FileDescriptor
View Source
var File_internal_machine_api_pb_docker_proto protoreflect.FileDescriptor
View Source
var File_internal_machine_api_pb_machine_proto protoreflect.FileDescriptor
View Source
var Machine_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.Machine",
	HandlerType: (*MachineServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CheckPrerequisites",
			Handler:    _Machine_CheckPrerequisites_Handler,
		},
		{
			MethodName: "InitCluster",
			Handler:    _Machine_InitCluster_Handler,
		},
		{
			MethodName: "JoinCluster",
			Handler:    _Machine_JoinCluster_Handler,
		},
		{
			MethodName: "Token",
			Handler:    _Machine_Token_Handler,
		},
		{
			MethodName: "Inspect",
			Handler:    _Machine_Inspect_Handler,
		},
		{
			MethodName: "Reset",
			Handler:    _Machine_Reset_Handler,
		},
		{
			MethodName: "InspectService",
			Handler:    _Machine_InspectService_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/machine/api/pb/machine.proto",
}

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

Functions

func RegisterCaddyServer added in v0.12.0

func RegisterCaddyServer(s grpc.ServiceRegistrar, srv CaddyServer)

func RegisterClusterServer

func RegisterClusterServer(s grpc.ServiceRegistrar, srv ClusterServer)

func RegisterDockerServer

func RegisterDockerServer(s grpc.ServiceRegistrar, srv DockerServer)

func RegisterMachineServer

func RegisterMachineServer(s grpc.ServiceRegistrar, srv MachineServer)

Types

type AddMachineRequest

type AddMachineRequest struct {
	Name     string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Network  *NetworkConfig `protobuf:"bytes,2,opt,name=network,proto3" json:"network,omitempty"`
	PublicIp *IP            `protobuf:"bytes,3,opt,name=public_ip,json=publicIp,proto3" json:"public_ip,omitempty"`
	// contains filtered or unexported fields
}

func (*AddMachineRequest) Descriptor deprecated

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

Deprecated: Use AddMachineRequest.ProtoReflect.Descriptor instead.

func (*AddMachineRequest) GetName

func (x *AddMachineRequest) GetName() string

func (*AddMachineRequest) GetNetwork

func (x *AddMachineRequest) GetNetwork() *NetworkConfig

func (*AddMachineRequest) GetPublicIp

func (x *AddMachineRequest) GetPublicIp() *IP

func (*AddMachineRequest) ProtoMessage

func (*AddMachineRequest) ProtoMessage()

func (*AddMachineRequest) ProtoReflect

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

func (*AddMachineRequest) Reset

func (x *AddMachineRequest) Reset()

func (*AddMachineRequest) String

func (x *AddMachineRequest) String() string

type AddMachineResponse

type AddMachineResponse struct {
	Machine *MachineInfo `protobuf:"bytes,1,opt,name=machine,proto3" json:"machine,omitempty"`
	// contains filtered or unexported fields
}

func (*AddMachineResponse) Descriptor deprecated

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

Deprecated: Use AddMachineResponse.ProtoReflect.Descriptor instead.

func (*AddMachineResponse) GetMachine

func (x *AddMachineResponse) GetMachine() *MachineInfo

func (*AddMachineResponse) ProtoMessage

func (*AddMachineResponse) ProtoMessage()

func (*AddMachineResponse) ProtoReflect

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

func (*AddMachineResponse) Reset

func (x *AddMachineResponse) Reset()

func (*AddMachineResponse) String

func (x *AddMachineResponse) String() string

type CaddyClient added in v0.12.0

type CaddyClient interface {
	// GetConfig retrieves the current Caddy configuration from the machine.
	GetConfig(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetCaddyConfigResponse, error)
}

CaddyClient is the client API for Caddy 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 NewCaddyClient added in v0.12.0

func NewCaddyClient(cc grpc.ClientConnInterface) CaddyClient

type CaddyServer added in v0.12.0

type CaddyServer interface {
	// GetConfig retrieves the current Caddy configuration from the machine.
	GetConfig(context.Context, *emptypb.Empty) (*GetCaddyConfigResponse, error)
	// contains filtered or unexported methods
}

CaddyServer is the server API for Caddy service. All implementations must embed UnimplementedCaddyServer for forward compatibility.

type CheckPrerequisitesResponse added in v0.7.0

type CheckPrerequisitesResponse struct {

	// Overall status of the checks.
	Satisfied bool `protobuf:"varint,1,opt,name=satisfied,proto3" json:"satisfied,omitempty"`
	// Error message if not satisfied (empty if all checks pass).
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckPrerequisitesResponse) Descriptor deprecated added in v0.7.0

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

Deprecated: Use CheckPrerequisitesResponse.ProtoReflect.Descriptor instead.

func (*CheckPrerequisitesResponse) GetError added in v0.7.0

func (x *CheckPrerequisitesResponse) GetError() string

func (*CheckPrerequisitesResponse) GetSatisfied added in v0.7.0

func (x *CheckPrerequisitesResponse) GetSatisfied() bool

func (*CheckPrerequisitesResponse) ProtoMessage added in v0.7.0

func (*CheckPrerequisitesResponse) ProtoMessage()

func (*CheckPrerequisitesResponse) ProtoReflect added in v0.7.0

func (*CheckPrerequisitesResponse) Reset added in v0.7.0

func (x *CheckPrerequisitesResponse) Reset()

func (*CheckPrerequisitesResponse) String added in v0.7.0

func (x *CheckPrerequisitesResponse) String() string

type ClusterClient

type ClusterClient interface {
	AddMachine(ctx context.Context, in *AddMachineRequest, opts ...grpc.CallOption) (*AddMachineResponse, error)
	ListMachines(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListMachinesResponse, error)
	UpdateMachine(ctx context.Context, in *UpdateMachineRequest, opts ...grpc.CallOption) (*UpdateMachineResponse, error)
	RemoveMachine(ctx context.Context, in *RemoveMachineRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReserveDomain(ctx context.Context, in *ReserveDomainRequest, opts ...grpc.CallOption) (*Domain, error)
	GetDomain(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Domain, error)
	ReleaseDomain(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Domain, error)
	CreateDomainRecords(ctx context.Context, in *CreateDomainRecordsRequest, opts ...grpc.CallOption) (*CreateDomainRecordsResponse, error)
}

ClusterClient is the client API for Cluster 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 NewClusterClient

func NewClusterClient(cc grpc.ClientConnInterface) ClusterClient

type ClusterServer

type ClusterServer interface {
	AddMachine(context.Context, *AddMachineRequest) (*AddMachineResponse, error)
	ListMachines(context.Context, *emptypb.Empty) (*ListMachinesResponse, error)
	UpdateMachine(context.Context, *UpdateMachineRequest) (*UpdateMachineResponse, error)
	RemoveMachine(context.Context, *RemoveMachineRequest) (*emptypb.Empty, error)
	ReserveDomain(context.Context, *ReserveDomainRequest) (*Domain, error)
	GetDomain(context.Context, *emptypb.Empty) (*Domain, error)
	ReleaseDomain(context.Context, *emptypb.Empty) (*Domain, error)
	CreateDomainRecords(context.Context, *CreateDomainRecordsRequest) (*CreateDomainRecordsResponse, error)
	// contains filtered or unexported methods
}

ClusterServer is the server API for Cluster service. All implementations must embed UnimplementedClusterServer for forward compatibility.

type CreateContainerRequest

type CreateContainerRequest struct {

	// JSON serialised container.Config.
	Config []byte `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// JSON serialised container.HostConfig.
	HostConfig []byte `protobuf:"bytes,2,opt,name=host_config,json=hostConfig,proto3" json:"host_config,omitempty"`
	// JSON serialised network.NetworkingConfig.
	NetworkConfig []byte `protobuf:"bytes,3,opt,name=network_config,json=networkConfig,proto3" json:"network_config,omitempty"`
	// JSON serialised ocispec.Platform.
	Platform []byte `protobuf:"bytes,4,opt,name=platform,proto3" json:"platform,omitempty"`
	Name     string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateContainerRequest) Descriptor deprecated

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

Deprecated: Use CreateContainerRequest.ProtoReflect.Descriptor instead.

func (*CreateContainerRequest) GetConfig

func (x *CreateContainerRequest) GetConfig() []byte

func (*CreateContainerRequest) GetHostConfig

func (x *CreateContainerRequest) GetHostConfig() []byte

func (*CreateContainerRequest) GetName

func (x *CreateContainerRequest) GetName() string

func (*CreateContainerRequest) GetNetworkConfig

func (x *CreateContainerRequest) GetNetworkConfig() []byte

func (*CreateContainerRequest) GetPlatform

func (x *CreateContainerRequest) GetPlatform() []byte

func (*CreateContainerRequest) ProtoMessage

func (*CreateContainerRequest) ProtoMessage()

func (*CreateContainerRequest) ProtoReflect

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

func (*CreateContainerRequest) Reset

func (x *CreateContainerRequest) Reset()

func (*CreateContainerRequest) String

func (x *CreateContainerRequest) String() string

type CreateContainerResponse

type CreateContainerResponse struct {

	// JSON serialised container.CreateResponse.
	Response []byte `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateContainerResponse) Descriptor deprecated

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

Deprecated: Use CreateContainerResponse.ProtoReflect.Descriptor instead.

func (*CreateContainerResponse) GetResponse

func (x *CreateContainerResponse) GetResponse() []byte

func (*CreateContainerResponse) ProtoMessage

func (*CreateContainerResponse) ProtoMessage()

func (*CreateContainerResponse) ProtoReflect

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

func (*CreateContainerResponse) Reset

func (x *CreateContainerResponse) Reset()

func (*CreateContainerResponse) String

func (x *CreateContainerResponse) String() string

type CreateDomainRecordsRequest

type CreateDomainRecordsRequest struct {
	Records []*DNSRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDomainRecordsRequest) Descriptor deprecated

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

Deprecated: Use CreateDomainRecordsRequest.ProtoReflect.Descriptor instead.

func (*CreateDomainRecordsRequest) GetRecords

func (x *CreateDomainRecordsRequest) GetRecords() []*DNSRecord

func (*CreateDomainRecordsRequest) ProtoMessage

func (*CreateDomainRecordsRequest) ProtoMessage()

func (*CreateDomainRecordsRequest) ProtoReflect

func (*CreateDomainRecordsRequest) Reset

func (x *CreateDomainRecordsRequest) Reset()

func (*CreateDomainRecordsRequest) String

func (x *CreateDomainRecordsRequest) String() string

type CreateDomainRecordsResponse

type CreateDomainRecordsResponse struct {
	Records []*DNSRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDomainRecordsResponse) Descriptor deprecated

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

Deprecated: Use CreateDomainRecordsResponse.ProtoReflect.Descriptor instead.

func (*CreateDomainRecordsResponse) GetRecords

func (x *CreateDomainRecordsResponse) GetRecords() []*DNSRecord

func (*CreateDomainRecordsResponse) ProtoMessage

func (*CreateDomainRecordsResponse) ProtoMessage()

func (*CreateDomainRecordsResponse) ProtoReflect

func (*CreateDomainRecordsResponse) Reset

func (x *CreateDomainRecordsResponse) Reset()

func (*CreateDomainRecordsResponse) String

func (x *CreateDomainRecordsResponse) String() string

type CreateServiceContainerRequest

type CreateServiceContainerRequest struct {
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// JSON serialised api.ServiceSpec.
	ServiceSpec   []byte `protobuf:"bytes,2,opt,name=service_spec,json=serviceSpec,proto3" json:"service_spec,omitempty"`
	ContainerName string `protobuf:"bytes,3,opt,name=container_name,json=containerName,proto3" json:"container_name,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateServiceContainerRequest) Descriptor deprecated

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

Deprecated: Use CreateServiceContainerRequest.ProtoReflect.Descriptor instead.

func (*CreateServiceContainerRequest) GetContainerName

func (x *CreateServiceContainerRequest) GetContainerName() string

func (*CreateServiceContainerRequest) GetServiceId

func (x *CreateServiceContainerRequest) GetServiceId() string

func (*CreateServiceContainerRequest) GetServiceSpec

func (x *CreateServiceContainerRequest) GetServiceSpec() []byte

func (*CreateServiceContainerRequest) ProtoMessage

func (*CreateServiceContainerRequest) ProtoMessage()

func (*CreateServiceContainerRequest) ProtoReflect

func (*CreateServiceContainerRequest) Reset

func (x *CreateServiceContainerRequest) Reset()

func (*CreateServiceContainerRequest) String

type CreateVolumeRequest added in v0.6.0

type CreateVolumeRequest struct {

	// JSON serialised volume.CreateOptions.
	Options []byte `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateVolumeRequest) Descriptor deprecated added in v0.6.0

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

Deprecated: Use CreateVolumeRequest.ProtoReflect.Descriptor instead.

func (*CreateVolumeRequest) GetOptions added in v0.6.0

func (x *CreateVolumeRequest) GetOptions() []byte

func (*CreateVolumeRequest) ProtoMessage added in v0.6.0

func (*CreateVolumeRequest) ProtoMessage()

func (*CreateVolumeRequest) ProtoReflect added in v0.6.0

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

func (*CreateVolumeRequest) Reset added in v0.6.0

func (x *CreateVolumeRequest) Reset()

func (*CreateVolumeRequest) String added in v0.6.0

func (x *CreateVolumeRequest) String() string

type CreateVolumeResponse added in v0.6.0

type CreateVolumeResponse struct {

	// JSON serialised volume.Volume.
	Volume []byte `protobuf:"bytes,1,opt,name=volume,proto3" json:"volume,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateVolumeResponse) Descriptor deprecated added in v0.6.0

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

Deprecated: Use CreateVolumeResponse.ProtoReflect.Descriptor instead.

func (*CreateVolumeResponse) GetVolume added in v0.6.0

func (x *CreateVolumeResponse) GetVolume() []byte

func (*CreateVolumeResponse) ProtoMessage added in v0.6.0

func (*CreateVolumeResponse) ProtoMessage()

func (*CreateVolumeResponse) ProtoReflect added in v0.6.0

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

func (*CreateVolumeResponse) Reset added in v0.6.0

func (x *CreateVolumeResponse) Reset()

func (*CreateVolumeResponse) String added in v0.6.0

func (x *CreateVolumeResponse) String() string

type DNSRecord

type DNSRecord struct {
	Name   string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type   DNSRecord_RecordType `protobuf:"varint,2,opt,name=type,proto3,enum=api.DNSRecord_RecordType" json:"type,omitempty"`
	Values []string             `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*DNSRecord) Descriptor deprecated

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

Deprecated: Use DNSRecord.ProtoReflect.Descriptor instead.

func (*DNSRecord) GetName

func (x *DNSRecord) GetName() string

func (*DNSRecord) GetType

func (x *DNSRecord) GetType() DNSRecord_RecordType

func (*DNSRecord) GetValues

func (x *DNSRecord) GetValues() []string

func (*DNSRecord) ProtoMessage

func (*DNSRecord) ProtoMessage()

func (*DNSRecord) ProtoReflect

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

func (*DNSRecord) Reset

func (x *DNSRecord) Reset()

func (*DNSRecord) String

func (x *DNSRecord) String() string

type DNSRecord_RecordType

type DNSRecord_RecordType int32
const (
	DNSRecord_UNSPECIFIED DNSRecord_RecordType = 0
	DNSRecord_A           DNSRecord_RecordType = 1
	DNSRecord_AAAA        DNSRecord_RecordType = 2
)

func (DNSRecord_RecordType) Descriptor

func (DNSRecord_RecordType) Enum

func (DNSRecord_RecordType) EnumDescriptor deprecated

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

Deprecated: Use DNSRecord_RecordType.Descriptor instead.

func (DNSRecord_RecordType) Number

func (DNSRecord_RecordType) String

func (x DNSRecord_RecordType) String() string

func (DNSRecord_RecordType) Type

type DockerClient

type DockerClient interface {
	CreateContainer(ctx context.Context, in *CreateContainerRequest, opts ...grpc.CallOption) (*CreateContainerResponse, error)
	InspectContainer(ctx context.Context, in *InspectContainerRequest, opts ...grpc.CallOption) (*InspectContainerResponse, error)
	StartContainer(ctx context.Context, in *StartContainerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	StopContainer(ctx context.Context, in *StopContainerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListContainers(ctx context.Context, in *ListContainersRequest, opts ...grpc.CallOption) (*ListContainersResponse, error)
	RemoveContainer(ctx context.Context, in *RemoveContainerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PullImage(ctx context.Context, in *PullImageRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[JSONMessage], error)
	InspectImage(ctx context.Context, in *InspectImageRequest, opts ...grpc.CallOption) (*InspectImageResponse, error)
	// InspectRemoteImage returns the image metadata for an image in a remote registry using the machine's
	// Docker auth credentials if necessary.
	InspectRemoteImage(ctx context.Context, in *InspectRemoteImageRequest, opts ...grpc.CallOption) (*InspectRemoteImageResponse, error)
	CreateVolume(ctx context.Context, in *CreateVolumeRequest, opts ...grpc.CallOption) (*CreateVolumeResponse, error)
	ListVolumes(ctx context.Context, in *ListVolumesRequest, opts ...grpc.CallOption) (*ListVolumesResponse, error)
	RemoveVolume(ctx context.Context, in *RemoveVolumeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	CreateServiceContainer(ctx context.Context, in *CreateServiceContainerRequest, opts ...grpc.CallOption) (*CreateContainerResponse, error)
	InspectServiceContainer(ctx context.Context, in *InspectContainerRequest, opts ...grpc.CallOption) (*ServiceContainer, error)
	ListServiceContainers(ctx context.Context, in *ListServiceContainersRequest, opts ...grpc.CallOption) (*ListServiceContainersResponse, error)
	RemoveServiceContainer(ctx context.Context, in *RemoveContainerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

DockerClient is the client API for Docker 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 NewDockerClient

func NewDockerClient(cc grpc.ClientConnInterface) DockerClient

type DockerServer

type DockerServer interface {
	CreateContainer(context.Context, *CreateContainerRequest) (*CreateContainerResponse, error)
	InspectContainer(context.Context, *InspectContainerRequest) (*InspectContainerResponse, error)
	StartContainer(context.Context, *StartContainerRequest) (*emptypb.Empty, error)
	StopContainer(context.Context, *StopContainerRequest) (*emptypb.Empty, error)
	ListContainers(context.Context, *ListContainersRequest) (*ListContainersResponse, error)
	RemoveContainer(context.Context, *RemoveContainerRequest) (*emptypb.Empty, error)
	PullImage(*PullImageRequest, grpc.ServerStreamingServer[JSONMessage]) error
	InspectImage(context.Context, *InspectImageRequest) (*InspectImageResponse, error)
	// InspectRemoteImage returns the image metadata for an image in a remote registry using the machine's
	// Docker auth credentials if necessary.
	InspectRemoteImage(context.Context, *InspectRemoteImageRequest) (*InspectRemoteImageResponse, error)
	CreateVolume(context.Context, *CreateVolumeRequest) (*CreateVolumeResponse, error)
	ListVolumes(context.Context, *ListVolumesRequest) (*ListVolumesResponse, error)
	RemoveVolume(context.Context, *RemoveVolumeRequest) (*emptypb.Empty, error)
	CreateServiceContainer(context.Context, *CreateServiceContainerRequest) (*CreateContainerResponse, error)
	InspectServiceContainer(context.Context, *InspectContainerRequest) (*ServiceContainer, error)
	ListServiceContainers(context.Context, *ListServiceContainersRequest) (*ListServiceContainersResponse, error)
	RemoveServiceContainer(context.Context, *RemoveContainerRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

DockerServer is the server API for Docker service. All implementations must embed UnimplementedDockerServer for forward compatibility.

type Docker_PullImageClient

type Docker_PullImageClient = grpc.ServerStreamingClient[JSONMessage]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Docker_PullImageServer

type Docker_PullImageServer = grpc.ServerStreamingServer[JSONMessage]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Domain

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

func (*Domain) Descriptor deprecated

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

Deprecated: Use Domain.ProtoReflect.Descriptor instead.

func (*Domain) GetName

func (x *Domain) GetName() string

func (*Domain) ProtoMessage

func (*Domain) ProtoMessage()

func (*Domain) ProtoReflect

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

func (*Domain) Reset

func (x *Domain) Reset()

func (*Domain) String

func (x *Domain) String() string

type Empty

type Empty struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

A helper message for marshalling the metadata field and injecting it into the response by the gRPC proxy.

func (*Empty) Descriptor deprecated

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) GetMetadata

func (x *Empty) GetMetadata() *Metadata

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect

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

func (*Empty) Reset

func (x *Empty) Reset()

func (*Empty) String

func (x *Empty) String() string

type EmptyResponse

type EmptyResponse struct {
	Messages []*Empty `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

EmptyResponse is a response message to be returned by the gRPC proxy when a request to the upstream failed. The nested Empty.Metadata message should contain an error.

func (*EmptyResponse) Descriptor deprecated

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

Deprecated: Use EmptyResponse.ProtoReflect.Descriptor instead.

func (*EmptyResponse) GetMessages

func (x *EmptyResponse) GetMessages() []*Empty

func (*EmptyResponse) ProtoMessage

func (*EmptyResponse) ProtoMessage()

func (*EmptyResponse) ProtoReflect

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

func (*EmptyResponse) Reset

func (x *EmptyResponse) Reset()

func (*EmptyResponse) String

func (x *EmptyResponse) String() string

type GetCaddyConfigResponse added in v0.12.0

type GetCaddyConfigResponse struct {

	// The generated Caddyfile content.
	Caddyfile string `protobuf:"bytes,1,opt,name=caddyfile,proto3" json:"caddyfile,omitempty"`
	// Timestamp when the config was last modified.
	ModifiedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=modified_at,json=modifiedAt,proto3" json:"modified_at,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCaddyConfigResponse) Descriptor deprecated added in v0.12.0

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

Deprecated: Use GetCaddyConfigResponse.ProtoReflect.Descriptor instead.

func (*GetCaddyConfigResponse) GetCaddyfile added in v0.12.0

func (x *GetCaddyConfigResponse) GetCaddyfile() string

func (*GetCaddyConfigResponse) GetModifiedAt added in v0.12.0

func (x *GetCaddyConfigResponse) GetModifiedAt() *timestamppb.Timestamp

func (*GetCaddyConfigResponse) ProtoMessage added in v0.12.0

func (*GetCaddyConfigResponse) ProtoMessage()

func (*GetCaddyConfigResponse) ProtoReflect added in v0.12.0

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

func (*GetCaddyConfigResponse) Reset added in v0.12.0

func (x *GetCaddyConfigResponse) Reset()

func (*GetCaddyConfigResponse) String added in v0.12.0

func (x *GetCaddyConfigResponse) String() string

type IP

type IP struct {
	Ip []byte `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	// contains filtered or unexported fields
}

func NewIP

func NewIP(addr netip.Addr) *IP

func (*IP) Descriptor deprecated

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

Deprecated: Use IP.ProtoReflect.Descriptor instead.

func (*IP) Equal

func (ip *IP) Equal(other *IP) bool

func (*IP) GetIp

func (x *IP) GetIp() []byte

func (*IP) ProtoMessage

func (*IP) ProtoMessage()

func (*IP) ProtoReflect

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

func (*IP) Reset

func (x *IP) Reset()

func (*IP) String

func (x *IP) String() string

func (*IP) ToAddr

func (ip *IP) ToAddr() (netip.Addr, error)

type IPPort

type IPPort struct {
	Ip   *IP    `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func NewIPPort

func NewIPPort(ap netip.AddrPort) *IPPort

func (*IPPort) Descriptor deprecated

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

Deprecated: Use IPPort.ProtoReflect.Descriptor instead.

func (*IPPort) GetIp

func (x *IPPort) GetIp() *IP

func (*IPPort) GetPort

func (x *IPPort) GetPort() uint32

func (*IPPort) ProtoMessage

func (*IPPort) ProtoMessage()

func (*IPPort) ProtoReflect

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

func (*IPPort) Reset

func (x *IPPort) Reset()

func (*IPPort) String

func (x *IPPort) String() string

func (*IPPort) ToAddrPort

func (ipp *IPPort) ToAddrPort() (netip.AddrPort, error)

type IPPrefix

type IPPrefix struct {
	Ip   *IP    `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Bits uint32 `protobuf:"varint,2,opt,name=bits,proto3" json:"bits,omitempty"`
	// contains filtered or unexported fields
}

func NewIPPrefix

func NewIPPrefix(p netip.Prefix) *IPPrefix

func (*IPPrefix) Descriptor deprecated

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

Deprecated: Use IPPrefix.ProtoReflect.Descriptor instead.

func (*IPPrefix) GetBits

func (x *IPPrefix) GetBits() uint32

func (*IPPrefix) GetIp

func (x *IPPrefix) GetIp() *IP

func (*IPPrefix) ProtoMessage

func (*IPPrefix) ProtoMessage()

func (*IPPrefix) ProtoReflect

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

func (*IPPrefix) Reset

func (x *IPPrefix) Reset()

func (*IPPrefix) String

func (x *IPPrefix) String() string

func (*IPPrefix) ToPrefix

func (p *IPPrefix) ToPrefix() (netip.Prefix, error)

type Image

type Image struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// JSON serialised types.ImageInspect.
	Image []byte `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	// contains filtered or unexported fields
}

func (*Image) Descriptor deprecated

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

Deprecated: Use Image.ProtoReflect.Descriptor instead.

func (*Image) GetImage

func (x *Image) GetImage() []byte

func (*Image) GetMetadata

func (x *Image) GetMetadata() *Metadata

func (*Image) ProtoMessage

func (*Image) ProtoMessage()

func (*Image) ProtoReflect

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

func (*Image) Reset

func (x *Image) Reset()

func (*Image) String

func (x *Image) String() string

type InitClusterRequest

type InitClusterRequest struct {
	MachineName string    `protobuf:"bytes,1,opt,name=machineName,proto3" json:"machineName,omitempty"`
	Network     *IPPrefix `protobuf:"bytes,2,opt,name=network,proto3" json:"network,omitempty"`
	// Types that are assignable to PublicIpConfig:
	//
	//	*InitClusterRequest_PublicIp
	//	*InitClusterRequest_PublicIpAuto
	PublicIpConfig isInitClusterRequest_PublicIpConfig `protobuf_oneof:"public_ip_config"`
	// contains filtered or unexported fields
}

func (*InitClusterRequest) Descriptor deprecated

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

Deprecated: Use InitClusterRequest.ProtoReflect.Descriptor instead.

func (*InitClusterRequest) GetMachineName

func (x *InitClusterRequest) GetMachineName() string

func (*InitClusterRequest) GetNetwork

func (x *InitClusterRequest) GetNetwork() *IPPrefix

func (*InitClusterRequest) GetPublicIp

func (x *InitClusterRequest) GetPublicIp() *IP

func (*InitClusterRequest) GetPublicIpAuto

func (x *InitClusterRequest) GetPublicIpAuto() bool

func (*InitClusterRequest) GetPublicIpConfig

func (m *InitClusterRequest) GetPublicIpConfig() isInitClusterRequest_PublicIpConfig

func (*InitClusterRequest) ProtoMessage

func (*InitClusterRequest) ProtoMessage()

func (*InitClusterRequest) ProtoReflect

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

func (*InitClusterRequest) Reset

func (x *InitClusterRequest) Reset()

func (*InitClusterRequest) String

func (x *InitClusterRequest) String() string

type InitClusterRequest_PublicIp

type InitClusterRequest_PublicIp struct {
	PublicIp *IP `protobuf:"bytes,3,opt,name=public_ip,json=publicIp,proto3,oneof"`
}

type InitClusterRequest_PublicIpAuto

type InitClusterRequest_PublicIpAuto struct {
	PublicIpAuto bool `protobuf:"varint,4,opt,name=public_ip_auto,json=publicIpAuto,proto3,oneof"`
}

type InitClusterResponse

type InitClusterResponse struct {
	Machine *MachineInfo `protobuf:"bytes,1,opt,name=machine,proto3" json:"machine,omitempty"`
	// contains filtered or unexported fields
}

func (*InitClusterResponse) Descriptor deprecated

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

Deprecated: Use InitClusterResponse.ProtoReflect.Descriptor instead.

func (*InitClusterResponse) GetMachine

func (x *InitClusterResponse) GetMachine() *MachineInfo

func (*InitClusterResponse) ProtoMessage

func (*InitClusterResponse) ProtoMessage()

func (*InitClusterResponse) ProtoReflect

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

func (*InitClusterResponse) Reset

func (x *InitClusterResponse) Reset()

func (*InitClusterResponse) String

func (x *InitClusterResponse) String() string

type InspectContainerRequest

type InspectContainerRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*InspectContainerRequest) Descriptor deprecated

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

Deprecated: Use InspectContainerRequest.ProtoReflect.Descriptor instead.

func (*InspectContainerRequest) GetId

func (x *InspectContainerRequest) GetId() string

func (*InspectContainerRequest) ProtoMessage

func (*InspectContainerRequest) ProtoMessage()

func (*InspectContainerRequest) ProtoReflect

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

func (*InspectContainerRequest) Reset

func (x *InspectContainerRequest) Reset()

func (*InspectContainerRequest) String

func (x *InspectContainerRequest) String() string

type InspectContainerResponse

type InspectContainerResponse struct {

	// JSON serialised container.InspectResponse.
	Response []byte `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*InspectContainerResponse) Descriptor deprecated

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

Deprecated: Use InspectContainerResponse.ProtoReflect.Descriptor instead.

func (*InspectContainerResponse) GetResponse

func (x *InspectContainerResponse) GetResponse() []byte

func (*InspectContainerResponse) ProtoMessage

func (*InspectContainerResponse) ProtoMessage()

func (*InspectContainerResponse) ProtoReflect

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

func (*InspectContainerResponse) Reset

func (x *InspectContainerResponse) Reset()

func (*InspectContainerResponse) String

func (x *InspectContainerResponse) String() string

type InspectImageRequest

type InspectImageRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*InspectImageRequest) Descriptor deprecated

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

Deprecated: Use InspectImageRequest.ProtoReflect.Descriptor instead.

func (*InspectImageRequest) GetId

func (x *InspectImageRequest) GetId() string

func (*InspectImageRequest) ProtoMessage

func (*InspectImageRequest) ProtoMessage()

func (*InspectImageRequest) ProtoReflect

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

func (*InspectImageRequest) Reset

func (x *InspectImageRequest) Reset()

func (*InspectImageRequest) String

func (x *InspectImageRequest) String() string

type InspectImageResponse

type InspectImageResponse struct {

	// Must contain only one repeated messages field to allow broadcasting InspectImage requests to multiple machines.
	Messages []*Image `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*InspectImageResponse) Descriptor deprecated

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

Deprecated: Use InspectImageResponse.ProtoReflect.Descriptor instead.

func (*InspectImageResponse) GetMessages

func (x *InspectImageResponse) GetMessages() []*Image

func (*InspectImageResponse) ProtoMessage

func (*InspectImageResponse) ProtoMessage()

func (*InspectImageResponse) ProtoReflect

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

func (*InspectImageResponse) Reset

func (x *InspectImageResponse) Reset()

func (*InspectImageResponse) String

func (x *InspectImageResponse) String() string

type InspectRemoteImageRequest

type InspectRemoteImageRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*InspectRemoteImageRequest) Descriptor deprecated

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

Deprecated: Use InspectRemoteImageRequest.ProtoReflect.Descriptor instead.

func (*InspectRemoteImageRequest) GetId

func (x *InspectRemoteImageRequest) GetId() string

func (*InspectRemoteImageRequest) ProtoMessage

func (*InspectRemoteImageRequest) ProtoMessage()

func (*InspectRemoteImageRequest) ProtoReflect

func (*InspectRemoteImageRequest) Reset

func (x *InspectRemoteImageRequest) Reset()

func (*InspectRemoteImageRequest) String

func (x *InspectRemoteImageRequest) String() string

type InspectRemoteImageResponse

type InspectRemoteImageResponse struct {

	// Must contain only one repeated messages field to allow broadcasting InspectRemoteImage requests to multiple machines.
	Messages []*RemoteImage `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*InspectRemoteImageResponse) Descriptor deprecated

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

Deprecated: Use InspectRemoteImageResponse.ProtoReflect.Descriptor instead.

func (*InspectRemoteImageResponse) GetMessages

func (x *InspectRemoteImageResponse) GetMessages() []*RemoteImage

func (*InspectRemoteImageResponse) ProtoMessage

func (*InspectRemoteImageResponse) ProtoMessage()

func (*InspectRemoteImageResponse) ProtoReflect

func (*InspectRemoteImageResponse) Reset

func (x *InspectRemoteImageResponse) Reset()

func (*InspectRemoteImageResponse) String

func (x *InspectRemoteImageResponse) String() string

type InspectServiceRequest

type InspectServiceRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*InspectServiceRequest) Descriptor deprecated

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

Deprecated: Use InspectServiceRequest.ProtoReflect.Descriptor instead.

func (*InspectServiceRequest) GetId

func (x *InspectServiceRequest) GetId() string

func (*InspectServiceRequest) ProtoMessage

func (*InspectServiceRequest) ProtoMessage()

func (*InspectServiceRequest) ProtoReflect

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

func (*InspectServiceRequest) Reset

func (x *InspectServiceRequest) Reset()

func (*InspectServiceRequest) String

func (x *InspectServiceRequest) String() string

type InspectServiceResponse

type InspectServiceResponse struct {
	Service *Service `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

func (*InspectServiceResponse) Descriptor deprecated

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

Deprecated: Use InspectServiceResponse.ProtoReflect.Descriptor instead.

func (*InspectServiceResponse) GetService

func (x *InspectServiceResponse) GetService() *Service

func (*InspectServiceResponse) ProtoMessage

func (*InspectServiceResponse) ProtoMessage()

func (*InspectServiceResponse) ProtoReflect

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

func (*InspectServiceResponse) Reset

func (x *InspectServiceResponse) Reset()

func (*InspectServiceResponse) String

func (x *InspectServiceResponse) String() string

type JSONMessage

type JSONMessage struct {

	// JSON serialised jsonmessage.JSONMessage.
	Message []byte `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*JSONMessage) Descriptor deprecated

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

Deprecated: Use JSONMessage.ProtoReflect.Descriptor instead.

func (*JSONMessage) GetMessage

func (x *JSONMessage) GetMessage() []byte

func (*JSONMessage) ProtoMessage

func (*JSONMessage) ProtoMessage()

func (*JSONMessage) ProtoReflect

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

func (*JSONMessage) Reset

func (x *JSONMessage) Reset()

func (*JSONMessage) String

func (x *JSONMessage) String() string

type JoinClusterRequest

type JoinClusterRequest struct {
	Machine       *MachineInfo   `protobuf:"bytes,1,opt,name=machine,proto3" json:"machine,omitempty"`
	OtherMachines []*MachineInfo `protobuf:"bytes,3,rep,name=other_machines,json=otherMachines,proto3" json:"other_machines,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinClusterRequest) Descriptor deprecated

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

Deprecated: Use JoinClusterRequest.ProtoReflect.Descriptor instead.

func (*JoinClusterRequest) GetMachine

func (x *JoinClusterRequest) GetMachine() *MachineInfo

func (*JoinClusterRequest) GetOtherMachines

func (x *JoinClusterRequest) GetOtherMachines() []*MachineInfo

func (*JoinClusterRequest) ProtoMessage

func (*JoinClusterRequest) ProtoMessage()

func (*JoinClusterRequest) ProtoReflect

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

func (*JoinClusterRequest) Reset

func (x *JoinClusterRequest) Reset()

func (*JoinClusterRequest) String

func (x *JoinClusterRequest) String() string

type ListContainersRequest

type ListContainersRequest struct {

	// JSON serialised container.ListOptions.
	Options []byte `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*ListContainersRequest) Descriptor deprecated

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

Deprecated: Use ListContainersRequest.ProtoReflect.Descriptor instead.

func (*ListContainersRequest) GetOptions

func (x *ListContainersRequest) GetOptions() []byte

func (*ListContainersRequest) ProtoMessage

func (*ListContainersRequest) ProtoMessage()

func (*ListContainersRequest) ProtoReflect

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

func (*ListContainersRequest) Reset

func (x *ListContainersRequest) Reset()

func (*ListContainersRequest) String

func (x *ListContainersRequest) String() string

type ListContainersResponse

type ListContainersResponse struct {

	// Must contain only one repeated messages field to allow broadcasting ListContainers requests to multiple machines.
	Messages []*MachineContainers `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*ListContainersResponse) Descriptor deprecated

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

Deprecated: Use ListContainersResponse.ProtoReflect.Descriptor instead.

func (*ListContainersResponse) GetMessages

func (x *ListContainersResponse) GetMessages() []*MachineContainers

func (*ListContainersResponse) ProtoMessage

func (*ListContainersResponse) ProtoMessage()

func (*ListContainersResponse) ProtoReflect

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

func (*ListContainersResponse) Reset

func (x *ListContainersResponse) Reset()

func (*ListContainersResponse) String

func (x *ListContainersResponse) String() string

type ListMachinesResponse

type ListMachinesResponse struct {
	Machines []*MachineMember `protobuf:"bytes,1,rep,name=machines,proto3" json:"machines,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMachinesResponse) Descriptor deprecated

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

Deprecated: Use ListMachinesResponse.ProtoReflect.Descriptor instead.

func (*ListMachinesResponse) GetMachines

func (x *ListMachinesResponse) GetMachines() []*MachineMember

func (*ListMachinesResponse) ProtoMessage

func (*ListMachinesResponse) ProtoMessage()

func (*ListMachinesResponse) ProtoReflect

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

func (*ListMachinesResponse) Reset

func (x *ListMachinesResponse) Reset()

func (*ListMachinesResponse) String

func (x *ListMachinesResponse) String() string

type ListServiceContainersRequest

type ListServiceContainersRequest struct {
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// JSON serialised container.ListOptions.
	Options []byte `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*ListServiceContainersRequest) Descriptor deprecated

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

Deprecated: Use ListServiceContainersRequest.ProtoReflect.Descriptor instead.

func (*ListServiceContainersRequest) GetOptions

func (x *ListServiceContainersRequest) GetOptions() []byte

func (*ListServiceContainersRequest) GetServiceId

func (x *ListServiceContainersRequest) GetServiceId() string

func (*ListServiceContainersRequest) ProtoMessage

func (*ListServiceContainersRequest) ProtoMessage()

func (*ListServiceContainersRequest) ProtoReflect

func (*ListServiceContainersRequest) Reset

func (x *ListServiceContainersRequest) Reset()

func (*ListServiceContainersRequest) String

type ListServiceContainersResponse

type ListServiceContainersResponse struct {

	// Must contain only one repeated messages field to allow broadcasting ListServiceContainers requests
	// to multiple machines.
	Messages []*MachineServiceContainers `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*ListServiceContainersResponse) Descriptor deprecated

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

Deprecated: Use ListServiceContainersResponse.ProtoReflect.Descriptor instead.

func (*ListServiceContainersResponse) GetMessages

func (*ListServiceContainersResponse) ProtoMessage

func (*ListServiceContainersResponse) ProtoMessage()

func (*ListServiceContainersResponse) ProtoReflect

func (*ListServiceContainersResponse) Reset

func (x *ListServiceContainersResponse) Reset()

func (*ListServiceContainersResponse) String

type ListVolumesRequest added in v0.6.0

type ListVolumesRequest struct {

	// JSON serialised volume.ListOptions.
	Options []byte `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*ListVolumesRequest) Descriptor deprecated added in v0.6.0

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

Deprecated: Use ListVolumesRequest.ProtoReflect.Descriptor instead.

func (*ListVolumesRequest) GetOptions added in v0.6.0

func (x *ListVolumesRequest) GetOptions() []byte

func (*ListVolumesRequest) ProtoMessage added in v0.6.0

func (*ListVolumesRequest) ProtoMessage()

func (*ListVolumesRequest) ProtoReflect added in v0.6.0

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

func (*ListVolumesRequest) Reset added in v0.6.0

func (x *ListVolumesRequest) Reset()

func (*ListVolumesRequest) String added in v0.6.0

func (x *ListVolumesRequest) String() string

type ListVolumesResponse added in v0.6.0

type ListVolumesResponse struct {

	// Must contain only one repeated messages field to allow broadcasting ListVolumes requests to multiple machines.
	Messages []*MachineVolumes `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*ListVolumesResponse) Descriptor deprecated added in v0.6.0

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

Deprecated: Use ListVolumesResponse.ProtoReflect.Descriptor instead.

func (*ListVolumesResponse) GetMessages added in v0.6.0

func (x *ListVolumesResponse) GetMessages() []*MachineVolumes

func (*ListVolumesResponse) ProtoMessage added in v0.6.0

func (*ListVolumesResponse) ProtoMessage()

func (*ListVolumesResponse) ProtoReflect added in v0.6.0

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

func (*ListVolumesResponse) Reset added in v0.6.0

func (x *ListVolumesResponse) Reset()

func (*ListVolumesResponse) String added in v0.6.0

func (x *ListVolumesResponse) String() string

type MachineClient

type MachineClient interface {
	// CheckPrerequisites verifies if the machine meets all necessary system requirements to participate in the cluster.
	CheckPrerequisites(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*CheckPrerequisitesResponse, error)
	InitCluster(ctx context.Context, in *InitClusterRequest, opts ...grpc.CallOption) (*InitClusterResponse, error)
	JoinCluster(ctx context.Context, in *JoinClusterRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Token(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*TokenResponse, error)
	Inspect(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*MachineInfo, error)
	// Reset restores the machine to a clean state, removing all cluster-related configuration and data.
	Reset(ctx context.Context, in *ResetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	InspectService(ctx context.Context, in *InspectServiceRequest, opts ...grpc.CallOption) (*InspectServiceResponse, error)
}

MachineClient is the client API for Machine 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 NewMachineClient

func NewMachineClient(cc grpc.ClientConnInterface) MachineClient

type MachineContainers

type MachineContainers struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// JSON serialised []container.InspectResponse.
	Containers []byte `protobuf:"bytes,2,opt,name=containers,proto3" json:"containers,omitempty"`
	// contains filtered or unexported fields
}

func (*MachineContainers) Descriptor deprecated

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

Deprecated: Use MachineContainers.ProtoReflect.Descriptor instead.

func (*MachineContainers) GetContainers

func (x *MachineContainers) GetContainers() []byte

func (*MachineContainers) GetMetadata

func (x *MachineContainers) GetMetadata() *Metadata

func (*MachineContainers) ProtoMessage

func (*MachineContainers) ProtoMessage()

func (*MachineContainers) ProtoReflect

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

func (*MachineContainers) Reset

func (x *MachineContainers) Reset()

func (*MachineContainers) String

func (x *MachineContainers) String() string

type MachineInfo

type MachineInfo struct {
	Id       string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name     string         `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Network  *NetworkConfig `protobuf:"bytes,3,opt,name=network,proto3" json:"network,omitempty"`
	PublicIp *IP            `protobuf:"bytes,4,opt,name=public_ip,json=publicIp,proto3" json:"public_ip,omitempty"`
	// contains filtered or unexported fields
}

func (*MachineInfo) Descriptor deprecated

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

Deprecated: Use MachineInfo.ProtoReflect.Descriptor instead.

func (*MachineInfo) GetId

func (x *MachineInfo) GetId() string

func (*MachineInfo) GetName

func (x *MachineInfo) GetName() string

func (*MachineInfo) GetNetwork

func (x *MachineInfo) GetNetwork() *NetworkConfig

func (*MachineInfo) GetPublicIp

func (x *MachineInfo) GetPublicIp() *IP

func (*MachineInfo) ProtoMessage

func (*MachineInfo) ProtoMessage()

func (*MachineInfo) ProtoReflect

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

func (*MachineInfo) Reset

func (x *MachineInfo) Reset()

func (*MachineInfo) String

func (x *MachineInfo) String() string

type MachineMember

type MachineMember struct {
	Machine *MachineInfo                  `protobuf:"bytes,1,opt,name=machine,proto3" json:"machine,omitempty"`
	State   MachineMember_MembershipState `protobuf:"varint,2,opt,name=state,proto3,enum=api.MachineMember_MembershipState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*MachineMember) Descriptor deprecated

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

Deprecated: Use MachineMember.ProtoReflect.Descriptor instead.

func (*MachineMember) GetMachine

func (x *MachineMember) GetMachine() *MachineInfo

func (*MachineMember) GetState

func (*MachineMember) ProtoMessage

func (*MachineMember) ProtoMessage()

func (*MachineMember) ProtoReflect

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

func (*MachineMember) Reset

func (x *MachineMember) Reset()

func (*MachineMember) String

func (x *MachineMember) String() string

type MachineMember_MembershipState

type MachineMember_MembershipState int32
const (
	MachineMember_UNKNOWN MachineMember_MembershipState = 0
	// The member is active.
	MachineMember_UP MachineMember_MembershipState = 1
	// The member is active, but at least one cluster member suspects its down. For all purposes,
	// a SUSPECT member is treated as if it were UP until either it refutes the suspicion (becoming UP)
	// or fails to do so (being declared DOWN).
	MachineMember_SUSPECT MachineMember_MembershipState = 2
	// The member is confirmed DOWN.
	MachineMember_DOWN MachineMember_MembershipState = 3
)

func (MachineMember_MembershipState) Descriptor

func (MachineMember_MembershipState) Enum

func (MachineMember_MembershipState) EnumDescriptor deprecated

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

Deprecated: Use MachineMember_MembershipState.Descriptor instead.

func (MachineMember_MembershipState) Number

func (MachineMember_MembershipState) String

func (MachineMember_MembershipState) Type

type MachineServer

type MachineServer interface {
	// CheckPrerequisites verifies if the machine meets all necessary system requirements to participate in the cluster.
	CheckPrerequisites(context.Context, *emptypb.Empty) (*CheckPrerequisitesResponse, error)
	InitCluster(context.Context, *InitClusterRequest) (*InitClusterResponse, error)
	JoinCluster(context.Context, *JoinClusterRequest) (*emptypb.Empty, error)
	Token(context.Context, *emptypb.Empty) (*TokenResponse, error)
	Inspect(context.Context, *emptypb.Empty) (*MachineInfo, error)
	// Reset restores the machine to a clean state, removing all cluster-related configuration and data.
	Reset(context.Context, *ResetRequest) (*emptypb.Empty, error)
	InspectService(context.Context, *InspectServiceRequest) (*InspectServiceResponse, error)
	// contains filtered or unexported methods
}

MachineServer is the server API for Machine service. All implementations must embed UnimplementedMachineServer for forward compatibility.

type MachineServiceContainers

type MachineServiceContainers struct {
	Metadata   *Metadata           `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Containers []*ServiceContainer `protobuf:"bytes,2,rep,name=containers,proto3" json:"containers,omitempty"`
	// contains filtered or unexported fields
}

func (*MachineServiceContainers) Descriptor deprecated

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

Deprecated: Use MachineServiceContainers.ProtoReflect.Descriptor instead.

func (*MachineServiceContainers) GetContainers

func (x *MachineServiceContainers) GetContainers() []*ServiceContainer

func (*MachineServiceContainers) GetMetadata

func (x *MachineServiceContainers) GetMetadata() *Metadata

func (*MachineServiceContainers) ProtoMessage

func (*MachineServiceContainers) ProtoMessage()

func (*MachineServiceContainers) ProtoReflect

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

func (*MachineServiceContainers) Reset

func (x *MachineServiceContainers) Reset()

func (*MachineServiceContainers) String

func (x *MachineServiceContainers) String() string

type MachineVolumes added in v0.6.0

type MachineVolumes struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// JSON serialised volume.ListResponse.
	Response []byte `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*MachineVolumes) Descriptor deprecated added in v0.6.0

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

Deprecated: Use MachineVolumes.ProtoReflect.Descriptor instead.

func (*MachineVolumes) GetMetadata added in v0.6.0

func (x *MachineVolumes) GetMetadata() *Metadata

func (*MachineVolumes) GetResponse added in v0.6.0

func (x *MachineVolumes) GetResponse() []byte

func (*MachineVolumes) ProtoMessage added in v0.6.0

func (*MachineVolumes) ProtoMessage()

func (*MachineVolumes) ProtoReflect added in v0.6.0

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

func (*MachineVolumes) Reset added in v0.6.0

func (x *MachineVolumes) Reset()

func (*MachineVolumes) String added in v0.6.0

func (x *MachineVolumes) String() string

type Metadata

type Metadata struct {

	// Address of the machine the response came from.
	Machine string `protobuf:"bytes,1,opt,name=machine,proto3" json:"machine,omitempty"`
	// error is set if the request to upstream failed. The rest of the response is undefined.
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// error as a gRPC Status message.
	Status *status.Status `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

Common metadata message nested in all reply message types, injected by the gRPC proxy to provide information about the machine that responded to the request.

func (*Metadata) Descriptor deprecated

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetError

func (x *Metadata) GetError() string

func (*Metadata) GetMachine

func (x *Metadata) GetMachine() string

func (*Metadata) GetStatus

func (x *Metadata) GetStatus() *status.Status

func (*Metadata) ProtoMessage

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect

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

func (*Metadata) Reset

func (x *Metadata) Reset()

func (*Metadata) String

func (x *Metadata) String() string

type NetworkConfig

type NetworkConfig struct {
	Subnet       *IPPrefix `protobuf:"bytes,1,opt,name=subnet,proto3" json:"subnet,omitempty"`
	ManagementIp *IP       `protobuf:"bytes,2,opt,name=management_ip,json=managementIp,proto3" json:"management_ip,omitempty"`
	Endpoints    []*IPPort `protobuf:"bytes,3,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	PublicKey    []byte    `protobuf:"bytes,4,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// contains filtered or unexported fields
}

func (*NetworkConfig) Descriptor deprecated

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

Deprecated: Use NetworkConfig.ProtoReflect.Descriptor instead.

func (*NetworkConfig) GetEndpoints

func (x *NetworkConfig) GetEndpoints() []*IPPort

func (*NetworkConfig) GetManagementIp

func (x *NetworkConfig) GetManagementIp() *IP

func (*NetworkConfig) GetPublicKey

func (x *NetworkConfig) GetPublicKey() []byte

func (*NetworkConfig) GetSubnet

func (x *NetworkConfig) GetSubnet() *IPPrefix

func (*NetworkConfig) ProtoMessage

func (*NetworkConfig) ProtoMessage()

func (*NetworkConfig) ProtoReflect

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

func (*NetworkConfig) Reset

func (x *NetworkConfig) Reset()

func (*NetworkConfig) String

func (x *NetworkConfig) String() string

func (*NetworkConfig) Validate

func (c *NetworkConfig) Validate() error

type PullImageRequest

type PullImageRequest struct {
	Image string `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	// JSON serialised image.PullOptions.
	Options []byte `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*PullImageRequest) Descriptor deprecated

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

Deprecated: Use PullImageRequest.ProtoReflect.Descriptor instead.

func (*PullImageRequest) GetImage

func (x *PullImageRequest) GetImage() string

func (*PullImageRequest) GetOptions

func (x *PullImageRequest) GetOptions() []byte

func (*PullImageRequest) ProtoMessage

func (*PullImageRequest) ProtoMessage()

func (*PullImageRequest) ProtoReflect

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

func (*PullImageRequest) Reset

func (x *PullImageRequest) Reset()

func (*PullImageRequest) String

func (x *PullImageRequest) String() string

type RemoteImage

type RemoteImage struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Image reference in the canonical form with the digest.
	Reference string `protobuf:"bytes,2,opt,name=reference,proto3" json:"reference,omitempty"`
	// Raw JSON manifest from the registry.
	Manifest []byte `protobuf:"bytes,3,opt,name=manifest,proto3" json:"manifest,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteImage) Descriptor deprecated

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

Deprecated: Use RemoteImage.ProtoReflect.Descriptor instead.

func (*RemoteImage) GetManifest

func (x *RemoteImage) GetManifest() []byte

func (*RemoteImage) GetMetadata

func (x *RemoteImage) GetMetadata() *Metadata

func (*RemoteImage) GetReference

func (x *RemoteImage) GetReference() string

func (*RemoteImage) ProtoMessage

func (*RemoteImage) ProtoMessage()

func (*RemoteImage) ProtoReflect

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

func (*RemoteImage) Reset

func (x *RemoteImage) Reset()

func (*RemoteImage) String

func (x *RemoteImage) String() string

type RemoveContainerRequest

type RemoveContainerRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// JSON serialised container.RemoveOptions.
	Options []byte `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveContainerRequest) Descriptor deprecated

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

Deprecated: Use RemoveContainerRequest.ProtoReflect.Descriptor instead.

func (*RemoveContainerRequest) GetId

func (x *RemoveContainerRequest) GetId() string

func (*RemoveContainerRequest) GetOptions

func (x *RemoveContainerRequest) GetOptions() []byte

func (*RemoveContainerRequest) ProtoMessage

func (*RemoveContainerRequest) ProtoMessage()

func (*RemoveContainerRequest) ProtoReflect

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

func (*RemoveContainerRequest) Reset

func (x *RemoveContainerRequest) Reset()

func (*RemoveContainerRequest) String

func (x *RemoveContainerRequest) String() string

type RemoveMachineRequest added in v0.10.0

type RemoveMachineRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveMachineRequest) Descriptor deprecated added in v0.10.0

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

Deprecated: Use RemoveMachineRequest.ProtoReflect.Descriptor instead.

func (*RemoveMachineRequest) GetId added in v0.10.0

func (x *RemoveMachineRequest) GetId() string

func (*RemoveMachineRequest) ProtoMessage added in v0.10.0

func (*RemoveMachineRequest) ProtoMessage()

func (*RemoveMachineRequest) ProtoReflect added in v0.10.0

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

func (*RemoveMachineRequest) Reset added in v0.10.0

func (x *RemoveMachineRequest) Reset()

func (*RemoveMachineRequest) String added in v0.10.0

func (x *RemoveMachineRequest) String() string

type RemoveVolumeRequest added in v0.6.0

type RemoveVolumeRequest struct {
	Id    string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Force bool   `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveVolumeRequest) Descriptor deprecated added in v0.6.0

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

Deprecated: Use RemoveVolumeRequest.ProtoReflect.Descriptor instead.

func (*RemoveVolumeRequest) GetForce added in v0.6.0

func (x *RemoveVolumeRequest) GetForce() bool

func (*RemoveVolumeRequest) GetId added in v0.6.0

func (x *RemoveVolumeRequest) GetId() string

func (*RemoveVolumeRequest) ProtoMessage added in v0.6.0

func (*RemoveVolumeRequest) ProtoMessage()

func (*RemoveVolumeRequest) ProtoReflect added in v0.6.0

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

func (*RemoveVolumeRequest) Reset added in v0.6.0

func (x *RemoveVolumeRequest) Reset()

func (*RemoveVolumeRequest) String added in v0.6.0

func (x *RemoveVolumeRequest) String() string

type ReserveDomainRequest

type ReserveDomainRequest struct {
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*ReserveDomainRequest) Descriptor deprecated

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

Deprecated: Use ReserveDomainRequest.ProtoReflect.Descriptor instead.

func (*ReserveDomainRequest) GetEndpoint

func (x *ReserveDomainRequest) GetEndpoint() string

func (*ReserveDomainRequest) ProtoMessage

func (*ReserveDomainRequest) ProtoMessage()

func (*ReserveDomainRequest) ProtoReflect

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

func (*ReserveDomainRequest) Reset

func (x *ReserveDomainRequest) Reset()

func (*ReserveDomainRequest) String

func (x *ReserveDomainRequest) String() string

type ResetRequest added in v0.9.0

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

func (*ResetRequest) Descriptor deprecated added in v0.9.0

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

Deprecated: Use ResetRequest.ProtoReflect.Descriptor instead.

func (*ResetRequest) ProtoMessage added in v0.9.0

func (*ResetRequest) ProtoMessage()

func (*ResetRequest) ProtoReflect added in v0.9.0

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

func (*ResetRequest) Reset added in v0.9.0

func (x *ResetRequest) Reset()

func (*ResetRequest) String added in v0.9.0

func (x *ResetRequest) String() string

type Service

type Service struct {
	Id         string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name       string               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Mode       string               `protobuf:"bytes,3,opt,name=mode,proto3" json:"mode,omitempty"`
	Containers []*Service_Container `protobuf:"bytes,4,rep,name=containers,proto3" json:"containers,omitempty"`
	// contains filtered or unexported fields
}

func (*Service) Descriptor deprecated

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

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetContainers

func (x *Service) GetContainers() []*Service_Container

func (*Service) GetId

func (x *Service) GetId() string

func (*Service) GetMode

func (x *Service) GetMode() string

func (*Service) GetName

func (x *Service) GetName() string

func (*Service) ProtoMessage

func (*Service) ProtoMessage()

func (*Service) ProtoReflect

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

func (*Service) Reset

func (x *Service) Reset()

func (*Service) String

func (x *Service) String() string

type ServiceContainer

type ServiceContainer struct {

	// JSON serialised container.InspectResponse.
	Container []byte `protobuf:"bytes,1,opt,name=container,proto3" json:"container,omitempty"`
	// JSON serialised api.ServiceSpec.
	ServiceSpec []byte `protobuf:"bytes,2,opt,name=service_spec,json=serviceSpec,proto3" json:"service_spec,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceContainer) Descriptor deprecated

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

Deprecated: Use ServiceContainer.ProtoReflect.Descriptor instead.

func (*ServiceContainer) GetContainer

func (x *ServiceContainer) GetContainer() []byte

func (*ServiceContainer) GetServiceSpec

func (x *ServiceContainer) GetServiceSpec() []byte

func (*ServiceContainer) ProtoMessage

func (*ServiceContainer) ProtoMessage()

func (*ServiceContainer) ProtoReflect

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

func (*ServiceContainer) Reset

func (x *ServiceContainer) Reset()

func (*ServiceContainer) String

func (x *ServiceContainer) String() string

type Service_Container

type Service_Container struct {
	MachineId string `protobuf:"bytes,1,opt,name=machine_id,json=machineId,proto3" json:"machine_id,omitempty"`
	// JSON encoded Docker types.Container.
	Container []byte `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"`
	// contains filtered or unexported fields
}

func (*Service_Container) Descriptor deprecated

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

Deprecated: Use Service_Container.ProtoReflect.Descriptor instead.

func (*Service_Container) GetContainer

func (x *Service_Container) GetContainer() []byte

func (*Service_Container) GetMachineId

func (x *Service_Container) GetMachineId() string

func (*Service_Container) ProtoMessage

func (*Service_Container) ProtoMessage()

func (*Service_Container) ProtoReflect

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

func (*Service_Container) Reset

func (x *Service_Container) Reset()

func (*Service_Container) String

func (x *Service_Container) String() string

type StartContainerRequest

type StartContainerRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// JSON serialised container.StartOptions.
	Options []byte `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*StartContainerRequest) Descriptor deprecated

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

Deprecated: Use StartContainerRequest.ProtoReflect.Descriptor instead.

func (*StartContainerRequest) GetId

func (x *StartContainerRequest) GetId() string

func (*StartContainerRequest) GetOptions

func (x *StartContainerRequest) GetOptions() []byte

func (*StartContainerRequest) ProtoMessage

func (*StartContainerRequest) ProtoMessage()

func (*StartContainerRequest) ProtoReflect

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

func (*StartContainerRequest) Reset

func (x *StartContainerRequest) Reset()

func (*StartContainerRequest) String

func (x *StartContainerRequest) String() string

type StopContainerRequest

type StopContainerRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// JSON serialised container.StopOptions.
	Options []byte `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*StopContainerRequest) Descriptor deprecated

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

Deprecated: Use StopContainerRequest.ProtoReflect.Descriptor instead.

func (*StopContainerRequest) GetId

func (x *StopContainerRequest) GetId() string

func (*StopContainerRequest) GetOptions

func (x *StopContainerRequest) GetOptions() []byte

func (*StopContainerRequest) ProtoMessage

func (*StopContainerRequest) ProtoMessage()

func (*StopContainerRequest) ProtoReflect

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

func (*StopContainerRequest) Reset

func (x *StopContainerRequest) Reset()

func (*StopContainerRequest) String

func (x *StopContainerRequest) String() string

type TokenResponse

type TokenResponse struct {
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*TokenResponse) Descriptor deprecated

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

Deprecated: Use TokenResponse.ProtoReflect.Descriptor instead.

func (*TokenResponse) GetToken

func (x *TokenResponse) GetToken() string

func (*TokenResponse) ProtoMessage

func (*TokenResponse) ProtoMessage()

func (*TokenResponse) ProtoReflect

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

func (*TokenResponse) Reset

func (x *TokenResponse) Reset()

func (*TokenResponse) String

func (x *TokenResponse) String() string

type UnimplementedCaddyServer added in v0.12.0

type UnimplementedCaddyServer struct{}

UnimplementedCaddyServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedCaddyServer) GetConfig added in v0.12.0

type UnimplementedClusterServer

type UnimplementedClusterServer struct{}

UnimplementedClusterServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedClusterServer) AddMachine

func (UnimplementedClusterServer) GetDomain

func (UnimplementedClusterServer) ListMachines

func (UnimplementedClusterServer) ReleaseDomain

func (UnimplementedClusterServer) RemoveMachine added in v0.10.0

func (UnimplementedClusterServer) ReserveDomain

func (UnimplementedClusterServer) UpdateMachine added in v0.10.0

type UnimplementedDockerServer

type UnimplementedDockerServer struct{}

UnimplementedDockerServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedDockerServer) CreateContainer

func (UnimplementedDockerServer) CreateVolume added in v0.6.0

func (UnimplementedDockerServer) InspectContainer

func (UnimplementedDockerServer) InspectImage

func (UnimplementedDockerServer) InspectServiceContainer

func (UnimplementedDockerServer) ListContainers

func (UnimplementedDockerServer) ListVolumes added in v0.6.0

func (UnimplementedDockerServer) PullImage

func (UnimplementedDockerServer) RemoveContainer

func (UnimplementedDockerServer) RemoveServiceContainer

func (UnimplementedDockerServer) RemoveVolume added in v0.6.0

func (UnimplementedDockerServer) StartContainer

func (UnimplementedDockerServer) StopContainer

type UnimplementedMachineServer

type UnimplementedMachineServer struct{}

UnimplementedMachineServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedMachineServer) CheckPrerequisites added in v0.7.0

func (UnimplementedMachineServer) InitCluster

func (UnimplementedMachineServer) Inspect

func (UnimplementedMachineServer) InspectService

func (UnimplementedMachineServer) JoinCluster

func (UnimplementedMachineServer) Reset added in v0.9.0

func (UnimplementedMachineServer) Token

type UnsafeCaddyServer added in v0.12.0

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

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

type UnsafeClusterServer

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

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

type UnsafeDockerServer

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

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

type UnsafeMachineServer

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

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

type UpdateMachineRequest added in v0.10.0

type UpdateMachineRequest struct {

	// Machine to update
	MachineId string `protobuf:"bytes,1,opt,name=machine_id,json=machineId,proto3" json:"machine_id,omitempty"`
	// Updated machine information
	Name      *string   `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	PublicIp  *IP       `protobuf:"bytes,3,opt,name=public_ip,json=publicIp,proto3,oneof" json:"public_ip,omitempty"`
	Endpoints []*IPPort `protobuf:"bytes,4,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateMachineRequest) Descriptor deprecated added in v0.10.0

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

Deprecated: Use UpdateMachineRequest.ProtoReflect.Descriptor instead.

func (*UpdateMachineRequest) GetEndpoints added in v0.10.0

func (x *UpdateMachineRequest) GetEndpoints() []*IPPort

func (*UpdateMachineRequest) GetMachineId added in v0.10.0

func (x *UpdateMachineRequest) GetMachineId() string

func (*UpdateMachineRequest) GetName added in v0.10.0

func (x *UpdateMachineRequest) GetName() string

func (*UpdateMachineRequest) GetPublicIp added in v0.10.0

func (x *UpdateMachineRequest) GetPublicIp() *IP

func (*UpdateMachineRequest) ProtoMessage added in v0.10.0

func (*UpdateMachineRequest) ProtoMessage()

func (*UpdateMachineRequest) ProtoReflect added in v0.10.0

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

func (*UpdateMachineRequest) Reset added in v0.10.0

func (x *UpdateMachineRequest) Reset()

func (*UpdateMachineRequest) String added in v0.10.0

func (x *UpdateMachineRequest) String() string

type UpdateMachineResponse added in v0.10.0

type UpdateMachineResponse struct {
	Machine *MachineInfo `protobuf:"bytes,1,opt,name=machine,proto3" json:"machine,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateMachineResponse) Descriptor deprecated added in v0.10.0

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

Deprecated: Use UpdateMachineResponse.ProtoReflect.Descriptor instead.

func (*UpdateMachineResponse) GetMachine added in v0.10.0

func (x *UpdateMachineResponse) GetMachine() *MachineInfo

func (*UpdateMachineResponse) ProtoMessage added in v0.10.0

func (*UpdateMachineResponse) ProtoMessage()

func (*UpdateMachineResponse) ProtoReflect added in v0.10.0

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

func (*UpdateMachineResponse) Reset added in v0.10.0

func (x *UpdateMachineResponse) Reset()

func (*UpdateMachineResponse) String added in v0.10.0

func (x *UpdateMachineResponse) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL