v1

package
v0.0.2-rc4 Latest Latest
Warning

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

 Go to latest Published: Nov 14, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthService        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowService          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupService = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterLeaseRPCServer 

func RegisterLeaseRPCServer(s grpc1.Server, srv LeaseRPCServer)

Types

type ForwarderPortStatus 

type ForwarderPortStatus struct {
	Host         string `protobuf:"bytes,1,opt,name=host,proto3" json:"host" yaml:"host"`
	Port         uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port" yaml:"port"`
	ExternalPort uint32 `protobuf:"varint,3,opt,name=external_port,json=externalPort,proto3" json:"external_port" yaml:"external_port"`
	Proto        string `protobuf:"bytes,4,opt,name=proto,proto3" json:"proto" yaml:"proto"`
	Name         string `protobuf:"bytes,5,opt,name=name,proto3" json:"name" yaml:"name"`
}

ForwarderPortStatus

func (*ForwarderPortStatus) Descriptor 

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

func (*ForwarderPortStatus) GetExternalPort 

func (m *ForwarderPortStatus) GetExternalPort() uint32

func (*ForwarderPortStatus) GetHost 

func (m *ForwarderPortStatus) GetHost() string

func (*ForwarderPortStatus) GetName 

func (m *ForwarderPortStatus) GetName() string

func (*ForwarderPortStatus) GetPort 

func (m *ForwarderPortStatus) GetPort() uint32

func (*ForwarderPortStatus) GetProto 

func (m *ForwarderPortStatus) GetProto() string

func (*ForwarderPortStatus) Marshal 

func (m *ForwarderPortStatus) Marshal() (dAtA []byte, err error)

func (*ForwarderPortStatus) MarshalTo 

func (m *ForwarderPortStatus) MarshalTo(dAtA []byte) (int, error)

func (*ForwarderPortStatus) MarshalToSizedBuffer 

func (m *ForwarderPortStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ForwarderPortStatus) ProtoMessage 

func (*ForwarderPortStatus) ProtoMessage()

func (*ForwarderPortStatus) Reset 

func (m *ForwarderPortStatus) Reset()

func (*ForwarderPortStatus) Size 

func (m *ForwarderPortStatus) Size() (n int)

func (*ForwarderPortStatus) String 

func (m *ForwarderPortStatus) String() string

func (*ForwarderPortStatus) Unmarshal 

func (m *ForwarderPortStatus) Unmarshal(dAtA []byte) error

func (*ForwarderPortStatus) XXX_DiscardUnknown 

func (m *ForwarderPortStatus) XXX_DiscardUnknown()

func (*ForwarderPortStatus) XXX_Marshal 

func (m *ForwarderPortStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ForwarderPortStatus) XXX_Merge 

func (m *ForwarderPortStatus) XXX_Merge(src proto.Message)

func (*ForwarderPortStatus) XXX_Size 

func (m *ForwarderPortStatus) XXX_Size() int

func (*ForwarderPortStatus) XXX_Unmarshal 

func (m *ForwarderPortStatus) XXX_Unmarshal(b []byte) error

type LeaseIPStatus 

type LeaseIPStatus struct {
	Port         uint32 `protobuf:"varint,1,opt,name=port,proto3" json:"port" yaml:"port"`
	ExternalPort uint32 `protobuf:"varint,2,opt,name=external_port,json=externalPort,proto3" json:"external_port" yaml:"external_port"`
	Protocol     string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol" yaml:"protocol"`
	Ip           string `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip" yaml:"ip"`
}

LeaseIPStatus

func (*LeaseIPStatus) Descriptor 

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

func (*LeaseIPStatus) GetExternalPort 

func (m *LeaseIPStatus) GetExternalPort() uint32

func (*LeaseIPStatus) GetIp 

func (m *LeaseIPStatus) GetIp() string

func (*LeaseIPStatus) GetPort 

func (m *LeaseIPStatus) GetPort() uint32

func (*LeaseIPStatus) GetProtocol 

func (m *LeaseIPStatus) GetProtocol() string

func (*LeaseIPStatus) Marshal 

func (m *LeaseIPStatus) Marshal() (dAtA []byte, err error)

func (*LeaseIPStatus) MarshalTo 

func (m *LeaseIPStatus) MarshalTo(dAtA []byte) (int, error)

func (*LeaseIPStatus) MarshalToSizedBuffer 

func (m *LeaseIPStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LeaseIPStatus) ProtoMessage 

func (*LeaseIPStatus) ProtoMessage()

func (*LeaseIPStatus) Reset 

func (m *LeaseIPStatus) Reset()

func (*LeaseIPStatus) Size 

func (m *LeaseIPStatus) Size() (n int)

func (*LeaseIPStatus) String 

func (m *LeaseIPStatus) String() string

func (*LeaseIPStatus) Unmarshal 

func (m *LeaseIPStatus) Unmarshal(dAtA []byte) error

func (*LeaseIPStatus) XXX_DiscardUnknown 

func (m *LeaseIPStatus) XXX_DiscardUnknown()

func (*LeaseIPStatus) XXX_Marshal 

func (m *LeaseIPStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LeaseIPStatus) XXX_Merge 

func (m *LeaseIPStatus) XXX_Merge(src proto.Message)

func (*LeaseIPStatus) XXX_Size 

func (m *LeaseIPStatus) XXX_Size() int

func (*LeaseIPStatus) XXX_Unmarshal 

func (m *LeaseIPStatus) XXX_Unmarshal(b []byte) error

type LeaseRPCClient 

type LeaseRPCClient interface {
	// SendManifest sends manifest to the provider
	SendManifest(ctx context.Context, in *SendManifestRequest, opts ...grpc.CallOption) (*SendManifestResponse, error)
	// ServiceStatus
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	ServiceStatus(ctx context.Context, in *ServiceStatusRequest, opts ...grpc.CallOption) (*ServiceStatusResponse, error)
	// StreamServiceStatus
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	StreamServiceStatus(ctx context.Context, in *ServiceStatusRequest, opts ...grpc.CallOption) (LeaseRPC_StreamServiceStatusClient, error)
	// ServiceLogs
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	ServiceLogs(ctx context.Context, in *ServiceLogsRequest, opts ...grpc.CallOption) (*ServiceLogsResponse, error)
	// StreamServiceLogs
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	StreamServiceLogs(ctx context.Context, in *ServiceLogsRequest, opts ...grpc.CallOption) (LeaseRPC_StreamServiceLogsClient, error)
}

LeaseRPCClient is the client API for LeaseRPC service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewLeaseRPCClient 

func NewLeaseRPCClient(cc grpc1.ClientConn) LeaseRPCClient

type LeaseRPCServer 

type LeaseRPCServer interface {
	// SendManifest sends manifest to the provider
	SendManifest(context.Context, *SendManifestRequest) (*SendManifestResponse, error)
	// ServiceStatus
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	ServiceStatus(context.Context, *ServiceStatusRequest) (*ServiceStatusResponse, error)
	// StreamServiceStatus
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	StreamServiceStatus(*ServiceStatusRequest, LeaseRPC_StreamServiceStatusServer) error
	// ServiceLogs
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	ServiceLogs(context.Context, *ServiceLogsRequest) (*ServiceLogsResponse, error)
	// StreamServiceLogs
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	StreamServiceLogs(*ServiceLogsRequest, LeaseRPC_StreamServiceLogsServer) error
}

LeaseRPCServer is the server API for LeaseRPC service.

type LeaseRPC_StreamServiceLogsClient 

type LeaseRPC_StreamServiceLogsClient interface {
	Recv() (*ServiceLogsResponse, error)
	grpc.ClientStream
}

type LeaseRPC_StreamServiceLogsServer 

type LeaseRPC_StreamServiceLogsServer interface {
	Send(*ServiceLogsResponse) error
	grpc.ServerStream
}

type LeaseRPC_StreamServiceStatusClient 

type LeaseRPC_StreamServiceStatusClient interface {
	Recv() (*ServiceStatusResponse, error)
	grpc.ClientStream
}

type LeaseRPC_StreamServiceStatusServer 

type LeaseRPC_StreamServiceStatusServer interface {
	Send(*ServiceStatusResponse) error
	grpc.ServerStream
}

type LeaseServiceStatus 

type LeaseServiceStatus struct {
	Available          int32    `protobuf:"varint,1,opt,name=available,proto3" json:"available,omitempty"`
	Total              int32    `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	Uris               []string `protobuf:"bytes,3,rep,name=uris,proto3" json:"uris,omitempty"`
	ObservedGeneration int64    `protobuf:"varint,4,opt,name=observed_generation,json=observedGeneration,proto3" json:"observed_generation,omitempty"`
	Replicas           int32    `protobuf:"varint,5,opt,name=replicas,proto3" json:"replicas,omitempty"`
	UpdatedReplicas    int32    `protobuf:"varint,6,opt,name=updated_replicas,json=updatedReplicas,proto3" json:"updated_replicas,omitempty"`
	ReadyReplicas      int32    `protobuf:"varint,7,opt,name=ready_replicas,json=readyReplicas,proto3" json:"ready_replicas,omitempty"`
	AvailableReplicas  int32    `protobuf:"varint,8,opt,name=available_replicas,json=availableReplicas,proto3" json:"available_replicas,omitempty"`
}

LeaseServiceStatus

func (*LeaseServiceStatus) Descriptor 

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

func (*LeaseServiceStatus) GetAvailable 

func (m *LeaseServiceStatus) GetAvailable() int32

func (*LeaseServiceStatus) GetAvailableReplicas 

func (m *LeaseServiceStatus) GetAvailableReplicas() int32

func (*LeaseServiceStatus) GetObservedGeneration 

func (m *LeaseServiceStatus) GetObservedGeneration() int64

func (*LeaseServiceStatus) GetReadyReplicas 

func (m *LeaseServiceStatus) GetReadyReplicas() int32

func (*LeaseServiceStatus) GetReplicas 

func (m *LeaseServiceStatus) GetReplicas() int32

func (*LeaseServiceStatus) GetTotal 

func (m *LeaseServiceStatus) GetTotal() int32

func (*LeaseServiceStatus) GetUpdatedReplicas 

func (m *LeaseServiceStatus) GetUpdatedReplicas() int32

func (*LeaseServiceStatus) GetUris 

func (m *LeaseServiceStatus) GetUris() []string

func (*LeaseServiceStatus) Marshal 

func (m *LeaseServiceStatus) Marshal() (dAtA []byte, err error)

func (*LeaseServiceStatus) MarshalTo 

func (m *LeaseServiceStatus) MarshalTo(dAtA []byte) (int, error)

func (*LeaseServiceStatus) MarshalToSizedBuffer 

func (m *LeaseServiceStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LeaseServiceStatus) ProtoMessage 

func (*LeaseServiceStatus) ProtoMessage()

func (*LeaseServiceStatus) Reset 

func (m *LeaseServiceStatus) Reset()

func (*LeaseServiceStatus) Size 

func (m *LeaseServiceStatus) Size() (n int)

func (*LeaseServiceStatus) String 

func (m *LeaseServiceStatus) String() string

func (*LeaseServiceStatus) Unmarshal 

func (m *LeaseServiceStatus) Unmarshal(dAtA []byte) error

func (*LeaseServiceStatus) XXX_DiscardUnknown 

func (m *LeaseServiceStatus) XXX_DiscardUnknown()

func (*LeaseServiceStatus) XXX_Marshal 

func (m *LeaseServiceStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LeaseServiceStatus) XXX_Merge 

func (m *LeaseServiceStatus) XXX_Merge(src proto.Message)

func (*LeaseServiceStatus) XXX_Size 

func (m *LeaseServiceStatus) XXX_Size() int

func (*LeaseServiceStatus) XXX_Unmarshal 

func (m *LeaseServiceStatus) XXX_Unmarshal(b []byte) error

type SendManifestRequest 

type SendManifestRequest struct {
	LeaseId  v1.LeaseID                               `protobuf:"bytes,1,opt,name=lease_id,json=leaseId,proto3" json:"LeaseID" yaml:"LeaseID"`
	Manifest pkg_akt_dev_go_manifest_v2beta3.Manifest `` /* 129-byte string literal not displayed */
}

SendManifestRequest is request type for the SendManifest Providers RPC method

func (*SendManifestRequest) Descriptor 

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

func (*SendManifestRequest) GetLeaseId 

func (m *SendManifestRequest) GetLeaseId() v1.LeaseID

func (*SendManifestRequest) GetManifest 

func (m *SendManifestRequest) GetManifest() pkg_akt_dev_go_manifest_v2beta3.Manifest

func (*SendManifestRequest) Marshal 

func (m *SendManifestRequest) Marshal() (dAtA []byte, err error)

func (*SendManifestRequest) MarshalTo 

func (m *SendManifestRequest) MarshalTo(dAtA []byte) (int, error)

func (*SendManifestRequest) MarshalToSizedBuffer 

func (m *SendManifestRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SendManifestRequest) ProtoMessage 

func (*SendManifestRequest) ProtoMessage()

func (*SendManifestRequest) Reset 

func (m *SendManifestRequest) Reset()

func (*SendManifestRequest) Size 

func (m *SendManifestRequest) Size() (n int)

func (*SendManifestRequest) String 

func (m *SendManifestRequest) String() string

func (*SendManifestRequest) Unmarshal 

func (m *SendManifestRequest) Unmarshal(dAtA []byte) error

func (*SendManifestRequest) XXX_DiscardUnknown 

func (m *SendManifestRequest) XXX_DiscardUnknown()

func (*SendManifestRequest) XXX_Marshal 

func (m *SendManifestRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SendManifestRequest) XXX_Merge 

func (m *SendManifestRequest) XXX_Merge(src proto.Message)

func (*SendManifestRequest) XXX_Size 

func (m *SendManifestRequest) XXX_Size() int

func (*SendManifestRequest) XXX_Unmarshal 

func (m *SendManifestRequest) XXX_Unmarshal(b []byte) error

type SendManifestResponse 

type SendManifestResponse struct {
}

SendManifestResponse is response type for the SendManifest Providers RPC method

func (*SendManifestResponse) Descriptor 

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

func (*SendManifestResponse) Marshal 

func (m *SendManifestResponse) Marshal() (dAtA []byte, err error)

func (*SendManifestResponse) MarshalTo 

func (m *SendManifestResponse) MarshalTo(dAtA []byte) (int, error)

func (*SendManifestResponse) MarshalToSizedBuffer 

func (m *SendManifestResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SendManifestResponse) ProtoMessage 

func (*SendManifestResponse) ProtoMessage()

func (*SendManifestResponse) Reset 

func (m *SendManifestResponse) Reset()

func (*SendManifestResponse) Size 

func (m *SendManifestResponse) Size() (n int)

func (*SendManifestResponse) String 

func (m *SendManifestResponse) String() string

func (*SendManifestResponse) Unmarshal 

func (m *SendManifestResponse) Unmarshal(dAtA []byte) error

func (*SendManifestResponse) XXX_DiscardUnknown 

func (m *SendManifestResponse) XXX_DiscardUnknown()

func (*SendManifestResponse) XXX_Marshal 

func (m *SendManifestResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SendManifestResponse) XXX_Merge 

func (m *SendManifestResponse) XXX_Merge(src proto.Message)

func (*SendManifestResponse) XXX_Size 

func (m *SendManifestResponse) XXX_Size() int

func (*SendManifestResponse) XXX_Unmarshal 

func (m *SendManifestResponse) XXX_Unmarshal(b []byte) error

type ServiceLogs 

type ServiceLogs struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name" yaml:"name"`
	Logs []byte `protobuf:"bytes,2,opt,name=logs,proto3" json:"logs" yaml:"logs"`
}

ServiceLogs

func (*ServiceLogs) Descriptor 

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

func (*ServiceLogs) GetLogs 

func (m *ServiceLogs) GetLogs() []byte

func (*ServiceLogs) GetName 

func (m *ServiceLogs) GetName() string

func (*ServiceLogs) Marshal 

func (m *ServiceLogs) Marshal() (dAtA []byte, err error)

func (*ServiceLogs) MarshalTo 

func (m *ServiceLogs) MarshalTo(dAtA []byte) (int, error)

func (*ServiceLogs) MarshalToSizedBuffer 

func (m *ServiceLogs) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceLogs) ProtoMessage 

func (*ServiceLogs) ProtoMessage()

func (*ServiceLogs) Reset 

func (m *ServiceLogs) Reset()

func (*ServiceLogs) Size 

func (m *ServiceLogs) Size() (n int)

func (*ServiceLogs) String 

func (m *ServiceLogs) String() string

func (*ServiceLogs) Unmarshal 

func (m *ServiceLogs) Unmarshal(dAtA []byte) error

func (*ServiceLogs) XXX_DiscardUnknown 

func (m *ServiceLogs) XXX_DiscardUnknown()

func (*ServiceLogs) XXX_Marshal 

func (m *ServiceLogs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceLogs) XXX_Merge 

func (m *ServiceLogs) XXX_Merge(src proto.Message)

func (*ServiceLogs) XXX_Size 

func (m *ServiceLogs) XXX_Size() int

func (*ServiceLogs) XXX_Unmarshal 

func (m *ServiceLogs) XXX_Unmarshal(b []byte) error

type ServiceLogsRequest 

type ServiceLogsRequest struct {
	LeaseId  v1.LeaseID `protobuf:"bytes,1,opt,name=lease_id,json=leaseId,proto3" json:"LeaseID" yaml:"LeaseID"`
	Services []string   `protobuf:"bytes,2,rep,name=services,proto3" json:"services" yaml:"services"`
}

ServiceLogsRequest

func (*ServiceLogsRequest) Descriptor 

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

func (*ServiceLogsRequest) GetLeaseId 

func (m *ServiceLogsRequest) GetLeaseId() v1.LeaseID

func (*ServiceLogsRequest) GetServices 

func (m *ServiceLogsRequest) GetServices() []string

func (*ServiceLogsRequest) Marshal 

func (m *ServiceLogsRequest) Marshal() (dAtA []byte, err error)

func (*ServiceLogsRequest) MarshalTo 

func (m *ServiceLogsRequest) MarshalTo(dAtA []byte) (int, error)

func (*ServiceLogsRequest) MarshalToSizedBuffer 

func (m *ServiceLogsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceLogsRequest) ProtoMessage 

func (*ServiceLogsRequest) ProtoMessage()

func (*ServiceLogsRequest) Reset 

func (m *ServiceLogsRequest) Reset()

func (*ServiceLogsRequest) Size 

func (m *ServiceLogsRequest) Size() (n int)

func (*ServiceLogsRequest) String 

func (m *ServiceLogsRequest) String() string

func (*ServiceLogsRequest) Unmarshal 

func (m *ServiceLogsRequest) Unmarshal(dAtA []byte) error

func (*ServiceLogsRequest) XXX_DiscardUnknown 

func (m *ServiceLogsRequest) XXX_DiscardUnknown()

func (*ServiceLogsRequest) XXX_Marshal 

func (m *ServiceLogsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceLogsRequest) XXX_Merge 

func (m *ServiceLogsRequest) XXX_Merge(src proto.Message)

func (*ServiceLogsRequest) XXX_Size 

func (m *ServiceLogsRequest) XXX_Size() int

func (*ServiceLogsRequest) XXX_Unmarshal 

func (m *ServiceLogsRequest) XXX_Unmarshal(b []byte) error

type ServiceLogsResponse 

type ServiceLogsResponse struct {
	Services []*ServiceLogs `protobuf:"bytes,1,rep,name=services,proto3" json:"LeaseID" yaml:"LeaseID"`
}

ServiceLogsResponse

func (*ServiceLogsResponse) Descriptor 

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

func (*ServiceLogsResponse) GetServices 

func (m *ServiceLogsResponse) GetServices() []*ServiceLogs

func (*ServiceLogsResponse) Marshal 

func (m *ServiceLogsResponse) Marshal() (dAtA []byte, err error)

func (*ServiceLogsResponse) MarshalTo 

func (m *ServiceLogsResponse) MarshalTo(dAtA []byte) (int, error)

func (*ServiceLogsResponse) MarshalToSizedBuffer 

func (m *ServiceLogsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceLogsResponse) ProtoMessage 

func (*ServiceLogsResponse) ProtoMessage()

func (*ServiceLogsResponse) Reset 

func (m *ServiceLogsResponse) Reset()

func (*ServiceLogsResponse) Size 

func (m *ServiceLogsResponse) Size() (n int)

func (*ServiceLogsResponse) String 

func (m *ServiceLogsResponse) String() string

func (*ServiceLogsResponse) Unmarshal 

func (m *ServiceLogsResponse) Unmarshal(dAtA []byte) error

func (*ServiceLogsResponse) XXX_DiscardUnknown 

func (m *ServiceLogsResponse) XXX_DiscardUnknown()

func (*ServiceLogsResponse) XXX_Marshal 

func (m *ServiceLogsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceLogsResponse) XXX_Merge 

func (m *ServiceLogsResponse) XXX_Merge(src proto.Message)

func (*ServiceLogsResponse) XXX_Size 

func (m *ServiceLogsResponse) XXX_Size() int

func (*ServiceLogsResponse) XXX_Unmarshal 

func (m *ServiceLogsResponse) XXX_Unmarshal(b []byte) error

type ServiceStatus 

type ServiceStatus struct {
	Name   string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name" yaml:"name"`
	Status LeaseServiceStatus    `protobuf:"bytes,2,opt,name=status,proto3" json:"status" yaml:"status"`
	Ports  []ForwarderPortStatus `protobuf:"bytes,3,rep,name=ports,proto3" json:"ports" yaml:"ports"`
	Ips    []LeaseIPStatus       `protobuf:"bytes,4,rep,name=ips,proto3" json:"ip" yaml:"ip"`
}

ServiceStatus

func (*ServiceStatus) Descriptor 

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

func (*ServiceStatus) GetIps 

func (m *ServiceStatus) GetIps() []LeaseIPStatus

func (*ServiceStatus) GetName 

func (m *ServiceStatus) GetName() string

func (*ServiceStatus) GetPorts 

func (m *ServiceStatus) GetPorts() []ForwarderPortStatus

func (*ServiceStatus) GetStatus 

func (m *ServiceStatus) GetStatus() LeaseServiceStatus

func (*ServiceStatus) Marshal 

func (m *ServiceStatus) Marshal() (dAtA []byte, err error)

func (*ServiceStatus) MarshalTo 

func (m *ServiceStatus) MarshalTo(dAtA []byte) (int, error)

func (*ServiceStatus) MarshalToSizedBuffer 

func (m *ServiceStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceStatus) ProtoMessage 

func (*ServiceStatus) ProtoMessage()

func (*ServiceStatus) Reset 

func (m *ServiceStatus) Reset()

func (*ServiceStatus) Size 

func (m *ServiceStatus) Size() (n int)

func (*ServiceStatus) String 

func (m *ServiceStatus) String() string

func (*ServiceStatus) Unmarshal 

func (m *ServiceStatus) Unmarshal(dAtA []byte) error

func (*ServiceStatus) XXX_DiscardUnknown 

func (m *ServiceStatus) XXX_DiscardUnknown()

func (*ServiceStatus) XXX_Marshal 

func (m *ServiceStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceStatus) XXX_Merge 

func (m *ServiceStatus) XXX_Merge(src proto.Message)

func (*ServiceStatus) XXX_Size 

func (m *ServiceStatus) XXX_Size() int

func (*ServiceStatus) XXX_Unmarshal 

func (m *ServiceStatus) XXX_Unmarshal(b []byte) error

type ServiceStatusRequest 

type ServiceStatusRequest struct {
	LeaseId  v1.LeaseID `protobuf:"bytes,1,opt,name=lease_id,json=leaseId,proto3" json:"LeaseID" yaml:"LeaseID"`
	Services []string   `protobuf:"bytes,2,rep,name=services,proto3" json:"services" yaml:"services"`
}

ServiceStatusRequest

func (*ServiceStatusRequest) Descriptor 

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

func (*ServiceStatusRequest) GetLeaseId 

func (m *ServiceStatusRequest) GetLeaseId() v1.LeaseID

func (*ServiceStatusRequest) GetServices 

func (m *ServiceStatusRequest) GetServices() []string

func (*ServiceStatusRequest) Marshal 

func (m *ServiceStatusRequest) Marshal() (dAtA []byte, err error)

func (*ServiceStatusRequest) MarshalTo 

func (m *ServiceStatusRequest) MarshalTo(dAtA []byte) (int, error)

func (*ServiceStatusRequest) MarshalToSizedBuffer 

func (m *ServiceStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceStatusRequest) ProtoMessage 

func (*ServiceStatusRequest) ProtoMessage()

func (*ServiceStatusRequest) Reset 

func (m *ServiceStatusRequest) Reset()

func (*ServiceStatusRequest) Size 

func (m *ServiceStatusRequest) Size() (n int)

func (*ServiceStatusRequest) String 

func (m *ServiceStatusRequest) String() string

func (*ServiceStatusRequest) Unmarshal 

func (m *ServiceStatusRequest) Unmarshal(dAtA []byte) error

func (*ServiceStatusRequest) XXX_DiscardUnknown 

func (m *ServiceStatusRequest) XXX_DiscardUnknown()

func (*ServiceStatusRequest) XXX_Marshal 

func (m *ServiceStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceStatusRequest) XXX_Merge 

func (m *ServiceStatusRequest) XXX_Merge(src proto.Message)

func (*ServiceStatusRequest) XXX_Size 

func (m *ServiceStatusRequest) XXX_Size() int

func (*ServiceStatusRequest) XXX_Unmarshal 

func (m *ServiceStatusRequest) XXX_Unmarshal(b []byte) error

type ServiceStatusResponse 

type ServiceStatusResponse struct {
	Services []ServiceStatus `protobuf:"bytes,1,rep,name=services,proto3" json:"services" yaml:"services"`
}

ServiceStatusResponse

func (*ServiceStatusResponse) Descriptor 

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

func (*ServiceStatusResponse) GetServices 

func (m *ServiceStatusResponse) GetServices() []ServiceStatus

func (*ServiceStatusResponse) Marshal 

func (m *ServiceStatusResponse) Marshal() (dAtA []byte, err error)

func (*ServiceStatusResponse) MarshalTo 

func (m *ServiceStatusResponse) MarshalTo(dAtA []byte) (int, error)

func (*ServiceStatusResponse) MarshalToSizedBuffer 

func (m *ServiceStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceStatusResponse) ProtoMessage 

func (*ServiceStatusResponse) ProtoMessage()

func (*ServiceStatusResponse) Reset 

func (m *ServiceStatusResponse) Reset()

func (*ServiceStatusResponse) Size 

func (m *ServiceStatusResponse) Size() (n int)

func (*ServiceStatusResponse) String 

func (m *ServiceStatusResponse) String() string

func (*ServiceStatusResponse) Unmarshal 

func (m *ServiceStatusResponse) Unmarshal(dAtA []byte) error

func (*ServiceStatusResponse) XXX_DiscardUnknown 

func (m *ServiceStatusResponse) XXX_DiscardUnknown()

func (*ServiceStatusResponse) XXX_Marshal 

func (m *ServiceStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceStatusResponse) XXX_Merge 

func (m *ServiceStatusResponse) XXX_Merge(src proto.Message)

func (*ServiceStatusResponse) XXX_Size 

func (m *ServiceStatusResponse) XXX_Size() int

func (*ServiceStatusResponse) XXX_Unmarshal 

func (m *ServiceStatusResponse) XXX_Unmarshal(b []byte) error

type ShellRequest 

type ShellRequest struct {
	LeaseId v1.LeaseID `protobuf:"bytes,1,opt,name=lease_id,json=leaseId,proto3" json:"LeaseID" yaml:"LeaseID"`
}

ShellRequest

func (*ShellRequest) Descriptor 

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

func (*ShellRequest) GetLeaseId 

func (m *ShellRequest) GetLeaseId() v1.LeaseID

func (*ShellRequest) Marshal 

func (m *ShellRequest) Marshal() (dAtA []byte, err error)

func (*ShellRequest) MarshalTo 

func (m *ShellRequest) MarshalTo(dAtA []byte) (int, error)

func (*ShellRequest) MarshalToSizedBuffer 

func (m *ShellRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ShellRequest) ProtoMessage 

func (*ShellRequest) ProtoMessage()

func (*ShellRequest) Reset 

func (m *ShellRequest) Reset()

func (*ShellRequest) Size 

func (m *ShellRequest) Size() (n int)

func (*ShellRequest) String 

func (m *ShellRequest) String() string

func (*ShellRequest) Unmarshal 

func (m *ShellRequest) Unmarshal(dAtA []byte) error

func (*ShellRequest) XXX_DiscardUnknown 

func (m *ShellRequest) XXX_DiscardUnknown()

func (*ShellRequest) XXX_Marshal 

func (m *ShellRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShellRequest) XXX_Merge 

func (m *ShellRequest) XXX_Merge(src proto.Message)

func (*ShellRequest) XXX_Size 

func (m *ShellRequest) XXX_Size() int

func (*ShellRequest) XXX_Unmarshal 

func (m *ShellRequest) XXX_Unmarshal(b []byte) error

type UnimplementedLeaseRPCServer 

type UnimplementedLeaseRPCServer struct {
}

UnimplementedLeaseRPCServer can be embedded to have forward compatible implementations.

func (*UnimplementedLeaseRPCServer) SendManifest 

func (*UnimplementedLeaseRPCServer) SendManifest(ctx context.Context, req *SendManifestRequest) (*SendManifestResponse, error)

func (*UnimplementedLeaseRPCServer) ServiceLogs 

func (*UnimplementedLeaseRPCServer) ServiceLogs(ctx context.Context, req *ServiceLogsRequest) (*ServiceLogsResponse, error)

func (*UnimplementedLeaseRPCServer) ServiceStatus 

func (*UnimplementedLeaseRPCServer) ServiceStatus(ctx context.Context, req *ServiceStatusRequest) (*ServiceStatusResponse, error)

func (*UnimplementedLeaseRPCServer) StreamServiceLogs 

func (*UnimplementedLeaseRPCServer) StreamServiceLogs(req *ServiceLogsRequest, srv LeaseRPC_StreamServiceLogsServer) error

func (*UnimplementedLeaseRPCServer) StreamServiceStatus 

func (*UnimplementedLeaseRPCServer) StreamServiceStatus(req *ServiceStatusRequest, srv LeaseRPC_StreamServiceStatusServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.