Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterCaddyServer(s grpc.ServiceRegistrar, srv CaddyServer)
- func RegisterCaddyStorageServer(s grpc.ServiceRegistrar, srv CaddyStorageServer)
- func RegisterClusterServer(s grpc.ServiceRegistrar, srv ClusterServer)
- func RegisterDockerServer(s grpc.ServiceRegistrar, srv DockerServer)
- func RegisterMachineServer(s grpc.ServiceRegistrar, srv MachineServer)
- type AddMachineRequest
- func (*AddMachineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddMachineRequest) GetName() string
- func (x *AddMachineRequest) GetNetwork() *NetworkConfig
- func (x *AddMachineRequest) GetPublicIp() *IP
- func (*AddMachineRequest) ProtoMessage()
- func (x *AddMachineRequest) ProtoReflect() protoreflect.Message
- func (x *AddMachineRequest) Reset()
- func (x *AddMachineRequest) String() string
- type AddMachineResponse
- func (*AddMachineResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AddMachineResponse) GetMachine() *MachineInfo
- func (*AddMachineResponse) ProtoMessage()
- func (x *AddMachineResponse) ProtoReflect() protoreflect.Message
- func (x *AddMachineResponse) Reset()
- func (x *AddMachineResponse) String() string
- type CaddyClient
- type CaddyServer
- type CaddyStorageClient
- type CaddyStorageServer
- type CheckPrerequisitesResponse
- func (*CheckPrerequisitesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CheckPrerequisitesResponse) GetError() string
- func (x *CheckPrerequisitesResponse) GetSatisfied() bool
- func (*CheckPrerequisitesResponse) ProtoMessage()
- func (x *CheckPrerequisitesResponse) ProtoReflect() protoreflect.Message
- func (x *CheckPrerequisitesResponse) Reset()
- func (x *CheckPrerequisitesResponse) String() string
- type ClusterClient
- type ClusterServer
- type CreateContainerRequest
- func (*CreateContainerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateContainerRequest) GetConfig() []byte
- func (x *CreateContainerRequest) GetHostConfig() []byte
- func (x *CreateContainerRequest) GetName() string
- func (x *CreateContainerRequest) GetNetworkConfig() []byte
- func (x *CreateContainerRequest) GetPlatform() []byte
- func (*CreateContainerRequest) ProtoMessage()
- func (x *CreateContainerRequest) ProtoReflect() protoreflect.Message
- func (x *CreateContainerRequest) Reset()
- func (x *CreateContainerRequest) String() string
- type CreateContainerResponse
- func (*CreateContainerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateContainerResponse) GetResponse() []byte
- func (*CreateContainerResponse) ProtoMessage()
- func (x *CreateContainerResponse) ProtoReflect() protoreflect.Message
- func (x *CreateContainerResponse) Reset()
- func (x *CreateContainerResponse) String() string
- type CreateDomainRecordsRequest
- func (*CreateDomainRecordsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateDomainRecordsRequest) GetRecords() []*DNSRecord
- func (*CreateDomainRecordsRequest) ProtoMessage()
- func (x *CreateDomainRecordsRequest) ProtoReflect() protoreflect.Message
- func (x *CreateDomainRecordsRequest) Reset()
- func (x *CreateDomainRecordsRequest) String() string
- type CreateDomainRecordsResponse
- func (*CreateDomainRecordsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateDomainRecordsResponse) GetRecords() []*DNSRecord
- func (*CreateDomainRecordsResponse) ProtoMessage()
- func (x *CreateDomainRecordsResponse) ProtoReflect() protoreflect.Message
- func (x *CreateDomainRecordsResponse) Reset()
- func (x *CreateDomainRecordsResponse) String() string
- type CreateServiceContainerRequest
- func (*CreateServiceContainerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateServiceContainerRequest) GetContainerName() string
- func (x *CreateServiceContainerRequest) GetContainerType() CreateServiceContainerRequest_ContainerType
- func (x *CreateServiceContainerRequest) GetServiceId() string
- func (x *CreateServiceContainerRequest) GetServiceSpec() []byte
- func (*CreateServiceContainerRequest) ProtoMessage()
- func (x *CreateServiceContainerRequest) ProtoReflect() protoreflect.Message
- func (x *CreateServiceContainerRequest) Reset()
- func (x *CreateServiceContainerRequest) String() string
- type CreateServiceContainerRequest_ContainerType
- func (CreateServiceContainerRequest_ContainerType) Descriptor() protoreflect.EnumDescriptor
- func (x CreateServiceContainerRequest_ContainerType) Enum() *CreateServiceContainerRequest_ContainerType
- func (CreateServiceContainerRequest_ContainerType) EnumDescriptor() ([]byte, []int)deprecated
- func (x CreateServiceContainerRequest_ContainerType) Number() protoreflect.EnumNumber
- func (x CreateServiceContainerRequest_ContainerType) String() string
- func (CreateServiceContainerRequest_ContainerType) Type() protoreflect.EnumType
- type CreateVolumeRequest
- func (*CreateVolumeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateVolumeRequest) GetOptions() []byte
- func (*CreateVolumeRequest) ProtoMessage()
- func (x *CreateVolumeRequest) ProtoReflect() protoreflect.Message
- func (x *CreateVolumeRequest) Reset()
- func (x *CreateVolumeRequest) String() string
- type CreateVolumeResponse
- func (*CreateVolumeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateVolumeResponse) GetVolume() []byte
- func (*CreateVolumeResponse) ProtoMessage()
- func (x *CreateVolumeResponse) ProtoReflect() protoreflect.Message
- func (x *CreateVolumeResponse) Reset()
- func (x *CreateVolumeResponse) String() string
- type DNSRecord
- func (*DNSRecord) Descriptor() ([]byte, []int)deprecated
- func (x *DNSRecord) GetName() string
- func (x *DNSRecord) GetType() DNSRecord_RecordType
- func (x *DNSRecord) GetValues() []string
- func (*DNSRecord) ProtoMessage()
- func (x *DNSRecord) ProtoReflect() protoreflect.Message
- func (x *DNSRecord) Reset()
- func (x *DNSRecord) String() string
- type DNSRecord_RecordType
- func (DNSRecord_RecordType) Descriptor() protoreflect.EnumDescriptor
- func (x DNSRecord_RecordType) Enum() *DNSRecord_RecordType
- func (DNSRecord_RecordType) EnumDescriptor() ([]byte, []int)deprecated
- func (x DNSRecord_RecordType) Number() protoreflect.EnumNumber
- func (x DNSRecord_RecordType) String() string
- func (DNSRecord_RecordType) Type() protoreflect.EnumType
- type DeleteCaddyStorageRequest
- func (*DeleteCaddyStorageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteCaddyStorageRequest) GetKey() string
- func (*DeleteCaddyStorageRequest) ProtoMessage()
- func (x *DeleteCaddyStorageRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteCaddyStorageRequest) Reset()
- func (x *DeleteCaddyStorageRequest) String() string
- type DockerClient
- type DockerServer
- type Docker_ContainerLogsClient
- type Docker_ContainerLogsServer
- type Docker_ExecContainerClient
- type Docker_ExecContainerServer
- type Docker_PullImageClient
- type Docker_PullImageServer
- type Domain
- type Empty
- type EmptyResponse
- type ExecConfig
- func (*ExecConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ExecConfig) GetContainerId() string
- func (x *ExecConfig) GetOptions() []byte
- func (*ExecConfig) ProtoMessage()
- func (x *ExecConfig) ProtoReflect() protoreflect.Message
- func (x *ExecConfig) Reset()
- func (x *ExecConfig) String() string
- type ExecContainerRequest
- func (*ExecContainerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExecContainerRequest) GetConfig() *ExecConfig
- func (m *ExecContainerRequest) GetPayload() isExecContainerRequest_Payload
- func (x *ExecContainerRequest) GetResize() *ResizeEvent
- func (x *ExecContainerRequest) GetStdin() []byte
- func (*ExecContainerRequest) ProtoMessage()
- func (x *ExecContainerRequest) ProtoReflect() protoreflect.Message
- func (x *ExecContainerRequest) Reset()
- func (x *ExecContainerRequest) String() string
- type ExecContainerRequest_Config
- type ExecContainerRequest_Resize
- type ExecContainerRequest_Stdin
- type ExecContainerResponse
- func (*ExecContainerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ExecContainerResponse) GetExecId() string
- func (x *ExecContainerResponse) GetExitCode() int32
- func (m *ExecContainerResponse) GetPayload() isExecContainerResponse_Payload
- func (x *ExecContainerResponse) GetStderr() []byte
- func (x *ExecContainerResponse) GetStdout() []byte
- func (*ExecContainerResponse) ProtoMessage()
- func (x *ExecContainerResponse) ProtoReflect() protoreflect.Message
- func (x *ExecContainerResponse) Reset()
- func (x *ExecContainerResponse) String() string
- type ExecContainerResponse_ExecId
- type ExecContainerResponse_ExitCode
- type ExecContainerResponse_Stderr
- type ExecContainerResponse_Stdout
- type GetCaddyConfigResponse
- func (*GetCaddyConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetCaddyConfigResponse) GetCaddyfile() string
- func (x *GetCaddyConfigResponse) GetLastReconciliationError() string
- func (x *GetCaddyConfigResponse) GetModifiedAt() *timestamppb.Timestamp
- func (*GetCaddyConfigResponse) ProtoMessage()
- func (x *GetCaddyConfigResponse) ProtoReflect() protoreflect.Message
- func (x *GetCaddyConfigResponse) Reset()
- func (x *GetCaddyConfigResponse) String() string
- type IP
- type IPPort
- func (*IPPort) Descriptor() ([]byte, []int)deprecated
- func (x *IPPort) GetIp() *IP
- func (x *IPPort) GetPort() uint32
- func (*IPPort) ProtoMessage()
- func (x *IPPort) ProtoReflect() protoreflect.Message
- func (x *IPPort) Reset()
- func (x *IPPort) String() string
- func (ipp *IPPort) ToAddrPort() (netip.AddrPort, error)
- type IPPrefix
- func (*IPPrefix) Descriptor() ([]byte, []int)deprecated
- func (x *IPPrefix) GetBits() uint32
- func (x *IPPrefix) GetIp() *IP
- func (*IPPrefix) ProtoMessage()
- func (x *IPPrefix) ProtoReflect() protoreflect.Message
- func (x *IPPrefix) Reset()
- func (x *IPPrefix) String() string
- func (p *IPPrefix) ToPrefix() (netip.Prefix, error)
- type Image
- type InitClusterRequest
- func (*InitClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InitClusterRequest) GetMachineName() string
- func (x *InitClusterRequest) GetNetwork() *IPPrefix
- func (x *InitClusterRequest) GetPublicIp() *IP
- func (x *InitClusterRequest) GetPublicIpAuto() bool
- func (m *InitClusterRequest) GetPublicIpConfig() isInitClusterRequest_PublicIpConfig
- func (x *InitClusterRequest) GetWireguardEndpoints() []*IPPort
- func (x *InitClusterRequest) GetWireguardMtu() int32
- func (x *InitClusterRequest) GetWireguardPort() int32
- func (*InitClusterRequest) ProtoMessage()
- func (x *InitClusterRequest) ProtoReflect() protoreflect.Message
- func (x *InitClusterRequest) Reset()
- func (x *InitClusterRequest) String() string
- type InitClusterRequest_PublicIp
- type InitClusterRequest_PublicIpAuto
- type InitClusterResponse
- func (*InitClusterResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InitClusterResponse) GetMachine() *MachineInfo
- func (*InitClusterResponse) ProtoMessage()
- func (x *InitClusterResponse) ProtoReflect() protoreflect.Message
- func (x *InitClusterResponse) Reset()
- func (x *InitClusterResponse) String() string
- type InspectContainerRequest
- func (*InspectContainerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InspectContainerRequest) GetId() string
- func (*InspectContainerRequest) ProtoMessage()
- func (x *InspectContainerRequest) ProtoReflect() protoreflect.Message
- func (x *InspectContainerRequest) Reset()
- func (x *InspectContainerRequest) String() string
- type InspectContainerResponse
- func (*InspectContainerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InspectContainerResponse) GetResponse() []byte
- func (*InspectContainerResponse) ProtoMessage()
- func (x *InspectContainerResponse) ProtoReflect() protoreflect.Message
- func (x *InspectContainerResponse) Reset()
- func (x *InspectContainerResponse) String() string
- type InspectImageRequest
- func (*InspectImageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InspectImageRequest) GetId() string
- func (*InspectImageRequest) ProtoMessage()
- func (x *InspectImageRequest) ProtoReflect() protoreflect.Message
- func (x *InspectImageRequest) Reset()
- func (x *InspectImageRequest) String() string
- type InspectImageResponse
- func (*InspectImageResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InspectImageResponse) GetMessages() []*Image
- func (*InspectImageResponse) ProtoMessage()
- func (x *InspectImageResponse) ProtoReflect() protoreflect.Message
- func (x *InspectImageResponse) Reset()
- func (x *InspectImageResponse) String() string
- type InspectMachineResponse
- func (*InspectMachineResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InspectMachineResponse) GetMachines() []*MachineDetails
- func (*InspectMachineResponse) ProtoMessage()
- func (x *InspectMachineResponse) ProtoReflect() protoreflect.Message
- func (x *InspectMachineResponse) Reset()
- func (x *InspectMachineResponse) String() string
- type InspectRemoteImageRequest
- func (*InspectRemoteImageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InspectRemoteImageRequest) GetId() string
- func (*InspectRemoteImageRequest) ProtoMessage()
- func (x *InspectRemoteImageRequest) ProtoReflect() protoreflect.Message
- func (x *InspectRemoteImageRequest) Reset()
- func (x *InspectRemoteImageRequest) String() string
- type InspectRemoteImageResponse
- func (*InspectRemoteImageResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InspectRemoteImageResponse) GetMessages() []*RemoteImage
- func (*InspectRemoteImageResponse) ProtoMessage()
- func (x *InspectRemoteImageResponse) ProtoReflect() protoreflect.Message
- func (x *InspectRemoteImageResponse) Reset()
- func (x *InspectRemoteImageResponse) String() string
- type InspectServiceRequest
- func (*InspectServiceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InspectServiceRequest) GetId() string
- func (*InspectServiceRequest) ProtoMessage()
- func (x *InspectServiceRequest) ProtoReflect() protoreflect.Message
- func (x *InspectServiceRequest) Reset()
- func (x *InspectServiceRequest) String() string
- type InspectServiceResponse
- func (*InspectServiceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InspectServiceResponse) GetService() *Service
- func (*InspectServiceResponse) ProtoMessage()
- func (x *InspectServiceResponse) ProtoReflect() protoreflect.Message
- func (x *InspectServiceResponse) Reset()
- func (x *InspectServiceResponse) String() string
- type InspectWireGuardNetworkResponse
- func (*InspectWireGuardNetworkResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InspectWireGuardNetworkResponse) GetInterfaceName() string
- func (x *InspectWireGuardNetworkResponse) GetListenPort() int32
- func (x *InspectWireGuardNetworkResponse) GetPeers() []*WireGuardPeer
- func (x *InspectWireGuardNetworkResponse) GetPublicKey() []byte
- func (*InspectWireGuardNetworkResponse) ProtoMessage()
- func (x *InspectWireGuardNetworkResponse) ProtoReflect() protoreflect.Message
- func (x *InspectWireGuardNetworkResponse) Reset()
- func (x *InspectWireGuardNetworkResponse) String() string
- type IssuedCertificate
- func (*IssuedCertificate) Descriptor() ([]byte, []int)deprecated
- func (x *IssuedCertificate) GetChain() []byte
- func (x *IssuedCertificate) GetIssuerData() []byte
- func (x *IssuedCertificate) GetSan() string
- func (*IssuedCertificate) ProtoMessage()
- func (x *IssuedCertificate) ProtoReflect() protoreflect.Message
- func (x *IssuedCertificate) Reset()
- func (x *IssuedCertificate) String() string
- type JSONMessage
- type JoinClusterRequest
- func (*JoinClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *JoinClusterRequest) GetMachine() *MachineInfo
- func (x *JoinClusterRequest) GetMinStoreVersion() map[string]uint64
- func (x *JoinClusterRequest) GetOtherMachines() []*MachineInfo
- func (x *JoinClusterRequest) GetWireguardMtu() int32
- func (x *JoinClusterRequest) GetWireguardPort() int32
- func (*JoinClusterRequest) ProtoMessage()
- func (x *JoinClusterRequest) ProtoReflect() protoreflect.Message
- func (x *JoinClusterRequest) Reset()
- func (x *JoinClusterRequest) String() string
- type ListCaddyStorageRequest
- func (*ListCaddyStorageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListCaddyStorageRequest) GetPrefix() string
- func (x *ListCaddyStorageRequest) GetRecursive() bool
- func (*ListCaddyStorageRequest) ProtoMessage()
- func (x *ListCaddyStorageRequest) ProtoReflect() protoreflect.Message
- func (x *ListCaddyStorageRequest) Reset()
- func (x *ListCaddyStorageRequest) String() string
- type ListCaddyStorageResponse
- func (*ListCaddyStorageResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListCaddyStorageResponse) GetKeys() []string
- func (*ListCaddyStorageResponse) ProtoMessage()
- func (x *ListCaddyStorageResponse) ProtoReflect() protoreflect.Message
- func (x *ListCaddyStorageResponse) Reset()
- func (x *ListCaddyStorageResponse) String() string
- type ListCertificatesResponse
- func (*ListCertificatesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListCertificatesResponse) GetCertificates() []*IssuedCertificate
- func (*ListCertificatesResponse) ProtoMessage()
- func (x *ListCertificatesResponse) ProtoReflect() protoreflect.Message
- func (x *ListCertificatesResponse) Reset()
- func (x *ListCertificatesResponse) String() string
- type ListContainersRequest
- func (*ListContainersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListContainersRequest) GetOptions() []byte
- func (*ListContainersRequest) ProtoMessage()
- func (x *ListContainersRequest) ProtoReflect() protoreflect.Message
- func (x *ListContainersRequest) Reset()
- func (x *ListContainersRequest) String() string
- type ListContainersResponse
- func (*ListContainersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListContainersResponse) GetMessages() []*MachineContainers
- func (*ListContainersResponse) ProtoMessage()
- func (x *ListContainersResponse) ProtoReflect() protoreflect.Message
- func (x *ListContainersResponse) Reset()
- func (x *ListContainersResponse) String() string
- type ListImagesRequest
- type ListImagesResponse
- func (*ListImagesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListImagesResponse) GetMessages() []*MachineImages
- func (*ListImagesResponse) ProtoMessage()
- func (x *ListImagesResponse) ProtoReflect() protoreflect.Message
- func (x *ListImagesResponse) Reset()
- func (x *ListImagesResponse) String() string
- type ListMachinesResponse
- func (*ListMachinesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListMachinesResponse) GetMachines() []*MachineMember
- func (*ListMachinesResponse) ProtoMessage()
- func (x *ListMachinesResponse) ProtoReflect() protoreflect.Message
- func (x *ListMachinesResponse) Reset()
- func (x *ListMachinesResponse) String() string
- type ListServiceContainersRequest
- func (*ListServiceContainersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListServiceContainersRequest) GetOptions() []byte
- func (x *ListServiceContainersRequest) GetServiceId() string
- func (*ListServiceContainersRequest) ProtoMessage()
- func (x *ListServiceContainersRequest) ProtoReflect() protoreflect.Message
- func (x *ListServiceContainersRequest) Reset()
- func (x *ListServiceContainersRequest) String() string
- type ListServiceContainersResponse
- func (*ListServiceContainersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListServiceContainersResponse) GetMessages() []*MachineServiceContainers
- func (*ListServiceContainersResponse) ProtoMessage()
- func (x *ListServiceContainersResponse) ProtoReflect() protoreflect.Message
- func (x *ListServiceContainersResponse) Reset()
- func (x *ListServiceContainersResponse) String() string
- type ListVolumesRequest
- func (*ListVolumesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListVolumesRequest) GetOptions() []byte
- func (*ListVolumesRequest) ProtoMessage()
- func (x *ListVolumesRequest) ProtoReflect() protoreflect.Message
- func (x *ListVolumesRequest) Reset()
- func (x *ListVolumesRequest) String() string
- type ListVolumesResponse
- func (*ListVolumesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListVolumesResponse) GetMessages() []*MachineVolumes
- func (*ListVolumesResponse) ProtoMessage()
- func (x *ListVolumesResponse) ProtoReflect() protoreflect.Message
- func (x *ListVolumesResponse) Reset()
- func (x *ListVolumesResponse) String() string
- type LoadCaddyStorageRequest
- func (*LoadCaddyStorageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LoadCaddyStorageRequest) GetKey() string
- func (*LoadCaddyStorageRequest) ProtoMessage()
- func (x *LoadCaddyStorageRequest) ProtoReflect() protoreflect.Message
- func (x *LoadCaddyStorageRequest) Reset()
- func (x *LoadCaddyStorageRequest) String() string
- type LoadCaddyStorageResponse
- func (*LoadCaddyStorageResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LoadCaddyStorageResponse) GetUpdatedAt() *timestamppb.Timestamp
- func (x *LoadCaddyStorageResponse) GetValue() []byte
- func (*LoadCaddyStorageResponse) ProtoMessage()
- func (x *LoadCaddyStorageResponse) ProtoReflect() protoreflect.Message
- func (x *LoadCaddyStorageResponse) Reset()
- func (x *LoadCaddyStorageResponse) String() string
- type LogEntry
- func (*LogEntry) Descriptor() ([]byte, []int)deprecated
- func (x *LogEntry) GetMessage() []byte
- func (x *LogEntry) GetStream() LogEntry_StreamType
- func (x *LogEntry) GetTimestamp() *timestamppb.Timestamp
- func (*LogEntry) ProtoMessage()
- func (x *LogEntry) ProtoReflect() protoreflect.Message
- func (x *LogEntry) Reset()
- func (x *LogEntry) String() string
- type LogEntry_StreamType
- func (LogEntry_StreamType) Descriptor() protoreflect.EnumDescriptor
- func (x LogEntry_StreamType) Enum() *LogEntry_StreamType
- func (LogEntry_StreamType) EnumDescriptor() ([]byte, []int)deprecated
- func (x LogEntry_StreamType) Number() protoreflect.EnumNumber
- func (x LogEntry_StreamType) String() string
- func (LogEntry_StreamType) Type() protoreflect.EnumType
- type LogsRequest
- func (*LogsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LogsRequest) GetFollow() bool
- func (x *LogsRequest) GetId() string
- func (x *LogsRequest) GetSince() string
- func (x *LogsRequest) GetTail() int32
- func (x *LogsRequest) GetUntil() string
- func (*LogsRequest) ProtoMessage()
- func (x *LogsRequest) ProtoReflect() protoreflect.Message
- func (x *LogsRequest) Reset()
- func (x *LogsRequest) String() string
- type MachineClient
- type MachineContainers
- func (*MachineContainers) Descriptor() ([]byte, []int)deprecated
- func (x *MachineContainers) GetContainers() []byte
- func (x *MachineContainers) GetMetadata() *Metadata
- func (*MachineContainers) ProtoMessage()
- func (x *MachineContainers) ProtoReflect() protoreflect.Message
- func (x *MachineContainers) Reset()
- func (x *MachineContainers) String() string
- type MachineDetails
- func (*MachineDetails) Descriptor() ([]byte, []int)deprecated
- func (x *MachineDetails) GetMachine() *MachineInfo
- func (x *MachineDetails) GetMetadata() *Metadata
- func (x *MachineDetails) GetRtts() map[string]*RTTStats
- func (x *MachineDetails) GetStoreVersion() map[string]uint64
- func (*MachineDetails) ProtoMessage()
- func (x *MachineDetails) ProtoReflect() protoreflect.Message
- func (x *MachineDetails) Reset()
- func (x *MachineDetails) String() string
- type MachineImages
- func (*MachineImages) Descriptor() ([]byte, []int)deprecated
- func (x *MachineImages) GetContainerdStore() bool
- func (x *MachineImages) GetImages() []byte
- func (x *MachineImages) GetMetadata() *Metadata
- func (*MachineImages) ProtoMessage()
- func (x *MachineImages) ProtoReflect() protoreflect.Message
- func (x *MachineImages) Reset()
- func (x *MachineImages) String() string
- type MachineInfo
- func (*MachineInfo) Descriptor() ([]byte, []int)deprecated
- func (x *MachineInfo) GetArch() string
- func (x *MachineInfo) GetDaemonVersion() string
- func (x *MachineInfo) GetDockerVersion() string
- func (x *MachineInfo) GetHostname() string
- func (x *MachineInfo) GetId() string
- func (x *MachineInfo) GetKernelVersion() string
- func (x *MachineInfo) GetName() string
- func (x *MachineInfo) GetNetwork() *NetworkConfig
- func (x *MachineInfo) GetOsPrettyName() string
- func (x *MachineInfo) GetPublicIp() *IP
- func (*MachineInfo) ProtoMessage()
- func (x *MachineInfo) ProtoReflect() protoreflect.Message
- func (x *MachineInfo) Reset()
- func (x *MachineInfo) String() string
- type MachineMember
- func (*MachineMember) Descriptor() ([]byte, []int)deprecated
- func (x *MachineMember) GetMachine() *MachineInfo
- func (x *MachineMember) GetState() MachineMember_MembershipState
- func (*MachineMember) ProtoMessage()
- func (x *MachineMember) ProtoReflect() protoreflect.Message
- func (x *MachineMember) Reset()
- func (x *MachineMember) String() string
- type MachineMember_MembershipState
- func (MachineMember_MembershipState) Descriptor() protoreflect.EnumDescriptor
- func (x MachineMember_MembershipState) Enum() *MachineMember_MembershipState
- func (MachineMember_MembershipState) EnumDescriptor() ([]byte, []int)deprecated
- func (x MachineMember_MembershipState) Number() protoreflect.EnumNumber
- func (x MachineMember_MembershipState) String() string
- func (MachineMember_MembershipState) Type() protoreflect.EnumType
- type MachineServer
- type MachineServiceContainers
- func (*MachineServiceContainers) Descriptor() ([]byte, []int)deprecated
- func (x *MachineServiceContainers) GetContainers() []*ServiceContainer
- func (x *MachineServiceContainers) GetHookContainers() []*ServiceContainer
- func (x *MachineServiceContainers) GetMetadata() *Metadata
- func (*MachineServiceContainers) ProtoMessage()
- func (x *MachineServiceContainers) ProtoReflect() protoreflect.Message
- func (x *MachineServiceContainers) Reset()
- func (x *MachineServiceContainers) String() string
- type MachineVolumes
- func (*MachineVolumes) Descriptor() ([]byte, []int)deprecated
- func (x *MachineVolumes) GetMetadata() *Metadata
- func (x *MachineVolumes) GetResponse() []byte
- func (*MachineVolumes) ProtoMessage()
- func (x *MachineVolumes) ProtoReflect() protoreflect.Message
- func (x *MachineVolumes) Reset()
- func (x *MachineVolumes) String() string
- type Machine_MachineLogsClient
- type Machine_MachineLogsServer
- type Metadata
- func (*Metadata) Descriptor() ([]byte, []int)deprecated
- func (x *Metadata) GetError() string
- func (x *Metadata) GetMachineAddr() string
- func (x *Metadata) GetMachineId() string
- func (x *Metadata) GetMachineName() string
- func (x *Metadata) GetStatus() *status.Status
- func (*Metadata) ProtoMessage()
- func (x *Metadata) ProtoReflect() protoreflect.Message
- func (x *Metadata) Reset()
- func (x *Metadata) String() string
- type NetworkConfig
- func (*NetworkConfig) Descriptor() ([]byte, []int)deprecated
- func (x *NetworkConfig) GetEndpoints() []*IPPort
- func (x *NetworkConfig) GetManagementIp() *IP
- func (x *NetworkConfig) GetPublicKey() []byte
- func (x *NetworkConfig) GetSubnet() *IPPrefix
- func (*NetworkConfig) ProtoMessage()
- func (x *NetworkConfig) ProtoReflect() protoreflect.Message
- func (x *NetworkConfig) Reset()
- func (x *NetworkConfig) String() string
- func (c *NetworkConfig) Validate() error
- type PullImageRequest
- func (*PullImageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PullImageRequest) GetImage() string
- func (x *PullImageRequest) GetOptions() []byte
- func (*PullImageRequest) ProtoMessage()
- func (x *PullImageRequest) ProtoReflect() protoreflect.Message
- func (x *PullImageRequest) Reset()
- func (x *PullImageRequest) String() string
- type RTTStats
- func (*RTTStats) Descriptor() ([]byte, []int)deprecated
- func (x *RTTStats) GetMedian() *durationpb.Duration
- func (x *RTTStats) GetStdDev() *durationpb.Duration
- func (*RTTStats) ProtoMessage()
- func (x *RTTStats) ProtoReflect() protoreflect.Message
- func (x *RTTStats) Reset()
- func (x *RTTStats) String() string
- type RemoteImage
- func (*RemoteImage) Descriptor() ([]byte, []int)deprecated
- func (x *RemoteImage) GetManifest() []byte
- func (x *RemoteImage) GetMetadata() *Metadata
- func (x *RemoteImage) GetReference() string
- func (*RemoteImage) ProtoMessage()
- func (x *RemoteImage) ProtoReflect() protoreflect.Message
- func (x *RemoteImage) Reset()
- func (x *RemoteImage) String() string
- type RemoveContainerRequest
- func (*RemoveContainerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveContainerRequest) GetId() string
- func (x *RemoveContainerRequest) GetOptions() []byte
- func (*RemoveContainerRequest) ProtoMessage()
- func (x *RemoveContainerRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveContainerRequest) Reset()
- func (x *RemoveContainerRequest) String() string
- type RemoveMachineRequest
- func (*RemoveMachineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveMachineRequest) GetId() string
- func (*RemoveMachineRequest) ProtoMessage()
- func (x *RemoveMachineRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveMachineRequest) Reset()
- func (x *RemoveMachineRequest) String() string
- type RemoveVolumeRequest
- func (*RemoveVolumeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveVolumeRequest) GetForce() bool
- func (x *RemoveVolumeRequest) GetId() string
- func (*RemoveVolumeRequest) ProtoMessage()
- func (x *RemoveVolumeRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveVolumeRequest) Reset()
- func (x *RemoveVolumeRequest) String() string
- type ReserveDomainRequest
- func (*ReserveDomainRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReserveDomainRequest) GetEndpoint() string
- func (*ReserveDomainRequest) ProtoMessage()
- func (x *ReserveDomainRequest) ProtoReflect() protoreflect.Message
- func (x *ReserveDomainRequest) Reset()
- func (x *ReserveDomainRequest) String() string
- type ResetRequest
- type ResizeEvent
- func (*ResizeEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ResizeEvent) GetHeight() uint32
- func (x *ResizeEvent) GetWidth() uint32
- func (*ResizeEvent) ProtoMessage()
- func (x *ResizeEvent) ProtoReflect() protoreflect.Message
- func (x *ResizeEvent) Reset()
- func (x *ResizeEvent) String() string
- type Service
- func (*Service) Descriptor() ([]byte, []int)deprecated
- func (x *Service) GetContainers() []*Service_Container
- func (x *Service) GetId() string
- func (x *Service) GetMode() string
- func (x *Service) GetName() string
- func (*Service) ProtoMessage()
- func (x *Service) ProtoReflect() protoreflect.Message
- func (x *Service) Reset()
- func (x *Service) String() string
- type ServiceContainer
- func (*ServiceContainer) Descriptor() ([]byte, []int)deprecated
- func (x *ServiceContainer) GetContainer() []byte
- func (x *ServiceContainer) GetServiceSpec() []byte
- func (*ServiceContainer) ProtoMessage()
- func (x *ServiceContainer) ProtoReflect() protoreflect.Message
- func (x *ServiceContainer) Reset()
- func (x *ServiceContainer) String() string
- type Service_Container
- func (*Service_Container) Descriptor() ([]byte, []int)deprecated
- func (x *Service_Container) GetContainer() []byte
- func (x *Service_Container) GetMachineId() string
- func (*Service_Container) ProtoMessage()
- func (x *Service_Container) ProtoReflect() protoreflect.Message
- func (x *Service_Container) Reset()
- func (x *Service_Container) String() string
- type SetDomainRequest
- type StartContainerRequest
- func (*StartContainerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartContainerRequest) GetId() string
- func (x *StartContainerRequest) GetOptions() []byte
- func (*StartContainerRequest) ProtoMessage()
- func (x *StartContainerRequest) ProtoReflect() protoreflect.Message
- func (x *StartContainerRequest) Reset()
- func (x *StartContainerRequest) String() string
- type StatCaddyStorageRequest
- func (*StatCaddyStorageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StatCaddyStorageRequest) GetKey() string
- func (*StatCaddyStorageRequest) ProtoMessage()
- func (x *StatCaddyStorageRequest) ProtoReflect() protoreflect.Message
- func (x *StatCaddyStorageRequest) Reset()
- func (x *StatCaddyStorageRequest) String() string
- type StatCaddyStorageResponse
- func (*StatCaddyStorageResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StatCaddyStorageResponse) GetIsTerminal() bool
- func (x *StatCaddyStorageResponse) GetKey() string
- func (x *StatCaddyStorageResponse) GetSize() int64
- func (x *StatCaddyStorageResponse) GetUpdatedAt() *timestamppb.Timestamp
- func (*StatCaddyStorageResponse) ProtoMessage()
- func (x *StatCaddyStorageResponse) ProtoReflect() protoreflect.Message
- func (x *StatCaddyStorageResponse) Reset()
- func (x *StatCaddyStorageResponse) String() string
- type StopContainerRequest
- func (*StopContainerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StopContainerRequest) GetId() string
- func (x *StopContainerRequest) GetOptions() []byte
- func (*StopContainerRequest) ProtoMessage()
- func (x *StopContainerRequest) ProtoReflect() protoreflect.Message
- func (x *StopContainerRequest) Reset()
- func (x *StopContainerRequest) String() string
- type StoreCaddyStorageRequest
- func (*StoreCaddyStorageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StoreCaddyStorageRequest) GetKey() string
- func (x *StoreCaddyStorageRequest) GetValue() []byte
- func (*StoreCaddyStorageRequest) ProtoMessage()
- func (x *StoreCaddyStorageRequest) ProtoReflect() protoreflect.Message
- func (x *StoreCaddyStorageRequest) Reset()
- func (x *StoreCaddyStorageRequest) String() string
- type TokenResponse
- type UnimplementedCaddyServer
- type UnimplementedCaddyStorageServer
- func (UnimplementedCaddyStorageServer) Delete(context.Context, *DeleteCaddyStorageRequest) (*emptypb.Empty, error)
- func (UnimplementedCaddyStorageServer) List(context.Context, *ListCaddyStorageRequest) (*ListCaddyStorageResponse, error)
- func (UnimplementedCaddyStorageServer) ListCertificates(context.Context, *emptypb.Empty) (*ListCertificatesResponse, error)
- func (UnimplementedCaddyStorageServer) Load(context.Context, *LoadCaddyStorageRequest) (*LoadCaddyStorageResponse, error)
- func (UnimplementedCaddyStorageServer) Stat(context.Context, *StatCaddyStorageRequest) (*StatCaddyStorageResponse, error)
- func (UnimplementedCaddyStorageServer) Store(context.Context, *StoreCaddyStorageRequest) (*emptypb.Empty, error)
- type UnimplementedClusterServer
- func (UnimplementedClusterServer) AddMachine(context.Context, *AddMachineRequest) (*AddMachineResponse, error)
- func (UnimplementedClusterServer) CreateDomainRecords(context.Context, *CreateDomainRecordsRequest) (*CreateDomainRecordsResponse, error)
- func (UnimplementedClusterServer) GetDomain(context.Context, *emptypb.Empty) (*Domain, error)
- func (UnimplementedClusterServer) ListMachines(context.Context, *emptypb.Empty) (*ListMachinesResponse, error)
- func (UnimplementedClusterServer) ReleaseDomain(context.Context, *emptypb.Empty) (*Domain, error)
- func (UnimplementedClusterServer) RemoveMachine(context.Context, *RemoveMachineRequest) (*emptypb.Empty, error)
- func (UnimplementedClusterServer) ReserveDomain(context.Context, *ReserveDomainRequest) (*Domain, error)
- func (UnimplementedClusterServer) SetDomain(context.Context, *SetDomainRequest) (*emptypb.Empty, error)
- type UnimplementedDockerServer
- func (UnimplementedDockerServer) ContainerLogs(*LogsRequest, grpc.ServerStreamingServer[LogEntry]) error
- func (UnimplementedDockerServer) CreateContainer(context.Context, *CreateContainerRequest) (*CreateContainerResponse, error)
- func (UnimplementedDockerServer) CreateServiceContainer(context.Context, *CreateServiceContainerRequest) (*CreateContainerResponse, error)
- func (UnimplementedDockerServer) CreateVolume(context.Context, *CreateVolumeRequest) (*CreateVolumeResponse, error)
- func (UnimplementedDockerServer) ExecContainer(grpc.BidiStreamingServer[ExecContainerRequest, ExecContainerResponse]) error
- func (UnimplementedDockerServer) InspectContainer(context.Context, *InspectContainerRequest) (*InspectContainerResponse, error)
- func (UnimplementedDockerServer) InspectImage(context.Context, *InspectImageRequest) (*InspectImageResponse, error)
- func (UnimplementedDockerServer) InspectRemoteImage(context.Context, *InspectRemoteImageRequest) (*InspectRemoteImageResponse, error)
- func (UnimplementedDockerServer) InspectServiceContainer(context.Context, *InspectContainerRequest) (*ServiceContainer, error)
- func (UnimplementedDockerServer) ListContainers(context.Context, *ListContainersRequest) (*ListContainersResponse, error)
- func (UnimplementedDockerServer) ListImages(context.Context, *ListImagesRequest) (*ListImagesResponse, error)
- func (UnimplementedDockerServer) ListServiceContainers(context.Context, *ListServiceContainersRequest) (*ListServiceContainersResponse, error)
- func (UnimplementedDockerServer) ListVolumes(context.Context, *ListVolumesRequest) (*ListVolumesResponse, error)
- func (UnimplementedDockerServer) PullImage(*PullImageRequest, grpc.ServerStreamingServer[JSONMessage]) error
- func (UnimplementedDockerServer) RemoveContainer(context.Context, *RemoveContainerRequest) (*emptypb.Empty, error)
- func (UnimplementedDockerServer) RemoveServiceContainer(context.Context, *RemoveContainerRequest) (*emptypb.Empty, error)
- func (UnimplementedDockerServer) RemoveVolume(context.Context, *RemoveVolumeRequest) (*emptypb.Empty, error)
- func (UnimplementedDockerServer) StartContainer(context.Context, *StartContainerRequest) (*emptypb.Empty, error)
- func (UnimplementedDockerServer) StopContainer(context.Context, *StopContainerRequest) (*emptypb.Empty, error)
- type UnimplementedMachineServer
- func (UnimplementedMachineServer) CheckPrerequisites(context.Context, *emptypb.Empty) (*CheckPrerequisitesResponse, error)
- func (UnimplementedMachineServer) InitCluster(context.Context, *InitClusterRequest) (*InitClusterResponse, error)
- func (UnimplementedMachineServer) Inspect(context.Context, *emptypb.Empty) (*MachineInfo, error)
- func (UnimplementedMachineServer) InspectMachine(context.Context, *emptypb.Empty) (*InspectMachineResponse, error)
- func (UnimplementedMachineServer) InspectService(context.Context, *InspectServiceRequest) (*InspectServiceResponse, error)
- func (UnimplementedMachineServer) InspectWireGuardNetwork(context.Context, *emptypb.Empty) (*InspectWireGuardNetworkResponse, error)
- func (UnimplementedMachineServer) JoinCluster(context.Context, *JoinClusterRequest) (*emptypb.Empty, error)
- func (UnimplementedMachineServer) MachineLogs(*LogsRequest, grpc.ServerStreamingServer[LogEntry]) error
- func (UnimplementedMachineServer) Reset(context.Context, *ResetRequest) (*emptypb.Empty, error)
- func (UnimplementedMachineServer) Token(context.Context, *emptypb.Empty) (*TokenResponse, error)
- func (UnimplementedMachineServer) UpdateMachine(context.Context, *UpdateMachineRequest) (*UpdateMachineResponse, error)
- func (UnimplementedMachineServer) WaitForStoreVersion(context.Context, *WaitForStoreVersionRequest) (*emptypb.Empty, error)
- type UnsafeCaddyServer
- type UnsafeCaddyStorageServer
- type UnsafeClusterServer
- type UnsafeDockerServer
- type UnsafeMachineServer
- type UpdateMachineRequest
- func (*UpdateMachineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateMachineRequest) GetEndpoints() []*IPPort
- func (x *UpdateMachineRequest) GetName() string
- func (x *UpdateMachineRequest) GetPublicIp() *IP
- func (*UpdateMachineRequest) ProtoMessage()
- func (x *UpdateMachineRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateMachineRequest) Reset()
- func (x *UpdateMachineRequest) String() string
- type UpdateMachineResponse
- func (*UpdateMachineResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateMachineResponse) GetMachine() *MachineInfo
- func (*UpdateMachineResponse) ProtoMessage()
- func (x *UpdateMachineResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateMachineResponse) Reset()
- func (x *UpdateMachineResponse) String() string
- type WaitForStoreVersionRequest
- func (*WaitForStoreVersionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WaitForStoreVersionRequest) GetMinVersion() map[string]uint64
- func (*WaitForStoreVersionRequest) ProtoMessage()
- func (x *WaitForStoreVersionRequest) ProtoReflect() protoreflect.Message
- func (x *WaitForStoreVersionRequest) Reset()
- func (x *WaitForStoreVersionRequest) String() string
- type WireGuardPeer
- func (*WireGuardPeer) Descriptor() ([]byte, []int)deprecated
- func (x *WireGuardPeer) GetAllowedIps() []string
- func (x *WireGuardPeer) GetEndpoint() string
- func (x *WireGuardPeer) GetLastHandshakeTime() *timestamppb.Timestamp
- func (x *WireGuardPeer) GetPublicKey() []byte
- func (x *WireGuardPeer) GetReceiveBytes() int64
- func (x *WireGuardPeer) GetTransmitBytes() int64
- func (*WireGuardPeer) ProtoMessage()
- func (x *WireGuardPeer) ProtoReflect() protoreflect.Message
- func (x *WireGuardPeer) Reset()
- func (x *WireGuardPeer) String() string
Constants ¶
const ( CaddyStorage_Store_FullMethodName = "/api.CaddyStorage/Store" CaddyStorage_Load_FullMethodName = "/api.CaddyStorage/Load" CaddyStorage_Delete_FullMethodName = "/api.CaddyStorage/Delete" CaddyStorage_List_FullMethodName = "/api.CaddyStorage/List" CaddyStorage_Stat_FullMethodName = "/api.CaddyStorage/Stat" CaddyStorage_ListCertificates_FullMethodName = "/api.CaddyStorage/ListCertificates" )
const ( Cluster_AddMachine_FullMethodName = "/api.Cluster/AddMachine" Cluster_ListMachines_FullMethodName = "/api.Cluster/ListMachines" Cluster_RemoveMachine_FullMethodName = "/api.Cluster/RemoveMachine" Cluster_ReserveDomain_FullMethodName = "/api.Cluster/ReserveDomain" Cluster_SetDomain_FullMethodName = "/api.Cluster/SetDomain" Cluster_GetDomain_FullMethodName = "/api.Cluster/GetDomain" Cluster_ReleaseDomain_FullMethodName = "/api.Cluster/ReleaseDomain" Cluster_CreateDomainRecords_FullMethodName = "/api.Cluster/CreateDomainRecords" )
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_ExecContainer_FullMethodName = "/api.Docker/ExecContainer" Docker_ContainerLogs_FullMethodName = "/api.Docker/ContainerLogs" Docker_PullImage_FullMethodName = "/api.Docker/PullImage" Docker_InspectImage_FullMethodName = "/api.Docker/InspectImage" Docker_InspectRemoteImage_FullMethodName = "/api.Docker/InspectRemoteImage" Docker_ListImages_FullMethodName = "/api.Docker/ListImages" 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" )
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_InspectMachine_FullMethodName = "/api.Machine/InspectMachine" Machine_WaitForStoreVersion_FullMethodName = "/api.Machine/WaitForStoreVersion" Machine_UpdateMachine_FullMethodName = "/api.Machine/UpdateMachine" Machine_InspectWireGuardNetwork_FullMethodName = "/api.Machine/InspectWireGuardNetwork" Machine_Reset_FullMethodName = "/api.Machine/Reset" Machine_InspectService_FullMethodName = "/api.Machine/InspectService" Machine_MachineLogs_FullMethodName = "/api.Machine/MachineLogs" )
const (
Caddy_GetConfig_FullMethodName = "/api.Caddy/GetConfig"
)
const KeyLen = 32
KeyLen is the expected key length for a WireGuard public or private key.
Variables ¶
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.
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.
var ( LogEntry_StreamType_name = map[int32]string{ 0: "UNKNOWN", 1: "STDOUT", 2: "STDERR", 3: "HEARTBEAT", } LogEntry_StreamType_value = map[string]int32{ "UNKNOWN": 0, "STDOUT": 1, "STDERR": 2, "HEARTBEAT": 3, } )
Enum value maps for LogEntry_StreamType.
var ( CreateServiceContainerRequest_ContainerType_name = map[int32]string{ 0: "SERVICE", 1: "PRE_DEPLOY", } CreateServiceContainerRequest_ContainerType_value = map[string]int32{ "SERVICE": 0, "PRE_DEPLOY": 1, } )
Enum value maps for CreateServiceContainerRequest_ContainerType.
var CaddyStorage_ServiceDesc = grpc.ServiceDesc{ ServiceName: "api.CaddyStorage", HandlerType: (*CaddyStorageServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Store", Handler: _CaddyStorage_Store_Handler, }, { MethodName: "Load", Handler: _CaddyStorage_Load_Handler, }, { MethodName: "Delete", Handler: _CaddyStorage_Delete_Handler, }, { MethodName: "List", Handler: _CaddyStorage_List_Handler, }, { MethodName: "Stat", Handler: _CaddyStorage_Stat_Handler, }, { MethodName: "ListCertificates", Handler: _CaddyStorage_ListCertificates_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "api/pb/caddy_storage.proto", }
CaddyStorage_ServiceDesc is the grpc.ServiceDesc for CaddyStorage service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Caddy_ServiceDesc = grpc.ServiceDesc{ ServiceName: "api.Caddy", HandlerType: (*CaddyServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetConfig", Handler: _Caddy_GetConfig_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "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)
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: "RemoveMachine", Handler: _Cluster_RemoveMachine_Handler, }, { MethodName: "ReserveDomain", Handler: _Cluster_ReserveDomain_Handler, }, { MethodName: "SetDomain", Handler: _Cluster_SetDomain_Handler, }, { MethodName: "GetDomain", Handler: _Cluster_GetDomain_Handler, }, { MethodName: "ReleaseDomain", Handler: _Cluster_ReleaseDomain_Handler, }, { MethodName: "CreateDomainRecords", Handler: _Cluster_CreateDomainRecords_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "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)
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: "ListImages", Handler: _Docker_ListImages_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: "ExecContainer", Handler: _Docker_ExecContainer_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "ContainerLogs", Handler: _Docker_ContainerLogs_Handler, ServerStreams: true, }, { StreamName: "PullImage", Handler: _Docker_PullImage_Handler, ServerStreams: true, }, }, Metadata: "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)
var File_api_pb_caddy_proto protoreflect.FileDescriptor
var File_api_pb_caddy_storage_proto protoreflect.FileDescriptor
var File_api_pb_cluster_proto protoreflect.FileDescriptor
var File_api_pb_common_proto protoreflect.FileDescriptor
var File_api_pb_docker_proto protoreflect.FileDescriptor
var File_api_pb_machine_proto protoreflect.FileDescriptor
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: "InspectMachine", Handler: _Machine_InspectMachine_Handler, }, { MethodName: "WaitForStoreVersion", Handler: _Machine_WaitForStoreVersion_Handler, }, { MethodName: "UpdateMachine", Handler: _Machine_UpdateMachine_Handler, }, { MethodName: "InspectWireGuardNetwork", Handler: _Machine_InspectWireGuardNetwork_Handler, }, { MethodName: "Reset", Handler: _Machine_Reset_Handler, }, { MethodName: "InspectService", Handler: _Machine_InspectService_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "MachineLogs", Handler: _Machine_MachineLogs_Handler, ServerStreams: true, }, }, Metadata: "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 ¶
func RegisterCaddyServer(s grpc.ServiceRegistrar, srv CaddyServer)
func RegisterCaddyStorageServer ¶
func RegisterCaddyStorageServer(s grpc.ServiceRegistrar, srv CaddyStorageServer)
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 ¶
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 ¶
func NewCaddyClient(cc grpc.ClientConnInterface) CaddyClient
type CaddyServer ¶
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 CaddyStorageClient ¶
type CaddyStorageClient interface {
Store(ctx context.Context, in *StoreCaddyStorageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
Load(ctx context.Context, in *LoadCaddyStorageRequest, opts ...grpc.CallOption) (*LoadCaddyStorageResponse, error)
Delete(ctx context.Context, in *DeleteCaddyStorageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
List(ctx context.Context, in *ListCaddyStorageRequest, opts ...grpc.CallOption) (*ListCaddyStorageResponse, error)
Stat(ctx context.Context, in *StatCaddyStorageRequest, opts ...grpc.CallOption) (*StatCaddyStorageResponse, error)
// ListCertificates lists certificates issued by Caddy and stored in the cluster store.
// Unreadable entries and invalid resource metadata are skipped. Chains and issuer data are returned as stored.
ListCertificates(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListCertificatesResponse, error)
}
CaddyStorageClient is the client API for CaddyStorage 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.
CaddyStorage exposes the CertMagic storage operations backed by the distributed cluster store. Each request operates on the receiving machine's store replica. Callers that need replication to catch up before reading should capture store versions with Machine.InspectMachine and call Machine.WaitForStoreVersion on the receiving machine, subject to that RPC's data-availability limitations (see WaitForStoreVersion docs). See Storage interface in https://github.com/caddyserver/certmagic/blob/master/storage.go.
func NewCaddyStorageClient ¶
func NewCaddyStorageClient(cc grpc.ClientConnInterface) CaddyStorageClient
type CaddyStorageServer ¶
type CaddyStorageServer interface {
Store(context.Context, *StoreCaddyStorageRequest) (*emptypb.Empty, error)
Load(context.Context, *LoadCaddyStorageRequest) (*LoadCaddyStorageResponse, error)
Delete(context.Context, *DeleteCaddyStorageRequest) (*emptypb.Empty, error)
List(context.Context, *ListCaddyStorageRequest) (*ListCaddyStorageResponse, error)
Stat(context.Context, *StatCaddyStorageRequest) (*StatCaddyStorageResponse, error)
// ListCertificates lists certificates issued by Caddy and stored in the cluster store.
// Unreadable entries and invalid resource metadata are skipped. Chains and issuer data are returned as stored.
ListCertificates(context.Context, *emptypb.Empty) (*ListCertificatesResponse, error)
// contains filtered or unexported methods
}
CaddyStorageServer is the server API for CaddyStorage service. All implementations must embed UnimplementedCaddyStorageServer for forward compatibility.
CaddyStorage exposes the CertMagic storage operations backed by the distributed cluster store. Each request operates on the receiving machine's store replica. Callers that need replication to catch up before reading should capture store versions with Machine.InspectMachine and call Machine.WaitForStoreVersion on the receiving machine, subject to that RPC's data-availability limitations (see WaitForStoreVersion docs). See Storage interface in https://github.com/caddyserver/certmagic/blob/master/storage.go.
type CheckPrerequisitesResponse ¶
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
func (*CheckPrerequisitesResponse) Descriptor() ([]byte, []int)
Deprecated: Use CheckPrerequisitesResponse.ProtoReflect.Descriptor instead.
func (*CheckPrerequisitesResponse) GetError ¶
func (x *CheckPrerequisitesResponse) GetError() string
func (*CheckPrerequisitesResponse) GetSatisfied ¶
func (x *CheckPrerequisitesResponse) GetSatisfied() bool
func (*CheckPrerequisitesResponse) ProtoMessage ¶
func (*CheckPrerequisitesResponse) ProtoMessage()
func (*CheckPrerequisitesResponse) ProtoReflect ¶
func (x *CheckPrerequisitesResponse) ProtoReflect() protoreflect.Message
func (*CheckPrerequisitesResponse) Reset ¶
func (x *CheckPrerequisitesResponse) Reset()
func (*CheckPrerequisitesResponse) String ¶
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)
RemoveMachine(ctx context.Context, in *RemoveMachineRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
ReserveDomain(ctx context.Context, in *ReserveDomainRequest, opts ...grpc.CallOption) (*Domain, error)
SetDomain(ctx context.Context, in *SetDomainRequest, opts ...grpc.CallOption) (*emptypb.Empty, 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)
RemoveMachine(context.Context, *RemoveMachineRequest) (*emptypb.Empty, error)
ReserveDomain(context.Context, *ReserveDomainRequest) (*Domain, error)
SetDomain(context.Context, *SetDomainRequest) (*emptypb.Empty, 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 (x *CreateDomainRecordsRequest) ProtoReflect() protoreflect.Message
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 (x *CreateDomainRecordsResponse) ProtoReflect() protoreflect.Message
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"`
ContainerType CreateServiceContainerRequest_ContainerType `` /* 154-byte string literal not displayed */
// 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) GetContainerType ¶
func (x *CreateServiceContainerRequest) GetContainerType() CreateServiceContainerRequest_ContainerType
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 (x *CreateServiceContainerRequest) ProtoReflect() protoreflect.Message
func (*CreateServiceContainerRequest) Reset ¶
func (x *CreateServiceContainerRequest) Reset()
func (*CreateServiceContainerRequest) String ¶
func (x *CreateServiceContainerRequest) String() string
type CreateServiceContainerRequest_ContainerType ¶
type CreateServiceContainerRequest_ContainerType int32
ContainerType specifies the purpose of the container being created.
const ( // SERVICE is the default type for long-running service containers. CreateServiceContainerRequest_SERVICE CreateServiceContainerRequest_ContainerType = 0 // PRE_DEPLOY is a one-shot container for a pre-deploy hook to run before service deployment. CreateServiceContainerRequest_PRE_DEPLOY CreateServiceContainerRequest_ContainerType = 1 )
func (CreateServiceContainerRequest_ContainerType) Descriptor ¶
func (CreateServiceContainerRequest_ContainerType) Descriptor() protoreflect.EnumDescriptor
func (CreateServiceContainerRequest_ContainerType) EnumDescriptor
deprecated
func (CreateServiceContainerRequest_ContainerType) EnumDescriptor() ([]byte, []int)
Deprecated: Use CreateServiceContainerRequest_ContainerType.Descriptor instead.
func (CreateServiceContainerRequest_ContainerType) Number ¶
func (x CreateServiceContainerRequest_ContainerType) Number() protoreflect.EnumNumber
func (CreateServiceContainerRequest_ContainerType) String ¶
func (x CreateServiceContainerRequest_ContainerType) String() string
func (CreateServiceContainerRequest_ContainerType) Type ¶
func (CreateServiceContainerRequest_ContainerType) Type() protoreflect.EnumType
type CreateVolumeRequest ¶
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
func (*CreateVolumeRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateVolumeRequest.ProtoReflect.Descriptor instead.
func (*CreateVolumeRequest) GetOptions ¶
func (x *CreateVolumeRequest) GetOptions() []byte
func (*CreateVolumeRequest) ProtoMessage ¶
func (*CreateVolumeRequest) ProtoMessage()
func (*CreateVolumeRequest) ProtoReflect ¶
func (x *CreateVolumeRequest) ProtoReflect() protoreflect.Message
func (*CreateVolumeRequest) Reset ¶
func (x *CreateVolumeRequest) Reset()
func (*CreateVolumeRequest) String ¶
func (x *CreateVolumeRequest) String() string
type CreateVolumeResponse ¶
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
func (*CreateVolumeResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateVolumeResponse.ProtoReflect.Descriptor instead.
func (*CreateVolumeResponse) GetVolume ¶
func (x *CreateVolumeResponse) GetVolume() []byte
func (*CreateVolumeResponse) ProtoMessage ¶
func (*CreateVolumeResponse) ProtoMessage()
func (*CreateVolumeResponse) ProtoReflect ¶
func (x *CreateVolumeResponse) ProtoReflect() protoreflect.Message
func (*CreateVolumeResponse) Reset ¶
func (x *CreateVolumeResponse) Reset()
func (*CreateVolumeResponse) String ¶
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) GetType ¶
func (x *DNSRecord) GetType() DNSRecord_RecordType
func (*DNSRecord) ProtoMessage ¶
func (*DNSRecord) ProtoMessage()
func (*DNSRecord) ProtoReflect ¶
func (x *DNSRecord) ProtoReflect() protoreflect.Message
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) Descriptor() protoreflect.EnumDescriptor
func (DNSRecord_RecordType) Enum ¶
func (x DNSRecord_RecordType) Enum() *DNSRecord_RecordType
func (DNSRecord_RecordType) EnumDescriptor
deprecated
func (DNSRecord_RecordType) EnumDescriptor() ([]byte, []int)
Deprecated: Use DNSRecord_RecordType.Descriptor instead.
func (DNSRecord_RecordType) Number ¶
func (x DNSRecord_RecordType) Number() protoreflect.EnumNumber
func (DNSRecord_RecordType) String ¶
func (x DNSRecord_RecordType) String() string
func (DNSRecord_RecordType) Type ¶
func (DNSRecord_RecordType) Type() protoreflect.EnumType
type DeleteCaddyStorageRequest ¶
type DeleteCaddyStorageRequest struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteCaddyStorageRequest) Descriptor
deprecated
func (*DeleteCaddyStorageRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteCaddyStorageRequest.ProtoReflect.Descriptor instead.
func (*DeleteCaddyStorageRequest) GetKey ¶
func (x *DeleteCaddyStorageRequest) GetKey() string
func (*DeleteCaddyStorageRequest) ProtoMessage ¶
func (*DeleteCaddyStorageRequest) ProtoMessage()
func (*DeleteCaddyStorageRequest) ProtoReflect ¶
func (x *DeleteCaddyStorageRequest) ProtoReflect() protoreflect.Message
func (*DeleteCaddyStorageRequest) Reset ¶
func (x *DeleteCaddyStorageRequest) Reset()
func (*DeleteCaddyStorageRequest) String ¶
func (x *DeleteCaddyStorageRequest) String() string
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)
ExecContainer(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ExecContainerRequest, ExecContainerResponse], error)
ContainerLogs(ctx context.Context, in *LogsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[LogEntry], 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)
ListImages(ctx context.Context, in *ListImagesRequest, opts ...grpc.CallOption) (*ListImagesResponse, 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)
ExecContainer(grpc.BidiStreamingServer[ExecContainerRequest, ExecContainerResponse]) error
ContainerLogs(*LogsRequest, grpc.ServerStreamingServer[LogEntry]) 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)
ListImages(context.Context, *ListImagesRequest) (*ListImagesResponse, 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_ContainerLogsClient ¶
type Docker_ContainerLogsClient = grpc.ServerStreamingClient[LogEntry]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Docker_ContainerLogsServer ¶
type Docker_ContainerLogsServer = grpc.ServerStreamingServer[LogEntry]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Docker_ExecContainerClient ¶
type Docker_ExecContainerClient = grpc.BidiStreamingClient[ExecContainerRequest, ExecContainerResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Docker_ExecContainerServer ¶
type Docker_ExecContainerServer = grpc.BidiStreamingServer[ExecContainerRequest, ExecContainerResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
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"`
// Whether the domain is reserved in Uncloud DNS. Older daemons (<0.21) omit this field
// and only support reserved domains, so clients should treat absence as true.
Reserved *bool `protobuf:"varint,2,opt,name=reserved,proto3,oneof" json:"reserved,omitempty"`
// contains filtered or unexported fields
}
func (*Domain) Descriptor
deprecated
func (*Domain) GetReserved ¶
func (*Domain) ProtoMessage ¶
func (*Domain) ProtoMessage()
func (*Domain) ProtoReflect ¶
func (x *Domain) ProtoReflect() protoreflect.Message
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) GetMetadata ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
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 ExecConfig ¶
type ExecConfig struct {
// Container ID to execute the command in.
ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
// JSON serialised ExecOptions
Options []byte `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
// contains filtered or unexported fields
}
func (*ExecConfig) Descriptor
deprecated
func (*ExecConfig) Descriptor() ([]byte, []int)
Deprecated: Use ExecConfig.ProtoReflect.Descriptor instead.
func (*ExecConfig) GetContainerId ¶
func (x *ExecConfig) GetContainerId() string
func (*ExecConfig) GetOptions ¶
func (x *ExecConfig) GetOptions() []byte
func (*ExecConfig) ProtoMessage ¶
func (*ExecConfig) ProtoMessage()
func (*ExecConfig) ProtoReflect ¶
func (x *ExecConfig) ProtoReflect() protoreflect.Message
func (*ExecConfig) Reset ¶
func (x *ExecConfig) Reset()
func (*ExecConfig) String ¶
func (x *ExecConfig) String() string
type ExecContainerRequest ¶
type ExecContainerRequest struct {
// Types that are assignable to Payload:
//
// *ExecContainerRequest_Config
// *ExecContainerRequest_Stdin
// *ExecContainerRequest_Resize
Payload isExecContainerRequest_Payload `protobuf_oneof:"payload"`
// contains filtered or unexported fields
}
func (*ExecContainerRequest) Descriptor
deprecated
func (*ExecContainerRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExecContainerRequest.ProtoReflect.Descriptor instead.
func (*ExecContainerRequest) GetConfig ¶
func (x *ExecContainerRequest) GetConfig() *ExecConfig
func (*ExecContainerRequest) GetPayload ¶
func (m *ExecContainerRequest) GetPayload() isExecContainerRequest_Payload
func (*ExecContainerRequest) GetResize ¶
func (x *ExecContainerRequest) GetResize() *ResizeEvent
func (*ExecContainerRequest) GetStdin ¶
func (x *ExecContainerRequest) GetStdin() []byte
func (*ExecContainerRequest) ProtoMessage ¶
func (*ExecContainerRequest) ProtoMessage()
func (*ExecContainerRequest) ProtoReflect ¶
func (x *ExecContainerRequest) ProtoReflect() protoreflect.Message
func (*ExecContainerRequest) Reset ¶
func (x *ExecContainerRequest) Reset()
func (*ExecContainerRequest) String ¶
func (x *ExecContainerRequest) String() string
type ExecContainerRequest_Config ¶
type ExecContainerRequest_Config struct {
// Initial configuration for the exec session. Must be sent as the first message.
Config *ExecConfig `protobuf:"bytes,1,opt,name=config,proto3,oneof"`
}
type ExecContainerRequest_Resize ¶
type ExecContainerRequest_Resize struct {
// TTY resize event (only used when TTY is enabled).
Resize *ResizeEvent `protobuf:"bytes,3,opt,name=resize,proto3,oneof"`
}
type ExecContainerRequest_Stdin ¶
type ExecContainerRequest_Stdin struct {
// Raw stdin data to be written to the exec process.
Stdin []byte `protobuf:"bytes,2,opt,name=stdin,proto3,oneof"`
}
type ExecContainerResponse ¶
type ExecContainerResponse struct {
// Types that are assignable to Payload:
//
// *ExecContainerResponse_ExecId
// *ExecContainerResponse_Stdout
// *ExecContainerResponse_Stderr
// *ExecContainerResponse_ExitCode
Payload isExecContainerResponse_Payload `protobuf_oneof:"payload"`
// contains filtered or unexported fields
}
func (*ExecContainerResponse) Descriptor
deprecated
func (*ExecContainerResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExecContainerResponse.ProtoReflect.Descriptor instead.
func (*ExecContainerResponse) GetExecId ¶
func (x *ExecContainerResponse) GetExecId() string
func (*ExecContainerResponse) GetExitCode ¶
func (x *ExecContainerResponse) GetExitCode() int32
func (*ExecContainerResponse) GetPayload ¶
func (m *ExecContainerResponse) GetPayload() isExecContainerResponse_Payload
func (*ExecContainerResponse) GetStderr ¶
func (x *ExecContainerResponse) GetStderr() []byte
func (*ExecContainerResponse) GetStdout ¶
func (x *ExecContainerResponse) GetStdout() []byte
func (*ExecContainerResponse) ProtoMessage ¶
func (*ExecContainerResponse) ProtoMessage()
func (*ExecContainerResponse) ProtoReflect ¶
func (x *ExecContainerResponse) ProtoReflect() protoreflect.Message
func (*ExecContainerResponse) Reset ¶
func (x *ExecContainerResponse) Reset()
func (*ExecContainerResponse) String ¶
func (x *ExecContainerResponse) String() string
type ExecContainerResponse_ExecId ¶
type ExecContainerResponse_ExecId struct {
// Exec instance ID returned after creating the exec.
ExecId string `protobuf:"bytes,1,opt,name=exec_id,json=execId,proto3,oneof"`
}
type ExecContainerResponse_ExitCode ¶
type ExecContainerResponse_ExitCode struct {
// Exit code of the exec process. Sent as the final message.
ExitCode int32 `protobuf:"varint,4,opt,name=exit_code,json=exitCode,proto3,oneof"`
}
type ExecContainerResponse_Stderr ¶
type ExecContainerResponse_Stderr struct {
// Raw stderr data from the exec process (only when TTY is disabled).
Stderr []byte `protobuf:"bytes,3,opt,name=stderr,proto3,oneof"`
}
type ExecContainerResponse_Stdout ¶
type ExecContainerResponse_Stdout struct {
// Raw stdout data from the exec process.
Stdout []byte `protobuf:"bytes,2,opt,name=stdout,proto3,oneof"`
}
type GetCaddyConfigResponse ¶
type GetCaddyConfigResponse struct {
// The saved 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"`
// Error from the latest unsuccessful reconciliation attempt.
LastReconciliationError string `` /* 132-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*GetCaddyConfigResponse) Descriptor
deprecated
func (*GetCaddyConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetCaddyConfigResponse.ProtoReflect.Descriptor instead.
func (*GetCaddyConfigResponse) GetCaddyfile ¶
func (x *GetCaddyConfigResponse) GetCaddyfile() string
func (*GetCaddyConfigResponse) GetLastReconciliationError ¶
func (x *GetCaddyConfigResponse) GetLastReconciliationError() string
func (*GetCaddyConfigResponse) GetModifiedAt ¶
func (x *GetCaddyConfigResponse) GetModifiedAt() *timestamppb.Timestamp
func (*GetCaddyConfigResponse) ProtoMessage ¶
func (*GetCaddyConfigResponse) ProtoMessage()
func (*GetCaddyConfigResponse) ProtoReflect ¶
func (x *GetCaddyConfigResponse) ProtoReflect() protoreflect.Message
func (*GetCaddyConfigResponse) Reset ¶
func (x *GetCaddyConfigResponse) Reset()
func (*GetCaddyConfigResponse) String ¶
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 (*IP) Descriptor
deprecated
func (*IP) ProtoMessage ¶
func (*IP) ProtoMessage()
func (*IP) ProtoReflect ¶
func (x *IP) ProtoReflect() protoreflect.Message
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 (*IPPort) Descriptor
deprecated
func (*IPPort) ProtoMessage ¶
func (*IPPort) ProtoMessage()
func (*IPPort) ProtoReflect ¶
func (x *IPPort) ProtoReflect() protoreflect.Message
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 (*IPPrefix) Descriptor
deprecated
func (*IPPrefix) ProtoMessage ¶
func (*IPPrefix) ProtoMessage()
func (*IPPrefix) ProtoReflect ¶
func (x *IPPrefix) ProtoReflect() protoreflect.Message
type Image ¶
type Image struct {
Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
// JSON serialised image.InspectResponse.
Image []byte `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
// contains filtered or unexported fields
}
func (*Image) Descriptor
deprecated
func (*Image) GetMetadata ¶
func (*Image) ProtoMessage ¶
func (*Image) ProtoMessage()
func (*Image) ProtoReflect ¶
func (x *Image) ProtoReflect() protoreflect.Message
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"`
// Optional WireGuard endpoints other machines will use to connect to this machine instead of auto-discovered ones.
WireguardEndpoints []*IPPort `protobuf:"bytes,5,rep,name=wireguard_endpoints,json=wireguardEndpoints,proto3" json:"wireguard_endpoints,omitempty"`
// WireGuard listen port for this machine. Uses the default port (51820) if 0 or not set.
WireguardPort int32 `protobuf:"varint,6,opt,name=wireguard_port,json=wireguardPort,proto3" json:"wireguard_port,omitempty"`
// MTU of the WireGuard interface on this machine. The daemon auto-detects the optimal MTU if 0 or not set.
WireguardMtu int32 `protobuf:"varint,7,opt,name=wireguard_mtu,json=wireguardMtu,proto3" json:"wireguard_mtu,omitempty"`
// 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) GetWireguardEndpoints ¶
func (x *InitClusterRequest) GetWireguardEndpoints() []*IPPort
func (*InitClusterRequest) GetWireguardMtu ¶
func (x *InitClusterRequest) GetWireguardMtu() int32
func (*InitClusterRequest) GetWireguardPort ¶
func (x *InitClusterRequest) GetWireguardPort() int32
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 InspectMachineResponse ¶
type InspectMachineResponse struct {
// Must contain only one repeated messages field to allow broadcasting InspectMachine requests to multiple machines.
Machines []*MachineDetails `protobuf:"bytes,1,rep,name=machines,proto3" json:"machines,omitempty"`
// contains filtered or unexported fields
}
func (*InspectMachineResponse) Descriptor
deprecated
func (*InspectMachineResponse) Descriptor() ([]byte, []int)
Deprecated: Use InspectMachineResponse.ProtoReflect.Descriptor instead.
func (*InspectMachineResponse) GetMachines ¶
func (x *InspectMachineResponse) GetMachines() []*MachineDetails
func (*InspectMachineResponse) ProtoMessage ¶
func (*InspectMachineResponse) ProtoMessage()
func (*InspectMachineResponse) ProtoReflect ¶
func (x *InspectMachineResponse) ProtoReflect() protoreflect.Message
func (*InspectMachineResponse) Reset ¶
func (x *InspectMachineResponse) Reset()
func (*InspectMachineResponse) String ¶
func (x *InspectMachineResponse) 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 (x *InspectRemoteImageRequest) ProtoReflect() protoreflect.Message
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 (x *InspectRemoteImageResponse) ProtoReflect() protoreflect.Message
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 InspectWireGuardNetworkResponse ¶
type InspectWireGuardNetworkResponse struct {
InterfaceName string `protobuf:"bytes,1,opt,name=interface_name,json=interfaceName,proto3" json:"interface_name,omitempty"`
PublicKey []byte `protobuf:"bytes,2,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
ListenPort int32 `protobuf:"varint,3,opt,name=listen_port,json=listenPort,proto3" json:"listen_port,omitempty"`
Peers []*WireGuardPeer `protobuf:"bytes,4,rep,name=peers,proto3" json:"peers,omitempty"`
// contains filtered or unexported fields
}
func (*InspectWireGuardNetworkResponse) Descriptor
deprecated
func (*InspectWireGuardNetworkResponse) Descriptor() ([]byte, []int)
Deprecated: Use InspectWireGuardNetworkResponse.ProtoReflect.Descriptor instead.
func (*InspectWireGuardNetworkResponse) GetInterfaceName ¶
func (x *InspectWireGuardNetworkResponse) GetInterfaceName() string
func (*InspectWireGuardNetworkResponse) GetListenPort ¶
func (x *InspectWireGuardNetworkResponse) GetListenPort() int32
func (*InspectWireGuardNetworkResponse) GetPeers ¶
func (x *InspectWireGuardNetworkResponse) GetPeers() []*WireGuardPeer
func (*InspectWireGuardNetworkResponse) GetPublicKey ¶
func (x *InspectWireGuardNetworkResponse) GetPublicKey() []byte
func (*InspectWireGuardNetworkResponse) ProtoMessage ¶
func (*InspectWireGuardNetworkResponse) ProtoMessage()
func (*InspectWireGuardNetworkResponse) ProtoReflect ¶
func (x *InspectWireGuardNetworkResponse) ProtoReflect() protoreflect.Message
func (*InspectWireGuardNetworkResponse) Reset ¶
func (x *InspectWireGuardNetworkResponse) Reset()
func (*InspectWireGuardNetworkResponse) String ¶
func (x *InspectWireGuardNetworkResponse) String() string
type IssuedCertificate ¶
type IssuedCertificate struct {
// Subject Alternative Name (SAN) of the certificate. Caddy doesn't issue certificates with multiple SANs.
San string `protobuf:"bytes,1,opt,name=san,proto3" json:"san,omitempty"`
// The PEM-encoding of DER-encoded ASN.1 data for the cert or chain, leaf first.
Chain []byte `protobuf:"bytes,2,opt,name=chain,proto3" json:"chain,omitempty"`
// Any extra information associated with the certificate, usually provided by the issuer implementation.
// JSON-encoded, may be absent or null.
IssuerData []byte `protobuf:"bytes,3,opt,name=issuer_data,json=issuerData,proto3" json:"issuer_data,omitempty"`
// contains filtered or unexported fields
}
func (*IssuedCertificate) Descriptor
deprecated
func (*IssuedCertificate) Descriptor() ([]byte, []int)
Deprecated: Use IssuedCertificate.ProtoReflect.Descriptor instead.
func (*IssuedCertificate) GetChain ¶
func (x *IssuedCertificate) GetChain() []byte
func (*IssuedCertificate) GetIssuerData ¶
func (x *IssuedCertificate) GetIssuerData() []byte
func (*IssuedCertificate) GetSan ¶
func (x *IssuedCertificate) GetSan() string
func (*IssuedCertificate) ProtoMessage ¶
func (*IssuedCertificate) ProtoMessage()
func (*IssuedCertificate) ProtoReflect ¶
func (x *IssuedCertificate) ProtoReflect() protoreflect.Message
func (*IssuedCertificate) Reset ¶
func (x *IssuedCertificate) Reset()
func (*IssuedCertificate) String ¶
func (x *IssuedCertificate) 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"`
// WireGuard listen port for this machine. Uses the default port (51820) if 0 or not set.
WireguardPort int32 `protobuf:"varint,5,opt,name=wireguard_port,json=wireguardPort,proto3" json:"wireguard_port,omitempty"`
// MTU of the WireGuard interface on this machine. The daemon auto-detects the optimal MTU if 0 or not set.
WireguardMtu int32 `protobuf:"varint,7,opt,name=wireguard_mtu,json=wireguardMtu,proto3" json:"wireguard_mtu,omitempty"`
// Cluster store version this machine must reach before participating.
// Per-actor vector (Corrosion actor UUID → minimum required db_version).
MinStoreVersion map[string]uint64 `` /* 197-byte string literal not displayed */
// 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) GetMinStoreVersion ¶
func (x *JoinClusterRequest) GetMinStoreVersion() map[string]uint64
func (*JoinClusterRequest) GetOtherMachines ¶
func (x *JoinClusterRequest) GetOtherMachines() []*MachineInfo
func (*JoinClusterRequest) GetWireguardMtu ¶
func (x *JoinClusterRequest) GetWireguardMtu() int32
func (*JoinClusterRequest) GetWireguardPort ¶
func (x *JoinClusterRequest) GetWireguardPort() int32
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 ListCaddyStorageRequest ¶
type ListCaddyStorageRequest struct {
Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
Recursive bool `protobuf:"varint,2,opt,name=recursive,proto3" json:"recursive,omitempty"`
// contains filtered or unexported fields
}
func (*ListCaddyStorageRequest) Descriptor
deprecated
func (*ListCaddyStorageRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListCaddyStorageRequest.ProtoReflect.Descriptor instead.
func (*ListCaddyStorageRequest) GetPrefix ¶
func (x *ListCaddyStorageRequest) GetPrefix() string
func (*ListCaddyStorageRequest) GetRecursive ¶
func (x *ListCaddyStorageRequest) GetRecursive() bool
func (*ListCaddyStorageRequest) ProtoMessage ¶
func (*ListCaddyStorageRequest) ProtoMessage()
func (*ListCaddyStorageRequest) ProtoReflect ¶
func (x *ListCaddyStorageRequest) ProtoReflect() protoreflect.Message
func (*ListCaddyStorageRequest) Reset ¶
func (x *ListCaddyStorageRequest) Reset()
func (*ListCaddyStorageRequest) String ¶
func (x *ListCaddyStorageRequest) String() string
type ListCaddyStorageResponse ¶
type ListCaddyStorageResponse struct {
Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
// contains filtered or unexported fields
}
func (*ListCaddyStorageResponse) Descriptor
deprecated
func (*ListCaddyStorageResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListCaddyStorageResponse.ProtoReflect.Descriptor instead.
func (*ListCaddyStorageResponse) GetKeys ¶
func (x *ListCaddyStorageResponse) GetKeys() []string
func (*ListCaddyStorageResponse) ProtoMessage ¶
func (*ListCaddyStorageResponse) ProtoMessage()
func (*ListCaddyStorageResponse) ProtoReflect ¶
func (x *ListCaddyStorageResponse) ProtoReflect() protoreflect.Message
func (*ListCaddyStorageResponse) Reset ¶
func (x *ListCaddyStorageResponse) Reset()
func (*ListCaddyStorageResponse) String ¶
func (x *ListCaddyStorageResponse) String() string
type ListCertificatesResponse ¶
type ListCertificatesResponse struct {
Certificates []*IssuedCertificate `protobuf:"bytes,1,rep,name=certificates,proto3" json:"certificates,omitempty"`
// contains filtered or unexported fields
}
func (*ListCertificatesResponse) Descriptor
deprecated
func (*ListCertificatesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListCertificatesResponse.ProtoReflect.Descriptor instead.
func (*ListCertificatesResponse) GetCertificates ¶
func (x *ListCertificatesResponse) GetCertificates() []*IssuedCertificate
func (*ListCertificatesResponse) ProtoMessage ¶
func (*ListCertificatesResponse) ProtoMessage()
func (*ListCertificatesResponse) ProtoReflect ¶
func (x *ListCertificatesResponse) ProtoReflect() protoreflect.Message
func (*ListCertificatesResponse) Reset ¶
func (x *ListCertificatesResponse) Reset()
func (*ListCertificatesResponse) String ¶
func (x *ListCertificatesResponse) 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 ListImagesRequest ¶
type ListImagesRequest struct {
// JSON serialised image.ListOptions.
Options []byte `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
// contains filtered or unexported fields
}
func (*ListImagesRequest) Descriptor
deprecated
func (*ListImagesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListImagesRequest.ProtoReflect.Descriptor instead.
func (*ListImagesRequest) GetOptions ¶
func (x *ListImagesRequest) GetOptions() []byte
func (*ListImagesRequest) ProtoMessage ¶
func (*ListImagesRequest) ProtoMessage()
func (*ListImagesRequest) ProtoReflect ¶
func (x *ListImagesRequest) ProtoReflect() protoreflect.Message
func (*ListImagesRequest) Reset ¶
func (x *ListImagesRequest) Reset()
func (*ListImagesRequest) String ¶
func (x *ListImagesRequest) String() string
type ListImagesResponse ¶
type ListImagesResponse struct {
// Must contain only one repeated messages field to allow broadcasting ListImages requests to multiple machines.
Messages []*MachineImages `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
// contains filtered or unexported fields
}
func (*ListImagesResponse) Descriptor
deprecated
func (*ListImagesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListImagesResponse.ProtoReflect.Descriptor instead.
func (*ListImagesResponse) GetMessages ¶
func (x *ListImagesResponse) GetMessages() []*MachineImages
func (*ListImagesResponse) ProtoMessage ¶
func (*ListImagesResponse) ProtoMessage()
func (*ListImagesResponse) ProtoReflect ¶
func (x *ListImagesResponse) ProtoReflect() protoreflect.Message
func (*ListImagesResponse) Reset ¶
func (x *ListImagesResponse) Reset()
func (*ListImagesResponse) String ¶
func (x *ListImagesResponse) 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 (x *ListServiceContainersRequest) ProtoReflect() protoreflect.Message
func (*ListServiceContainersRequest) Reset ¶
func (x *ListServiceContainersRequest) Reset()
func (*ListServiceContainersRequest) String ¶
func (x *ListServiceContainersRequest) String() 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 (x *ListServiceContainersResponse) GetMessages() []*MachineServiceContainers
func (*ListServiceContainersResponse) ProtoMessage ¶
func (*ListServiceContainersResponse) ProtoMessage()
func (*ListServiceContainersResponse) ProtoReflect ¶
func (x *ListServiceContainersResponse) ProtoReflect() protoreflect.Message
func (*ListServiceContainersResponse) Reset ¶
func (x *ListServiceContainersResponse) Reset()
func (*ListServiceContainersResponse) String ¶
func (x *ListServiceContainersResponse) String() string
type ListVolumesRequest ¶
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
func (*ListVolumesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListVolumesRequest.ProtoReflect.Descriptor instead.
func (*ListVolumesRequest) GetOptions ¶
func (x *ListVolumesRequest) GetOptions() []byte
func (*ListVolumesRequest) ProtoMessage ¶
func (*ListVolumesRequest) ProtoMessage()
func (*ListVolumesRequest) ProtoReflect ¶
func (x *ListVolumesRequest) ProtoReflect() protoreflect.Message
func (*ListVolumesRequest) Reset ¶
func (x *ListVolumesRequest) Reset()
func (*ListVolumesRequest) String ¶
func (x *ListVolumesRequest) String() string
type ListVolumesResponse ¶
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
func (*ListVolumesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListVolumesResponse.ProtoReflect.Descriptor instead.
func (*ListVolumesResponse) GetMessages ¶
func (x *ListVolumesResponse) GetMessages() []*MachineVolumes
func (*ListVolumesResponse) ProtoMessage ¶
func (*ListVolumesResponse) ProtoMessage()
func (*ListVolumesResponse) ProtoReflect ¶
func (x *ListVolumesResponse) ProtoReflect() protoreflect.Message
func (*ListVolumesResponse) Reset ¶
func (x *ListVolumesResponse) Reset()
func (*ListVolumesResponse) String ¶
func (x *ListVolumesResponse) String() string
type LoadCaddyStorageRequest ¶
type LoadCaddyStorageRequest struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
// contains filtered or unexported fields
}
func (*LoadCaddyStorageRequest) Descriptor
deprecated
func (*LoadCaddyStorageRequest) Descriptor() ([]byte, []int)
Deprecated: Use LoadCaddyStorageRequest.ProtoReflect.Descriptor instead.
func (*LoadCaddyStorageRequest) GetKey ¶
func (x *LoadCaddyStorageRequest) GetKey() string
func (*LoadCaddyStorageRequest) ProtoMessage ¶
func (*LoadCaddyStorageRequest) ProtoMessage()
func (*LoadCaddyStorageRequest) ProtoReflect ¶
func (x *LoadCaddyStorageRequest) ProtoReflect() protoreflect.Message
func (*LoadCaddyStorageRequest) Reset ¶
func (x *LoadCaddyStorageRequest) Reset()
func (*LoadCaddyStorageRequest) String ¶
func (x *LoadCaddyStorageRequest) String() string
type LoadCaddyStorageResponse ¶
type LoadCaddyStorageResponse struct {
Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
// contains filtered or unexported fields
}
func (*LoadCaddyStorageResponse) Descriptor
deprecated
func (*LoadCaddyStorageResponse) Descriptor() ([]byte, []int)
Deprecated: Use LoadCaddyStorageResponse.ProtoReflect.Descriptor instead.
func (*LoadCaddyStorageResponse) GetUpdatedAt ¶
func (x *LoadCaddyStorageResponse) GetUpdatedAt() *timestamppb.Timestamp
func (*LoadCaddyStorageResponse) GetValue ¶
func (x *LoadCaddyStorageResponse) GetValue() []byte
func (*LoadCaddyStorageResponse) ProtoMessage ¶
func (*LoadCaddyStorageResponse) ProtoMessage()
func (*LoadCaddyStorageResponse) ProtoReflect ¶
func (x *LoadCaddyStorageResponse) ProtoReflect() protoreflect.Message
func (*LoadCaddyStorageResponse) Reset ¶
func (x *LoadCaddyStorageResponse) Reset()
func (*LoadCaddyStorageResponse) String ¶
func (x *LoadCaddyStorageResponse) String() string
type LogEntry ¶
type LogEntry struct {
Stream LogEntry_StreamType `protobuf:"varint,1,opt,name=stream,proto3,enum=api.LogEntry_StreamType" json:"stream,omitempty"`
Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
// Log line content. Empty for heartbeat entries.
Message []byte `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*LogEntry) Descriptor
deprecated
func (*LogEntry) GetMessage ¶
func (*LogEntry) GetStream ¶
func (x *LogEntry) GetStream() LogEntry_StreamType
func (*LogEntry) GetTimestamp ¶
func (x *LogEntry) GetTimestamp() *timestamppb.Timestamp
func (*LogEntry) ProtoMessage ¶
func (*LogEntry) ProtoMessage()
func (*LogEntry) ProtoReflect ¶
func (x *LogEntry) ProtoReflect() protoreflect.Message
type LogEntry_StreamType ¶
type LogEntry_StreamType int32
const ( LogEntry_UNKNOWN LogEntry_StreamType = 0 LogEntry_STDOUT LogEntry_StreamType = 1 LogEntry_STDERR LogEntry_StreamType = 2 LogEntry_HEARTBEAT LogEntry_StreamType = 3 )
func (LogEntry_StreamType) Descriptor ¶
func (LogEntry_StreamType) Descriptor() protoreflect.EnumDescriptor
func (LogEntry_StreamType) Enum ¶
func (x LogEntry_StreamType) Enum() *LogEntry_StreamType
func (LogEntry_StreamType) EnumDescriptor
deprecated
func (LogEntry_StreamType) EnumDescriptor() ([]byte, []int)
Deprecated: Use LogEntry_StreamType.Descriptor instead.
func (LogEntry_StreamType) Number ¶
func (x LogEntry_StreamType) Number() protoreflect.EnumNumber
func (LogEntry_StreamType) String ¶
func (x LogEntry_StreamType) String() string
func (LogEntry_StreamType) Type ¶
func (LogEntry_StreamType) Type() protoreflect.EnumType
type LogsRequest ¶
type LogsRequest struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// Options for logs retrieval.
Follow bool `protobuf:"varint,2,opt,name=follow,proto3" json:"follow,omitempty"`
Tail int32 `protobuf:"varint,3,opt,name=tail,proto3" json:"tail,omitempty"` // -1 means all
Since string `protobuf:"bytes,4,opt,name=since,proto3" json:"since,omitempty"` // https://www.rfc-editor.org/rfc/rfc3339.html timestamp or Go duration string
Until string `protobuf:"bytes,5,opt,name=until,proto3" json:"until,omitempty"` // https://www.rfc-editor.org/rfc/rfc3339.html timestamp or Go duration string
// contains filtered or unexported fields
}
func (*LogsRequest) Descriptor
deprecated
func (*LogsRequest) Descriptor() ([]byte, []int)
Deprecated: Use LogsRequest.ProtoReflect.Descriptor instead.
func (*LogsRequest) GetFollow ¶
func (x *LogsRequest) GetFollow() bool
func (*LogsRequest) GetId ¶
func (x *LogsRequest) GetId() string
func (*LogsRequest) GetSince ¶
func (x *LogsRequest) GetSince() string
func (*LogsRequest) GetTail ¶
func (x *LogsRequest) GetTail() int32
func (*LogsRequest) GetUntil ¶
func (x *LogsRequest) GetUntil() string
func (*LogsRequest) ProtoMessage ¶
func (*LogsRequest) ProtoMessage()
func (*LogsRequest) ProtoReflect ¶
func (x *LogsRequest) ProtoReflect() protoreflect.Message
func (*LogsRequest) Reset ¶
func (x *LogsRequest) Reset()
func (*LogsRequest) String ¶
func (x *LogsRequest) 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)
// Deprecated: use InspectMachine instead.
Inspect(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*MachineInfo, error)
// InspectMachine retrieves detailed information about the machine. Supports broadcasting to multiple machines.
InspectMachine(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*InspectMachineResponse, error)
// WaitForStoreVersion waits until the cluster store on this machine has reached each requested actor version, with
// no known missing or pending transactions through those versions from active members.
// Corrosion may satisfy a version by applying its surviving changes or by marking it complete because its changes
// have been superseded.
//
// Waiting normally makes the captured data available on this machine. However, another write may replace some of that
// data before it arrives. Corrosion can then complete the older version without transferring the replaced data.
// If the replacement is outside the requested versions, this RPC can succeed while the affected data is still missing
// or outdated. This can happen during concurrent updates even when all machines are well connected.
//
// Success does not guarantee an exact snapshot or delivery of every historical value. Callers that require a specific
// record or condition should verify it after waiting.
//
// This RPC observes native replication without initiating synchronisation.
// Use the RPC deadline to bound the wait.
WaitForStoreVersion(ctx context.Context, in *WaitForStoreVersionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
// UpdateMachine updates the configuration of the machine.
UpdateMachine(ctx context.Context, in *UpdateMachineRequest, opts ...grpc.CallOption) (*UpdateMachineResponse, error)
// InspectWireGuardNetwork retrieves the current WireGuard network configuration and peer status.
InspectWireGuardNetwork(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*InspectWireGuardNetworkResponse, 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)
MachineLogs(ctx context.Context, in *LogsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[LogEntry], 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 MachineDetails ¶
type MachineDetails struct {
Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
Machine *MachineInfo `protobuf:"bytes,2,opt,name=machine,proto3" json:"machine,omitempty"`
// Round-trip times to other machines in the cluster, keyed by peer machine ID.
Rtts map[string]*RTTStats `` /* 149-byte string literal not displayed */
// Store replication progress observed on this machine.
// Maps each Corrosion actor UUID to its highest processed database version. Corrosion also counts versions whose
// changes were superseded and skipped. Versions at or below a reported version may still be missing or pending
// locally.
//
// Pass this vector to WaitForStoreVersion on another machine to wait for replication through these versions.
// See that RPC's data-availability limitations. To combine observations from several machines, take the maximum
// for each actor.
// Capturing this vector does not wait for replication or prevent further writes.
StoreVersion map[string]uint64 `` /* 186-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*MachineDetails) Descriptor
deprecated
func (*MachineDetails) Descriptor() ([]byte, []int)
Deprecated: Use MachineDetails.ProtoReflect.Descriptor instead.
func (*MachineDetails) GetMachine ¶
func (x *MachineDetails) GetMachine() *MachineInfo
func (*MachineDetails) GetMetadata ¶
func (x *MachineDetails) GetMetadata() *Metadata
func (*MachineDetails) GetRtts ¶
func (x *MachineDetails) GetRtts() map[string]*RTTStats
func (*MachineDetails) GetStoreVersion ¶
func (x *MachineDetails) GetStoreVersion() map[string]uint64
func (*MachineDetails) ProtoMessage ¶
func (*MachineDetails) ProtoMessage()
func (*MachineDetails) ProtoReflect ¶
func (x *MachineDetails) ProtoReflect() protoreflect.Message
func (*MachineDetails) Reset ¶
func (x *MachineDetails) Reset()
func (*MachineDetails) String ¶
func (x *MachineDetails) String() string
type MachineImages ¶
type MachineImages struct {
Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
// JSON serialised []image.Summary.
Images []byte `protobuf:"bytes,2,opt,name=images,proto3" json:"images,omitempty"`
// True if Docker uses the containerd image store, false if it uses its internal image store.
ContainerdStore bool `protobuf:"varint,3,opt,name=containerd_store,json=containerdStore,proto3" json:"containerd_store,omitempty"`
// contains filtered or unexported fields
}
func (*MachineImages) Descriptor
deprecated
func (*MachineImages) Descriptor() ([]byte, []int)
Deprecated: Use MachineImages.ProtoReflect.Descriptor instead.
func (*MachineImages) GetContainerdStore ¶
func (x *MachineImages) GetContainerdStore() bool
func (*MachineImages) GetImages ¶
func (x *MachineImages) GetImages() []byte
func (*MachineImages) GetMetadata ¶
func (x *MachineImages) GetMetadata() *Metadata
func (*MachineImages) ProtoMessage ¶
func (*MachineImages) ProtoMessage()
func (*MachineImages) ProtoReflect ¶
func (x *MachineImages) ProtoReflect() protoreflect.Message
func (*MachineImages) Reset ¶
func (x *MachineImages) Reset()
func (*MachineImages) String ¶
func (x *MachineImages) 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"`
// Version of the machine daemon (uncloudd).
DaemonVersion string `protobuf:"bytes,7,opt,name=daemon_version,json=daemonVersion,proto3" json:"daemon_version,omitempty"`
// Version of the Docker engine running on the machine. Could be empty if unable to get.
DockerVersion string `protobuf:"bytes,8,opt,name=docker_version,json=dockerVersion,proto3" json:"docker_version,omitempty"`
// Operating system hostname.
Hostname string `protobuf:"bytes,5,opt,name=hostname,proto3" json:"hostname,omitempty"`
// CPU architecture.
Arch string `protobuf:"bytes,6,opt,name=arch,proto3" json:"arch,omitempty"`
// Human-readable operating system name and version, e.g. "Ubuntu 24.04.4 LTS". Empty if cannot be determined.
OsPrettyName string `protobuf:"bytes,9,opt,name=os_pretty_name,json=osPrettyName,proto3" json:"os_pretty_name,omitempty"`
// Kernel release version, e.g. "6.8.0-31-generic".
KernelVersion string `protobuf:"bytes,10,opt,name=kernel_version,json=kernelVersion,proto3" json:"kernel_version,omitempty"`
// contains filtered or unexported fields
}
func (*MachineInfo) Descriptor
deprecated
func (*MachineInfo) Descriptor() ([]byte, []int)
Deprecated: Use MachineInfo.ProtoReflect.Descriptor instead.
func (*MachineInfo) GetArch ¶
func (x *MachineInfo) GetArch() string
func (*MachineInfo) GetDaemonVersion ¶
func (x *MachineInfo) GetDaemonVersion() string
func (*MachineInfo) GetDockerVersion ¶
func (x *MachineInfo) GetDockerVersion() string
func (*MachineInfo) GetHostname ¶
func (x *MachineInfo) GetHostname() string
func (*MachineInfo) GetId ¶
func (x *MachineInfo) GetId() string
func (*MachineInfo) GetKernelVersion ¶
func (x *MachineInfo) GetKernelVersion() string
func (*MachineInfo) GetName ¶
func (x *MachineInfo) GetName() string
func (*MachineInfo) GetNetwork ¶
func (x *MachineInfo) GetNetwork() *NetworkConfig
func (*MachineInfo) GetOsPrettyName ¶
func (x *MachineInfo) GetOsPrettyName() string
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 (x *MachineMember) GetState() MachineMember_MembershipState
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) Descriptor() protoreflect.EnumDescriptor
func (MachineMember_MembershipState) Enum ¶
func (x MachineMember_MembershipState) Enum() *MachineMember_MembershipState
func (MachineMember_MembershipState) EnumDescriptor
deprecated
func (MachineMember_MembershipState) EnumDescriptor() ([]byte, []int)
Deprecated: Use MachineMember_MembershipState.Descriptor instead.
func (MachineMember_MembershipState) Number ¶
func (x MachineMember_MembershipState) Number() protoreflect.EnumNumber
func (MachineMember_MembershipState) String ¶
func (x MachineMember_MembershipState) String() string
func (MachineMember_MembershipState) Type ¶
func (MachineMember_MembershipState) Type() protoreflect.EnumType
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)
// Deprecated: use InspectMachine instead.
Inspect(context.Context, *emptypb.Empty) (*MachineInfo, error)
// InspectMachine retrieves detailed information about the machine. Supports broadcasting to multiple machines.
InspectMachine(context.Context, *emptypb.Empty) (*InspectMachineResponse, error)
// WaitForStoreVersion waits until the cluster store on this machine has reached each requested actor version, with
// no known missing or pending transactions through those versions from active members.
// Corrosion may satisfy a version by applying its surviving changes or by marking it complete because its changes
// have been superseded.
//
// Waiting normally makes the captured data available on this machine. However, another write may replace some of that
// data before it arrives. Corrosion can then complete the older version without transferring the replaced data.
// If the replacement is outside the requested versions, this RPC can succeed while the affected data is still missing
// or outdated. This can happen during concurrent updates even when all machines are well connected.
//
// Success does not guarantee an exact snapshot or delivery of every historical value. Callers that require a specific
// record or condition should verify it after waiting.
//
// This RPC observes native replication without initiating synchronisation.
// Use the RPC deadline to bound the wait.
WaitForStoreVersion(context.Context, *WaitForStoreVersionRequest) (*emptypb.Empty, error)
// UpdateMachine updates the configuration of the machine.
UpdateMachine(context.Context, *UpdateMachineRequest) (*UpdateMachineResponse, error)
// InspectWireGuardNetwork retrieves the current WireGuard network configuration and peer status.
InspectWireGuardNetwork(context.Context, *emptypb.Empty) (*InspectWireGuardNetworkResponse, 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)
MachineLogs(*LogsRequest, grpc.ServerStreamingServer[LogEntry]) 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"`
// One-shot containers for deployment hooks (e.g. pre-deploy).
HookContainers []*ServiceContainer `protobuf:"bytes,3,rep,name=hook_containers,json=hookContainers,proto3" json:"hook_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) GetHookContainers ¶
func (x *MachineServiceContainers) GetHookContainers() []*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 ¶
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
func (*MachineVolumes) Descriptor() ([]byte, []int)
Deprecated: Use MachineVolumes.ProtoReflect.Descriptor instead.
func (*MachineVolumes) GetMetadata ¶
func (x *MachineVolumes) GetMetadata() *Metadata
func (*MachineVolumes) GetResponse ¶
func (x *MachineVolumes) GetResponse() []byte
func (*MachineVolumes) ProtoMessage ¶
func (*MachineVolumes) ProtoMessage()
func (*MachineVolumes) ProtoReflect ¶
func (x *MachineVolumes) ProtoReflect() protoreflect.Message
func (*MachineVolumes) Reset ¶
func (x *MachineVolumes) Reset()
func (*MachineVolumes) String ¶
func (x *MachineVolumes) String() string
type Machine_MachineLogsClient ¶
type Machine_MachineLogsClient = grpc.ServerStreamingClient[LogEntry]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Machine_MachineLogsServer ¶
type Machine_MachineLogsServer = grpc.ServerStreamingServer[LogEntry]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Metadata ¶
type Metadata struct {
// ID of the machine the response came from.
MachineId string `protobuf:"bytes,4,opt,name=machine_id,json=machineId,proto3" json:"machine_id,omitempty"`
// Name of the machine the response came from.
MachineName string `protobuf:"bytes,5,opt,name=machine_name,json=machineName,proto3" json:"machine_name,omitempty"`
// Address of the machine the response came from.
MachineAddr string `protobuf:"bytes,1,opt,name=machine_addr,json=machineAddr,proto3" json:"machine_addr,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) GetMachineAddr ¶
func (*Metadata) GetMachineId ¶
func (*Metadata) GetMachineName ¶
func (*Metadata) ProtoMessage ¶
func (*Metadata) ProtoMessage()
func (*Metadata) ProtoReflect ¶
func (x *Metadata) ProtoReflect() protoreflect.Message
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 RTTStats ¶
type RTTStats struct {
Median *durationpb.Duration `protobuf:"bytes,1,opt,name=median,proto3" json:"median,omitempty"`
StdDev *durationpb.Duration `protobuf:"bytes,2,opt,name=std_dev,json=stdDev,proto3" json:"std_dev,omitempty"`
// contains filtered or unexported fields
}
func (*RTTStats) Descriptor
deprecated
func (*RTTStats) GetMedian ¶
func (x *RTTStats) GetMedian() *durationpb.Duration
func (*RTTStats) GetStdDev ¶
func (x *RTTStats) GetStdDev() *durationpb.Duration
func (*RTTStats) ProtoMessage ¶
func (*RTTStats) ProtoMessage()
func (*RTTStats) ProtoReflect ¶
func (x *RTTStats) ProtoReflect() protoreflect.Message
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 ¶
type RemoveMachineRequest struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// contains filtered or unexported fields
}
func (*RemoveMachineRequest) Descriptor
deprecated
func (*RemoveMachineRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveMachineRequest.ProtoReflect.Descriptor instead.
func (*RemoveMachineRequest) GetId ¶
func (x *RemoveMachineRequest) GetId() string
func (*RemoveMachineRequest) ProtoMessage ¶
func (*RemoveMachineRequest) ProtoMessage()
func (*RemoveMachineRequest) ProtoReflect ¶
func (x *RemoveMachineRequest) ProtoReflect() protoreflect.Message
func (*RemoveMachineRequest) Reset ¶
func (x *RemoveMachineRequest) Reset()
func (*RemoveMachineRequest) String ¶
func (x *RemoveMachineRequest) String() string
type RemoveVolumeRequest ¶
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
func (*RemoveVolumeRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveVolumeRequest.ProtoReflect.Descriptor instead.
func (*RemoveVolumeRequest) GetForce ¶
func (x *RemoveVolumeRequest) GetForce() bool
func (*RemoveVolumeRequest) GetId ¶
func (x *RemoveVolumeRequest) GetId() string
func (*RemoveVolumeRequest) ProtoMessage ¶
func (*RemoveVolumeRequest) ProtoMessage()
func (*RemoveVolumeRequest) ProtoReflect ¶
func (x *RemoveVolumeRequest) ProtoReflect() protoreflect.Message
func (*RemoveVolumeRequest) Reset ¶
func (x *RemoveVolumeRequest) Reset()
func (*RemoveVolumeRequest) String ¶
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 ¶
type ResetRequest struct {
// contains filtered or unexported fields
}
func (*ResetRequest) Descriptor
deprecated
func (*ResetRequest) Descriptor() ([]byte, []int)
Deprecated: Use ResetRequest.ProtoReflect.Descriptor instead.
func (*ResetRequest) ProtoMessage ¶
func (*ResetRequest) ProtoMessage()
func (*ResetRequest) ProtoReflect ¶
func (x *ResetRequest) ProtoReflect() protoreflect.Message
func (*ResetRequest) Reset ¶
func (x *ResetRequest) Reset()
func (*ResetRequest) String ¶
func (x *ResetRequest) String() string
type ResizeEvent ¶
type ResizeEvent struct {
Height uint32 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
Width uint32 `protobuf:"varint,2,opt,name=width,proto3" json:"width,omitempty"`
// contains filtered or unexported fields
}
func (*ResizeEvent) Descriptor
deprecated
func (*ResizeEvent) Descriptor() ([]byte, []int)
Deprecated: Use ResizeEvent.ProtoReflect.Descriptor instead.
func (*ResizeEvent) GetHeight ¶
func (x *ResizeEvent) GetHeight() uint32
func (*ResizeEvent) GetWidth ¶
func (x *ResizeEvent) GetWidth() uint32
func (*ResizeEvent) ProtoMessage ¶
func (*ResizeEvent) ProtoMessage()
func (*ResizeEvent) ProtoReflect ¶
func (x *ResizeEvent) ProtoReflect() protoreflect.Message
func (*ResizeEvent) Reset ¶
func (x *ResizeEvent) Reset()
func (*ResizeEvent) String ¶
func (x *ResizeEvent) 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) GetContainers ¶
func (x *Service) GetContainers() []*Service_Container
func (*Service) ProtoMessage ¶
func (*Service) ProtoMessage()
func (*Service) ProtoReflect ¶
func (x *Service) ProtoReflect() protoreflect.Message
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 SetDomainRequest ¶
type SetDomainRequest struct {
// An externally managed domain name. Empty clears a manually set domain.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*SetDomainRequest) Descriptor
deprecated
func (*SetDomainRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetDomainRequest.ProtoReflect.Descriptor instead.
func (*SetDomainRequest) GetName ¶
func (x *SetDomainRequest) GetName() string
func (*SetDomainRequest) ProtoMessage ¶
func (*SetDomainRequest) ProtoMessage()
func (*SetDomainRequest) ProtoReflect ¶
func (x *SetDomainRequest) ProtoReflect() protoreflect.Message
func (*SetDomainRequest) Reset ¶
func (x *SetDomainRequest) Reset()
func (*SetDomainRequest) String ¶
func (x *SetDomainRequest) 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 StatCaddyStorageRequest ¶
type StatCaddyStorageRequest struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
// contains filtered or unexported fields
}
func (*StatCaddyStorageRequest) Descriptor
deprecated
func (*StatCaddyStorageRequest) Descriptor() ([]byte, []int)
Deprecated: Use StatCaddyStorageRequest.ProtoReflect.Descriptor instead.
func (*StatCaddyStorageRequest) GetKey ¶
func (x *StatCaddyStorageRequest) GetKey() string
func (*StatCaddyStorageRequest) ProtoMessage ¶
func (*StatCaddyStorageRequest) ProtoMessage()
func (*StatCaddyStorageRequest) ProtoReflect ¶
func (x *StatCaddyStorageRequest) ProtoReflect() protoreflect.Message
func (*StatCaddyStorageRequest) Reset ¶
func (x *StatCaddyStorageRequest) Reset()
func (*StatCaddyStorageRequest) String ¶
func (x *StatCaddyStorageRequest) String() string
type StatCaddyStorageResponse ¶
type StatCaddyStorageResponse struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
Size int64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
IsTerminal bool `protobuf:"varint,4,opt,name=is_terminal,json=isTerminal,proto3" json:"is_terminal,omitempty"`
// contains filtered or unexported fields
}
func (*StatCaddyStorageResponse) Descriptor
deprecated
func (*StatCaddyStorageResponse) Descriptor() ([]byte, []int)
Deprecated: Use StatCaddyStorageResponse.ProtoReflect.Descriptor instead.
func (*StatCaddyStorageResponse) GetIsTerminal ¶
func (x *StatCaddyStorageResponse) GetIsTerminal() bool
func (*StatCaddyStorageResponse) GetKey ¶
func (x *StatCaddyStorageResponse) GetKey() string
func (*StatCaddyStorageResponse) GetSize ¶
func (x *StatCaddyStorageResponse) GetSize() int64
func (*StatCaddyStorageResponse) GetUpdatedAt ¶
func (x *StatCaddyStorageResponse) GetUpdatedAt() *timestamppb.Timestamp
func (*StatCaddyStorageResponse) ProtoMessage ¶
func (*StatCaddyStorageResponse) ProtoMessage()
func (*StatCaddyStorageResponse) ProtoReflect ¶
func (x *StatCaddyStorageResponse) ProtoReflect() protoreflect.Message
func (*StatCaddyStorageResponse) Reset ¶
func (x *StatCaddyStorageResponse) Reset()
func (*StatCaddyStorageResponse) String ¶
func (x *StatCaddyStorageResponse) 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 StoreCaddyStorageRequest ¶
type StoreCaddyStorageRequest struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
func (*StoreCaddyStorageRequest) Descriptor
deprecated
func (*StoreCaddyStorageRequest) Descriptor() ([]byte, []int)
Deprecated: Use StoreCaddyStorageRequest.ProtoReflect.Descriptor instead.
func (*StoreCaddyStorageRequest) GetKey ¶
func (x *StoreCaddyStorageRequest) GetKey() string
func (*StoreCaddyStorageRequest) GetValue ¶
func (x *StoreCaddyStorageRequest) GetValue() []byte
func (*StoreCaddyStorageRequest) ProtoMessage ¶
func (*StoreCaddyStorageRequest) ProtoMessage()
func (*StoreCaddyStorageRequest) ProtoReflect ¶
func (x *StoreCaddyStorageRequest) ProtoReflect() protoreflect.Message
func (*StoreCaddyStorageRequest) Reset ¶
func (x *StoreCaddyStorageRequest) Reset()
func (*StoreCaddyStorageRequest) String ¶
func (x *StoreCaddyStorageRequest) 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 ¶
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 ¶
func (UnimplementedCaddyServer) GetConfig(context.Context, *emptypb.Empty) (*GetCaddyConfigResponse, error)
type UnimplementedCaddyStorageServer ¶
type UnimplementedCaddyStorageServer struct{}
UnimplementedCaddyStorageServer 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 (UnimplementedCaddyStorageServer) Delete ¶
func (UnimplementedCaddyStorageServer) Delete(context.Context, *DeleteCaddyStorageRequest) (*emptypb.Empty, error)
func (UnimplementedCaddyStorageServer) ListCertificates ¶
func (UnimplementedCaddyStorageServer) ListCertificates(context.Context, *emptypb.Empty) (*ListCertificatesResponse, error)
func (UnimplementedCaddyStorageServer) Store ¶
func (UnimplementedCaddyStorageServer) Store(context.Context, *StoreCaddyStorageRequest) (*emptypb.Empty, error)
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) AddMachine(context.Context, *AddMachineRequest) (*AddMachineResponse, error)
func (UnimplementedClusterServer) CreateDomainRecords ¶
func (UnimplementedClusterServer) CreateDomainRecords(context.Context, *CreateDomainRecordsRequest) (*CreateDomainRecordsResponse, error)
func (UnimplementedClusterServer) ListMachines ¶
func (UnimplementedClusterServer) ListMachines(context.Context, *emptypb.Empty) (*ListMachinesResponse, error)
func (UnimplementedClusterServer) ReleaseDomain ¶
func (UnimplementedClusterServer) RemoveMachine ¶
func (UnimplementedClusterServer) RemoveMachine(context.Context, *RemoveMachineRequest) (*emptypb.Empty, error)
func (UnimplementedClusterServer) ReserveDomain ¶
func (UnimplementedClusterServer) ReserveDomain(context.Context, *ReserveDomainRequest) (*Domain, error)
func (UnimplementedClusterServer) SetDomain ¶
func (UnimplementedClusterServer) SetDomain(context.Context, *SetDomainRequest) (*emptypb.Empty, error)
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) ContainerLogs ¶
func (UnimplementedDockerServer) ContainerLogs(*LogsRequest, grpc.ServerStreamingServer[LogEntry]) error
func (UnimplementedDockerServer) CreateContainer ¶
func (UnimplementedDockerServer) CreateContainer(context.Context, *CreateContainerRequest) (*CreateContainerResponse, error)
func (UnimplementedDockerServer) CreateServiceContainer ¶
func (UnimplementedDockerServer) CreateServiceContainer(context.Context, *CreateServiceContainerRequest) (*CreateContainerResponse, error)
func (UnimplementedDockerServer) CreateVolume ¶
func (UnimplementedDockerServer) CreateVolume(context.Context, *CreateVolumeRequest) (*CreateVolumeResponse, error)
func (UnimplementedDockerServer) ExecContainer ¶
func (UnimplementedDockerServer) ExecContainer(grpc.BidiStreamingServer[ExecContainerRequest, ExecContainerResponse]) error
func (UnimplementedDockerServer) InspectContainer ¶
func (UnimplementedDockerServer) InspectContainer(context.Context, *InspectContainerRequest) (*InspectContainerResponse, error)
func (UnimplementedDockerServer) InspectImage ¶
func (UnimplementedDockerServer) InspectImage(context.Context, *InspectImageRequest) (*InspectImageResponse, error)
func (UnimplementedDockerServer) InspectRemoteImage ¶
func (UnimplementedDockerServer) InspectRemoteImage(context.Context, *InspectRemoteImageRequest) (*InspectRemoteImageResponse, error)
func (UnimplementedDockerServer) InspectServiceContainer ¶
func (UnimplementedDockerServer) InspectServiceContainer(context.Context, *InspectContainerRequest) (*ServiceContainer, error)
func (UnimplementedDockerServer) ListContainers ¶
func (UnimplementedDockerServer) ListContainers(context.Context, *ListContainersRequest) (*ListContainersResponse, error)
func (UnimplementedDockerServer) ListImages ¶
func (UnimplementedDockerServer) ListImages(context.Context, *ListImagesRequest) (*ListImagesResponse, error)
func (UnimplementedDockerServer) ListServiceContainers ¶
func (UnimplementedDockerServer) ListServiceContainers(context.Context, *ListServiceContainersRequest) (*ListServiceContainersResponse, error)
func (UnimplementedDockerServer) ListVolumes ¶
func (UnimplementedDockerServer) ListVolumes(context.Context, *ListVolumesRequest) (*ListVolumesResponse, error)
func (UnimplementedDockerServer) PullImage ¶
func (UnimplementedDockerServer) PullImage(*PullImageRequest, grpc.ServerStreamingServer[JSONMessage]) error
func (UnimplementedDockerServer) RemoveContainer ¶
func (UnimplementedDockerServer) RemoveContainer(context.Context, *RemoveContainerRequest) (*emptypb.Empty, error)
func (UnimplementedDockerServer) RemoveServiceContainer ¶
func (UnimplementedDockerServer) RemoveServiceContainer(context.Context, *RemoveContainerRequest) (*emptypb.Empty, error)
func (UnimplementedDockerServer) RemoveVolume ¶
func (UnimplementedDockerServer) RemoveVolume(context.Context, *RemoveVolumeRequest) (*emptypb.Empty, error)
func (UnimplementedDockerServer) StartContainer ¶
func (UnimplementedDockerServer) StartContainer(context.Context, *StartContainerRequest) (*emptypb.Empty, error)
func (UnimplementedDockerServer) StopContainer ¶
func (UnimplementedDockerServer) StopContainer(context.Context, *StopContainerRequest) (*emptypb.Empty, error)
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 ¶
func (UnimplementedMachineServer) CheckPrerequisites(context.Context, *emptypb.Empty) (*CheckPrerequisitesResponse, error)
func (UnimplementedMachineServer) InitCluster ¶
func (UnimplementedMachineServer) InitCluster(context.Context, *InitClusterRequest) (*InitClusterResponse, error)
func (UnimplementedMachineServer) Inspect ¶
func (UnimplementedMachineServer) Inspect(context.Context, *emptypb.Empty) (*MachineInfo, error)
func (UnimplementedMachineServer) InspectMachine ¶
func (UnimplementedMachineServer) InspectMachine(context.Context, *emptypb.Empty) (*InspectMachineResponse, error)
func (UnimplementedMachineServer) InspectService ¶
func (UnimplementedMachineServer) InspectService(context.Context, *InspectServiceRequest) (*InspectServiceResponse, error)
func (UnimplementedMachineServer) InspectWireGuardNetwork ¶
func (UnimplementedMachineServer) InspectWireGuardNetwork(context.Context, *emptypb.Empty) (*InspectWireGuardNetworkResponse, error)
func (UnimplementedMachineServer) JoinCluster ¶
func (UnimplementedMachineServer) JoinCluster(context.Context, *JoinClusterRequest) (*emptypb.Empty, error)
func (UnimplementedMachineServer) MachineLogs ¶
func (UnimplementedMachineServer) MachineLogs(*LogsRequest, grpc.ServerStreamingServer[LogEntry]) error
func (UnimplementedMachineServer) Reset ¶
func (UnimplementedMachineServer) Reset(context.Context, *ResetRequest) (*emptypb.Empty, error)
func (UnimplementedMachineServer) Token ¶
func (UnimplementedMachineServer) Token(context.Context, *emptypb.Empty) (*TokenResponse, error)
func (UnimplementedMachineServer) UpdateMachine ¶
func (UnimplementedMachineServer) UpdateMachine(context.Context, *UpdateMachineRequest) (*UpdateMachineResponse, error)
func (UnimplementedMachineServer) WaitForStoreVersion ¶
func (UnimplementedMachineServer) WaitForStoreVersion(context.Context, *WaitForStoreVersionRequest) (*emptypb.Empty, error)
type UnsafeCaddyServer ¶
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 UnsafeCaddyStorageServer ¶
type UnsafeCaddyStorageServer interface {
// contains filtered or unexported methods
}
UnsafeCaddyStorageServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CaddyStorageServer 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 ¶
type UpdateMachineRequest struct {
// Updated machine information. Only the set fields are applied.
Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"`
PublicIp *IP `protobuf:"bytes,2,opt,name=public_ip,json=publicIp,proto3,oneof" json:"public_ip,omitempty"`
Endpoints []*IPPort `protobuf:"bytes,3,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateMachineRequest) Descriptor
deprecated
func (*UpdateMachineRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateMachineRequest.ProtoReflect.Descriptor instead.
func (*UpdateMachineRequest) GetEndpoints ¶
func (x *UpdateMachineRequest) GetEndpoints() []*IPPort
func (*UpdateMachineRequest) GetName ¶
func (x *UpdateMachineRequest) GetName() string
func (*UpdateMachineRequest) GetPublicIp ¶
func (x *UpdateMachineRequest) GetPublicIp() *IP
func (*UpdateMachineRequest) ProtoMessage ¶
func (*UpdateMachineRequest) ProtoMessage()
func (*UpdateMachineRequest) ProtoReflect ¶
func (x *UpdateMachineRequest) ProtoReflect() protoreflect.Message
func (*UpdateMachineRequest) Reset ¶
func (x *UpdateMachineRequest) Reset()
func (*UpdateMachineRequest) String ¶
func (x *UpdateMachineRequest) String() string
type UpdateMachineResponse ¶
type UpdateMachineResponse struct {
Machine *MachineInfo `protobuf:"bytes,1,opt,name=machine,proto3" json:"machine,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateMachineResponse) Descriptor
deprecated
func (*UpdateMachineResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateMachineResponse.ProtoReflect.Descriptor instead.
func (*UpdateMachineResponse) GetMachine ¶
func (x *UpdateMachineResponse) GetMachine() *MachineInfo
func (*UpdateMachineResponse) ProtoMessage ¶
func (*UpdateMachineResponse) ProtoMessage()
func (*UpdateMachineResponse) ProtoReflect ¶
func (x *UpdateMachineResponse) ProtoReflect() protoreflect.Message
func (*UpdateMachineResponse) Reset ¶
func (x *UpdateMachineResponse) Reset()
func (*UpdateMachineResponse) String ¶
func (x *UpdateMachineResponse) String() string
type WaitForStoreVersionRequest ¶
type WaitForStoreVersionRequest struct {
// Minimum database version to reach for each Corrosion actor UUID.
// Obtain a vector from InspectMachine. To combine several responses, take the maximum version for each actor.
// Actors omitted from this vector and versions above its targets are not awaited. An empty vector requires
// no replication. Unknown actors with positive targets remain pending until replication reaches them or the RPC ends.
MinVersion map[string]uint64 `` /* 180-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*WaitForStoreVersionRequest) Descriptor
deprecated
func (*WaitForStoreVersionRequest) Descriptor() ([]byte, []int)
Deprecated: Use WaitForStoreVersionRequest.ProtoReflect.Descriptor instead.
func (*WaitForStoreVersionRequest) GetMinVersion ¶
func (x *WaitForStoreVersionRequest) GetMinVersion() map[string]uint64
func (*WaitForStoreVersionRequest) ProtoMessage ¶
func (*WaitForStoreVersionRequest) ProtoMessage()
func (*WaitForStoreVersionRequest) ProtoReflect ¶
func (x *WaitForStoreVersionRequest) ProtoReflect() protoreflect.Message
func (*WaitForStoreVersionRequest) Reset ¶
func (x *WaitForStoreVersionRequest) Reset()
func (*WaitForStoreVersionRequest) String ¶
func (x *WaitForStoreVersionRequest) String() string
type WireGuardPeer ¶
type WireGuardPeer struct {
PublicKey []byte `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
Endpoint string `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
LastHandshakeTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=last_handshake_time,json=lastHandshakeTime,proto3" json:"last_handshake_time,omitempty"`
ReceiveBytes int64 `protobuf:"varint,4,opt,name=receive_bytes,json=receiveBytes,proto3" json:"receive_bytes,omitempty"`
TransmitBytes int64 `protobuf:"varint,5,opt,name=transmit_bytes,json=transmitBytes,proto3" json:"transmit_bytes,omitempty"`
AllowedIps []string `protobuf:"bytes,6,rep,name=allowed_ips,json=allowedIps,proto3" json:"allowed_ips,omitempty"`
// contains filtered or unexported fields
}
func (*WireGuardPeer) Descriptor
deprecated
func (*WireGuardPeer) Descriptor() ([]byte, []int)
Deprecated: Use WireGuardPeer.ProtoReflect.Descriptor instead.
func (*WireGuardPeer) GetAllowedIps ¶
func (x *WireGuardPeer) GetAllowedIps() []string
func (*WireGuardPeer) GetEndpoint ¶
func (x *WireGuardPeer) GetEndpoint() string
func (*WireGuardPeer) GetLastHandshakeTime ¶
func (x *WireGuardPeer) GetLastHandshakeTime() *timestamppb.Timestamp
func (*WireGuardPeer) GetPublicKey ¶
func (x *WireGuardPeer) GetPublicKey() []byte
func (*WireGuardPeer) GetReceiveBytes ¶
func (x *WireGuardPeer) GetReceiveBytes() int64
func (*WireGuardPeer) GetTransmitBytes ¶
func (x *WireGuardPeer) GetTransmitBytes() int64
func (*WireGuardPeer) ProtoMessage ¶
func (*WireGuardPeer) ProtoMessage()
func (*WireGuardPeer) ProtoReflect ¶
func (x *WireGuardPeer) ProtoReflect() protoreflect.Message
func (*WireGuardPeer) Reset ¶
func (x *WireGuardPeer) Reset()
func (*WireGuardPeer) String ¶
func (x *WireGuardPeer) String() string