Documentation ¶
Index ¶
- Variables
- func RegisterAgentServiceServer(s *grpc.Server, srv AgentServiceServer)
- type AgentServiceClient
- type AgentServiceServer
- type AgentService_HeartbeatClient
- type AgentService_HeartbeatServer
- type AgentService_SyncClient
- type AgentService_SyncServer
- type CreateServiceRequest
- func (*CreateServiceRequest) Descriptor() ([]byte, []int)
- func (m *CreateServiceRequest) GetEncryptionMethod() ServiceEncryptionMethod_Enum
- func (m *CreateServiceRequest) GetNodeId() string
- func (m *CreateServiceRequest) GetPassword() string
- func (m *CreateServiceRequest) GetPortFrom() int32
- func (m *CreateServiceRequest) GetPortTo() int32
- func (m *CreateServiceRequest) GetType() ServiceType_Enum
- func (m *CreateServiceRequest) GetUserId() string
- func (*CreateServiceRequest) ProtoMessage()
- func (m *CreateServiceRequest) Reset()
- func (m *CreateServiceRequest) String() string
- func (m *CreateServiceRequest) XXX_DiscardUnknown()
- func (m *CreateServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateServiceRequest) XXX_Merge(src proto.Message)
- func (m *CreateServiceRequest) XXX_Size() int
- func (m *CreateServiceRequest) XXX_Unmarshal(b []byte) error
- type CreateServiceResponse
- func (*CreateServiceResponse) Descriptor() ([]byte, []int)
- func (m *CreateServiceResponse) GetContainerId() string
- func (m *CreateServiceResponse) GetContainerName() string
- func (m *CreateServiceResponse) GetPort() int32
- func (*CreateServiceResponse) ProtoMessage()
- func (m *CreateServiceResponse) Reset()
- func (m *CreateServiceResponse) String() string
- func (m *CreateServiceResponse) XXX_DiscardUnknown()
- func (m *CreateServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateServiceResponse) XXX_Merge(src proto.Message)
- func (m *CreateServiceResponse) XXX_Size() int
- func (m *CreateServiceResponse) XXX_Unmarshal(b []byte) error
- type EmptyRequest
- func (*EmptyRequest) Descriptor() ([]byte, []int)
- func (*EmptyRequest) ProtoMessage()
- func (m *EmptyRequest) Reset()
- func (m *EmptyRequest) String() string
- func (m *EmptyRequest) XXX_DiscardUnknown()
- func (m *EmptyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EmptyRequest) XXX_Merge(src proto.Message)
- func (m *EmptyRequest) XXX_Size() int
- func (m *EmptyRequest) XXX_Unmarshal(b []byte) error
- type EmptyResponse
- func (*EmptyResponse) Descriptor() ([]byte, []int)
- func (*EmptyResponse) ProtoMessage()
- func (m *EmptyResponse) Reset()
- func (m *EmptyResponse) String() string
- func (m *EmptyResponse) XXX_DiscardUnknown()
- func (m *EmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EmptyResponse) XXX_Merge(src proto.Message)
- func (m *EmptyResponse) XXX_Size() int
- func (m *EmptyResponse) XXX_Unmarshal(b []byte) error
- type HeartbeatRequest
- func (*HeartbeatRequest) Descriptor() ([]byte, []int)
- func (m *HeartbeatRequest) GetInterval() *duration.Duration
- func (*HeartbeatRequest) ProtoMessage()
- func (m *HeartbeatRequest) Reset()
- func (m *HeartbeatRequest) String() string
- func (m *HeartbeatRequest) XXX_DiscardUnknown()
- func (m *HeartbeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HeartbeatRequest) XXX_Merge(src proto.Message)
- func (m *HeartbeatRequest) XXX_Size() int
- func (m *HeartbeatRequest) XXX_Unmarshal(b []byte) error
- type HeartbeatStreamServer
- func (*HeartbeatStreamServer) Descriptor() ([]byte, []int)
- func (*HeartbeatStreamServer) ProtoMessage()
- func (m *HeartbeatStreamServer) Reset()
- func (m *HeartbeatStreamServer) String() string
- func (m *HeartbeatStreamServer) XXX_DiscardUnknown()
- func (m *HeartbeatStreamServer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HeartbeatStreamServer) XXX_Merge(src proto.Message)
- func (m *HeartbeatStreamServer) XXX_Size() int
- func (m *HeartbeatStreamServer) XXX_Unmarshal(b []byte) error
- type RemoveServiceRequest
- func (*RemoveServiceRequest) Descriptor() ([]byte, []int)
- func (m *RemoveServiceRequest) GetContainerId() string
- func (*RemoveServiceRequest) ProtoMessage()
- func (m *RemoveServiceRequest) Reset()
- func (m *RemoveServiceRequest) String() string
- func (m *RemoveServiceRequest) XXX_DiscardUnknown()
- func (m *RemoveServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RemoveServiceRequest) XXX_Merge(src proto.Message)
- func (m *RemoveServiceRequest) XXX_Size() int
- func (m *RemoveServiceRequest) XXX_Unmarshal(b []byte) error
- type ServiceEncryptionMethod
- func (*ServiceEncryptionMethod) Descriptor() ([]byte, []int)
- func (*ServiceEncryptionMethod) ProtoMessage()
- func (m *ServiceEncryptionMethod) Reset()
- func (m *ServiceEncryptionMethod) String() string
- func (m *ServiceEncryptionMethod) XXX_DiscardUnknown()
- func (m *ServiceEncryptionMethod) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceEncryptionMethod) XXX_Merge(src proto.Message)
- func (m *ServiceEncryptionMethod) XXX_Size() int
- func (m *ServiceEncryptionMethod) XXX_Unmarshal(b []byte) error
- type ServiceEncryptionMethod_Enum
- func (ServiceEncryptionMethod_Enum) EnumDescriptor() ([]byte, []int)
- func (x ServiceEncryptionMethod_Enum) MarshalJSON() ([]byte, error)
- func (x ServiceEncryptionMethod_Enum) String() string
- func (x *ServiceEncryptionMethod_Enum) UnmarshalJSON(data []byte) error
- func (x ServiceEncryptionMethod_Enum) ValidMethod() string
- type ServiceInfo
- func (*ServiceInfo) Descriptor() ([]byte, []int)
- func (m *ServiceInfo) GetContainerId() string
- func (m *ServiceInfo) GetContainerName() string
- func (m *ServiceInfo) GetStatsResult() int64
- func (m *ServiceInfo) GetStatus() ServiceStatus_Enum
- func (*ServiceInfo) ProtoMessage()
- func (m *ServiceInfo) Reset()
- func (m *ServiceInfo) String() string
- func (m *ServiceInfo) XXX_DiscardUnknown()
- func (m *ServiceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceInfo) XXX_Merge(src proto.Message)
- func (m *ServiceInfo) XXX_Size() int
- func (m *ServiceInfo) XXX_Unmarshal(b []byte) error
- type ServiceStatus
- func (*ServiceStatus) Descriptor() ([]byte, []int)
- func (*ServiceStatus) ProtoMessage()
- func (m *ServiceStatus) Reset()
- func (m *ServiceStatus) String() string
- func (m *ServiceStatus) XXX_DiscardUnknown()
- func (m *ServiceStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceStatus) XXX_Merge(src proto.Message)
- func (m *ServiceStatus) XXX_Size() int
- func (m *ServiceStatus) XXX_Unmarshal(b []byte) error
- type ServiceStatus_Enum
- type ServiceType
- func (*ServiceType) Descriptor() ([]byte, []int)
- func (*ServiceType) ProtoMessage()
- func (m *ServiceType) Reset()
- func (m *ServiceType) String() string
- func (m *ServiceType) XXX_DiscardUnknown()
- func (m *ServiceType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceType) XXX_Merge(src proto.Message)
- func (m *ServiceType) XXX_Size() int
- func (m *ServiceType) XXX_Unmarshal(b []byte) error
- type ServiceType_Enum
- func (ServiceType_Enum) EnumDescriptor() ([]byte, []int)
- func (x ServiceType_Enum) ImageName() string
- func (x ServiceType_Enum) MarshalJSON() ([]byte, error)
- func (x ServiceType_Enum) String() string
- func (x ServiceType_Enum) Suit(m ServiceEncryptionMethod_Enum) bool
- func (x *ServiceType_Enum) UnmarshalJSON(data []byte) error
- type StartServiceRequest
- func (*StartServiceRequest) Descriptor() ([]byte, []int)
- func (m *StartServiceRequest) GetContainerId() string
- func (*StartServiceRequest) ProtoMessage()
- func (m *StartServiceRequest) Reset()
- func (m *StartServiceRequest) String() string
- func (m *StartServiceRequest) XXX_DiscardUnknown()
- func (m *StartServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartServiceRequest) XXX_Merge(src proto.Message)
- func (m *StartServiceRequest) XXX_Size() int
- func (m *StartServiceRequest) XXX_Unmarshal(b []byte) error
- type StopServiceRequest
- func (*StopServiceRequest) Descriptor() ([]byte, []int)
- func (m *StopServiceRequest) GetContainerId() string
- func (*StopServiceRequest) ProtoMessage()
- func (m *StopServiceRequest) Reset()
- func (m *StopServiceRequest) String() string
- func (m *StopServiceRequest) XXX_DiscardUnknown()
- func (m *StopServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StopServiceRequest) XXX_Merge(src proto.Message)
- func (m *StopServiceRequest) XXX_Size() int
- func (m *StopServiceRequest) XXX_Unmarshal(b []byte) error
- type SyncRequest
- func (*SyncRequest) Descriptor() ([]byte, []int)
- func (m *SyncRequest) GetNodeId() string
- func (m *SyncRequest) GetSyncInterval() *duration.Duration
- func (*SyncRequest) ProtoMessage()
- func (m *SyncRequest) Reset()
- func (m *SyncRequest) String() string
- func (m *SyncRequest) XXX_DiscardUnknown()
- func (m *SyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SyncRequest) XXX_Merge(src proto.Message)
- func (m *SyncRequest) XXX_Size() int
- func (m *SyncRequest) XXX_Unmarshal(b []byte) error
- type SyncStreamServer
- func (*SyncStreamServer) Descriptor() ([]byte, []int)
- func (m *SyncStreamServer) GetServices() []*ServiceInfo
- func (*SyncStreamServer) ProtoMessage()
- func (m *SyncStreamServer) Reset()
- func (m *SyncStreamServer) String() string
- func (m *SyncStreamServer) XXX_DiscardUnknown()
- func (m *SyncStreamServer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SyncStreamServer) XXX_Merge(src proto.Message)
- func (m *SyncStreamServer) XXX_Size() int
- func (m *SyncStreamServer) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ServiceEncryptionMethod_Enum_name = map[int32]string{
0: "NOT_SET",
1: "AES_256_CFB",
2: "AES_128_GCM",
3: "AES_192_GCM",
4: "AES_256_GCM",
5: "CHACHA20_IETF_POLY1305",
6: "AES_256_CTR",
7: "CHACHA20",
8: "CHACHA20_IETF",
}
View Source
var ServiceEncryptionMethod_Enum_value = map[string]int32{
"NOT_SET": 0,
"AES_256_CFB": 1,
"AES_128_GCM": 2,
"AES_192_GCM": 3,
"AES_256_GCM": 4,
"CHACHA20_IETF_POLY1305": 5,
"AES_256_CTR": 6,
"CHACHA20": 7,
"CHACHA20_IETF": 8,
}
View Source
var ServiceName = _AgentService_serviceDesc.ServiceName
View Source
var ServiceStatus_Enum_name = map[int32]string{
0: "NOT_SET",
1: "RUNNING",
2: "STOPPED",
}
View Source
var ServiceStatus_Enum_value = map[string]int32{
"NOT_SET": 0,
"RUNNING": 1,
"STOPPED": 2,
}
View Source
var ServiceType_Enum_name = map[int32]string{
0: "NOT_SET",
1: "SS_LIBEV",
2: "SSR",
}
View Source
var ServiceType_Enum_value = map[string]int32{
"NOT_SET": 0,
"SS_LIBEV": 1,
"SSR": 2,
}
Functions ¶
func RegisterAgentServiceServer ¶
func RegisterAgentServiceServer(s *grpc.Server, srv AgentServiceServer)
Types ¶
type AgentServiceClient ¶
type AgentServiceClient interface { Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (AgentService_HeartbeatClient, error) Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (AgentService_SyncClient, error) CreateService(ctx context.Context, in *CreateServiceRequest, opts ...grpc.CallOption) (*CreateServiceResponse, error) StopService(ctx context.Context, in *StopServiceRequest, opts ...grpc.CallOption) (*EmptyResponse, error) StartService(ctx context.Context, in *StartServiceRequest, opts ...grpc.CallOption) (*EmptyResponse, error) RemoveService(ctx context.Context, in *RemoveServiceRequest, opts ...grpc.CallOption) (*EmptyResponse, error) }
AgentServiceClient is the client API for AgentService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAgentServiceClient ¶
func NewAgentServiceClient(cc *grpc.ClientConn) AgentServiceClient
type AgentServiceServer ¶
type AgentServiceServer interface { Heartbeat(*HeartbeatRequest, AgentService_HeartbeatServer) error Sync(*SyncRequest, AgentService_SyncServer) error CreateService(context.Context, *CreateServiceRequest) (*CreateServiceResponse, error) StopService(context.Context, *StopServiceRequest) (*EmptyResponse, error) StartService(context.Context, *StartServiceRequest) (*EmptyResponse, error) RemoveService(context.Context, *RemoveServiceRequest) (*EmptyResponse, error) }
AgentServiceServer is the server API for AgentService service.
type AgentService_HeartbeatClient ¶
type AgentService_HeartbeatClient interface { Recv() (*HeartbeatStreamServer, error) grpc.ClientStream }
type AgentService_HeartbeatServer ¶
type AgentService_HeartbeatServer interface { Send(*HeartbeatStreamServer) error grpc.ServerStream }
type AgentService_SyncClient ¶
type AgentService_SyncClient interface { Recv() (*SyncStreamServer, error) grpc.ClientStream }
type AgentService_SyncServer ¶
type AgentService_SyncServer interface { Send(*SyncStreamServer) error grpc.ServerStream }
type CreateServiceRequest ¶
type CreateServiceRequest struct { PortFrom int32 `protobuf:"varint,1,opt,name=port_from,json=portFrom,proto3" json:"port_from,omitempty"` PortTo int32 `protobuf:"varint,2,opt,name=port_to,json=portTo,proto3" json:"port_to,omitempty"` Type ServiceType_Enum `protobuf:"varint,3,opt,name=type,proto3,enum=ServiceType_Enum" json:"type,omitempty"` EncryptionMethod ServiceEncryptionMethod_Enum `` /* 144-byte string literal not displayed */ Password string `protobuf:"bytes,5,opt,name=password,proto3" json:"password,omitempty"` UserId string `protobuf:"bytes,6,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` NodeId string `protobuf:"bytes,7,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateServiceRequest) Descriptor ¶
func (*CreateServiceRequest) Descriptor() ([]byte, []int)
func (*CreateServiceRequest) GetEncryptionMethod ¶
func (m *CreateServiceRequest) GetEncryptionMethod() ServiceEncryptionMethod_Enum
func (*CreateServiceRequest) GetNodeId ¶
func (m *CreateServiceRequest) GetNodeId() string
func (*CreateServiceRequest) GetPassword ¶
func (m *CreateServiceRequest) GetPassword() string
func (*CreateServiceRequest) GetPortFrom ¶
func (m *CreateServiceRequest) GetPortFrom() int32
func (*CreateServiceRequest) GetPortTo ¶
func (m *CreateServiceRequest) GetPortTo() int32
func (*CreateServiceRequest) GetType ¶
func (m *CreateServiceRequest) GetType() ServiceType_Enum
func (*CreateServiceRequest) GetUserId ¶
func (m *CreateServiceRequest) GetUserId() string
func (*CreateServiceRequest) ProtoMessage ¶
func (*CreateServiceRequest) ProtoMessage()
func (*CreateServiceRequest) Reset ¶
func (m *CreateServiceRequest) Reset()
func (*CreateServiceRequest) String ¶
func (m *CreateServiceRequest) String() string
func (*CreateServiceRequest) XXX_DiscardUnknown ¶
func (m *CreateServiceRequest) XXX_DiscardUnknown()
func (*CreateServiceRequest) XXX_Marshal ¶
func (m *CreateServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateServiceRequest) XXX_Merge ¶
func (m *CreateServiceRequest) XXX_Merge(src proto.Message)
func (*CreateServiceRequest) XXX_Size ¶
func (m *CreateServiceRequest) XXX_Size() int
func (*CreateServiceRequest) XXX_Unmarshal ¶
func (m *CreateServiceRequest) XXX_Unmarshal(b []byte) error
type CreateServiceResponse ¶
type CreateServiceResponse struct { ContainerName string `protobuf:"bytes,1,opt,name=container_name,json=containerName,proto3" json:"container_name,omitempty"` ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` Port int32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateServiceResponse) Descriptor ¶
func (*CreateServiceResponse) Descriptor() ([]byte, []int)
func (*CreateServiceResponse) GetContainerId ¶
func (m *CreateServiceResponse) GetContainerId() string
func (*CreateServiceResponse) GetContainerName ¶
func (m *CreateServiceResponse) GetContainerName() string
func (*CreateServiceResponse) GetPort ¶
func (m *CreateServiceResponse) GetPort() int32
func (*CreateServiceResponse) ProtoMessage ¶
func (*CreateServiceResponse) ProtoMessage()
func (*CreateServiceResponse) Reset ¶
func (m *CreateServiceResponse) Reset()
func (*CreateServiceResponse) String ¶
func (m *CreateServiceResponse) String() string
func (*CreateServiceResponse) XXX_DiscardUnknown ¶
func (m *CreateServiceResponse) XXX_DiscardUnknown()
func (*CreateServiceResponse) XXX_Marshal ¶
func (m *CreateServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateServiceResponse) XXX_Merge ¶
func (m *CreateServiceResponse) XXX_Merge(src proto.Message)
func (*CreateServiceResponse) XXX_Size ¶
func (m *CreateServiceResponse) XXX_Size() int
func (*CreateServiceResponse) XXX_Unmarshal ¶
func (m *CreateServiceResponse) XXX_Unmarshal(b []byte) error
type EmptyRequest ¶
type EmptyRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*EmptyRequest) Descriptor ¶
func (*EmptyRequest) Descriptor() ([]byte, []int)
func (*EmptyRequest) ProtoMessage ¶
func (*EmptyRequest) ProtoMessage()
func (*EmptyRequest) Reset ¶
func (m *EmptyRequest) Reset()
func (*EmptyRequest) String ¶
func (m *EmptyRequest) String() string
func (*EmptyRequest) XXX_DiscardUnknown ¶
func (m *EmptyRequest) XXX_DiscardUnknown()
func (*EmptyRequest) XXX_Marshal ¶
func (m *EmptyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EmptyRequest) XXX_Merge ¶
func (m *EmptyRequest) XXX_Merge(src proto.Message)
func (*EmptyRequest) XXX_Size ¶
func (m *EmptyRequest) XXX_Size() int
func (*EmptyRequest) XXX_Unmarshal ¶
func (m *EmptyRequest) XXX_Unmarshal(b []byte) error
type EmptyResponse ¶
type EmptyResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*EmptyResponse) Descriptor ¶
func (*EmptyResponse) Descriptor() ([]byte, []int)
func (*EmptyResponse) ProtoMessage ¶
func (*EmptyResponse) ProtoMessage()
func (*EmptyResponse) Reset ¶
func (m *EmptyResponse) Reset()
func (*EmptyResponse) String ¶
func (m *EmptyResponse) String() string
func (*EmptyResponse) XXX_DiscardUnknown ¶
func (m *EmptyResponse) XXX_DiscardUnknown()
func (*EmptyResponse) XXX_Marshal ¶
func (m *EmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EmptyResponse) XXX_Merge ¶
func (m *EmptyResponse) XXX_Merge(src proto.Message)
func (*EmptyResponse) XXX_Size ¶
func (m *EmptyResponse) XXX_Size() int
func (*EmptyResponse) XXX_Unmarshal ¶
func (m *EmptyResponse) XXX_Unmarshal(b []byte) error
type HeartbeatRequest ¶
type HeartbeatRequest struct { Interval *duration.Duration `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HeartbeatRequest) Descriptor ¶
func (*HeartbeatRequest) Descriptor() ([]byte, []int)
func (*HeartbeatRequest) GetInterval ¶
func (m *HeartbeatRequest) GetInterval() *duration.Duration
func (*HeartbeatRequest) ProtoMessage ¶
func (*HeartbeatRequest) ProtoMessage()
func (*HeartbeatRequest) Reset ¶
func (m *HeartbeatRequest) Reset()
func (*HeartbeatRequest) String ¶
func (m *HeartbeatRequest) String() string
func (*HeartbeatRequest) XXX_DiscardUnknown ¶
func (m *HeartbeatRequest) XXX_DiscardUnknown()
func (*HeartbeatRequest) XXX_Marshal ¶
func (m *HeartbeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HeartbeatRequest) XXX_Merge ¶
func (m *HeartbeatRequest) XXX_Merge(src proto.Message)
func (*HeartbeatRequest) XXX_Size ¶
func (m *HeartbeatRequest) XXX_Size() int
func (*HeartbeatRequest) XXX_Unmarshal ¶
func (m *HeartbeatRequest) XXX_Unmarshal(b []byte) error
type HeartbeatStreamServer ¶
type HeartbeatStreamServer struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HeartbeatStreamServer) Descriptor ¶
func (*HeartbeatStreamServer) Descriptor() ([]byte, []int)
func (*HeartbeatStreamServer) ProtoMessage ¶
func (*HeartbeatStreamServer) ProtoMessage()
func (*HeartbeatStreamServer) Reset ¶
func (m *HeartbeatStreamServer) Reset()
func (*HeartbeatStreamServer) String ¶
func (m *HeartbeatStreamServer) String() string
func (*HeartbeatStreamServer) XXX_DiscardUnknown ¶
func (m *HeartbeatStreamServer) XXX_DiscardUnknown()
func (*HeartbeatStreamServer) XXX_Marshal ¶
func (m *HeartbeatStreamServer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HeartbeatStreamServer) XXX_Merge ¶
func (m *HeartbeatStreamServer) XXX_Merge(src proto.Message)
func (*HeartbeatStreamServer) XXX_Size ¶
func (m *HeartbeatStreamServer) XXX_Size() int
func (*HeartbeatStreamServer) XXX_Unmarshal ¶
func (m *HeartbeatStreamServer) XXX_Unmarshal(b []byte) error
type RemoveServiceRequest ¶
type RemoveServiceRequest struct { ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RemoveServiceRequest) Descriptor ¶
func (*RemoveServiceRequest) Descriptor() ([]byte, []int)
func (*RemoveServiceRequest) GetContainerId ¶
func (m *RemoveServiceRequest) GetContainerId() string
func (*RemoveServiceRequest) ProtoMessage ¶
func (*RemoveServiceRequest) ProtoMessage()
func (*RemoveServiceRequest) Reset ¶
func (m *RemoveServiceRequest) Reset()
func (*RemoveServiceRequest) String ¶
func (m *RemoveServiceRequest) String() string
func (*RemoveServiceRequest) XXX_DiscardUnknown ¶
func (m *RemoveServiceRequest) XXX_DiscardUnknown()
func (*RemoveServiceRequest) XXX_Marshal ¶
func (m *RemoveServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RemoveServiceRequest) XXX_Merge ¶
func (m *RemoveServiceRequest) XXX_Merge(src proto.Message)
func (*RemoveServiceRequest) XXX_Size ¶
func (m *RemoveServiceRequest) XXX_Size() int
func (*RemoveServiceRequest) XXX_Unmarshal ¶
func (m *RemoveServiceRequest) XXX_Unmarshal(b []byte) error
type ServiceEncryptionMethod ¶
type ServiceEncryptionMethod struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ServiceEncryptionMethod) Descriptor ¶
func (*ServiceEncryptionMethod) Descriptor() ([]byte, []int)
func (*ServiceEncryptionMethod) ProtoMessage ¶
func (*ServiceEncryptionMethod) ProtoMessage()
func (*ServiceEncryptionMethod) Reset ¶
func (m *ServiceEncryptionMethod) Reset()
func (*ServiceEncryptionMethod) String ¶
func (m *ServiceEncryptionMethod) String() string
func (*ServiceEncryptionMethod) XXX_DiscardUnknown ¶
func (m *ServiceEncryptionMethod) XXX_DiscardUnknown()
func (*ServiceEncryptionMethod) XXX_Marshal ¶
func (m *ServiceEncryptionMethod) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceEncryptionMethod) XXX_Merge ¶
func (m *ServiceEncryptionMethod) XXX_Merge(src proto.Message)
func (*ServiceEncryptionMethod) XXX_Size ¶
func (m *ServiceEncryptionMethod) XXX_Size() int
func (*ServiceEncryptionMethod) XXX_Unmarshal ¶
func (m *ServiceEncryptionMethod) XXX_Unmarshal(b []byte) error
type ServiceEncryptionMethod_Enum ¶
type ServiceEncryptionMethod_Enum int32
const ( ServiceEncryptionMethod_NOT_SET ServiceEncryptionMethod_Enum = 0 ServiceEncryptionMethod_AES_256_CFB ServiceEncryptionMethod_Enum = 1 ServiceEncryptionMethod_AES_128_GCM ServiceEncryptionMethod_Enum = 2 ServiceEncryptionMethod_AES_192_GCM ServiceEncryptionMethod_Enum = 3 ServiceEncryptionMethod_AES_256_GCM ServiceEncryptionMethod_Enum = 4 ServiceEncryptionMethod_CHACHA20_IETF_POLY1305 ServiceEncryptionMethod_Enum = 5 ServiceEncryptionMethod_AES_256_CTR ServiceEncryptionMethod_Enum = 6 ServiceEncryptionMethod_CHACHA20 ServiceEncryptionMethod_Enum = 7 ServiceEncryptionMethod_CHACHA20_IETF ServiceEncryptionMethod_Enum = 8 )
func (ServiceEncryptionMethod_Enum) EnumDescriptor ¶
func (ServiceEncryptionMethod_Enum) EnumDescriptor() ([]byte, []int)
func (ServiceEncryptionMethod_Enum) MarshalJSON ¶
func (x ServiceEncryptionMethod_Enum) MarshalJSON() ([]byte, error)
func (ServiceEncryptionMethod_Enum) String ¶
func (x ServiceEncryptionMethod_Enum) String() string
func (*ServiceEncryptionMethod_Enum) UnmarshalJSON ¶
func (x *ServiceEncryptionMethod_Enum) UnmarshalJSON(data []byte) error
func (ServiceEncryptionMethod_Enum) ValidMethod ¶
func (x ServiceEncryptionMethod_Enum) ValidMethod() string
type ServiceInfo ¶
type ServiceInfo struct { ContainerName string `protobuf:"bytes,1,opt,name=container_name,json=containerName,proto3" json:"container_name,omitempty"` ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` Status ServiceStatus_Enum `protobuf:"varint,3,opt,name=status,proto3,enum=ServiceStatus_Enum" json:"status,omitempty"` StatsResult int64 `protobuf:"varint,4,opt,name=stats_result,json=statsResult,proto3" json:"stats_result,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ServiceInfo) Descriptor ¶
func (*ServiceInfo) Descriptor() ([]byte, []int)
func (*ServiceInfo) GetContainerId ¶
func (m *ServiceInfo) GetContainerId() string
func (*ServiceInfo) GetContainerName ¶
func (m *ServiceInfo) GetContainerName() string
func (*ServiceInfo) GetStatsResult ¶
func (m *ServiceInfo) GetStatsResult() int64
func (*ServiceInfo) GetStatus ¶
func (m *ServiceInfo) GetStatus() ServiceStatus_Enum
func (*ServiceInfo) ProtoMessage ¶
func (*ServiceInfo) ProtoMessage()
func (*ServiceInfo) Reset ¶
func (m *ServiceInfo) Reset()
func (*ServiceInfo) String ¶
func (m *ServiceInfo) String() string
func (*ServiceInfo) XXX_DiscardUnknown ¶
func (m *ServiceInfo) XXX_DiscardUnknown()
func (*ServiceInfo) XXX_Marshal ¶
func (m *ServiceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceInfo) XXX_Merge ¶
func (m *ServiceInfo) XXX_Merge(src proto.Message)
func (*ServiceInfo) XXX_Size ¶
func (m *ServiceInfo) XXX_Size() int
func (*ServiceInfo) XXX_Unmarshal ¶
func (m *ServiceInfo) XXX_Unmarshal(b []byte) error
type ServiceStatus ¶
type ServiceStatus struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ServiceStatus) Descriptor ¶
func (*ServiceStatus) Descriptor() ([]byte, []int)
func (*ServiceStatus) ProtoMessage ¶
func (*ServiceStatus) ProtoMessage()
func (*ServiceStatus) Reset ¶
func (m *ServiceStatus) Reset()
func (*ServiceStatus) String ¶
func (m *ServiceStatus) String() string
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 ServiceStatus_Enum ¶
type ServiceStatus_Enum int32
const ( ServiceStatus_NOT_SET ServiceStatus_Enum = 0 ServiceStatus_RUNNING ServiceStatus_Enum = 1 ServiceStatus_STOPPED ServiceStatus_Enum = 2 )
func (ServiceStatus_Enum) EnumDescriptor ¶
func (ServiceStatus_Enum) EnumDescriptor() ([]byte, []int)
func (ServiceStatus_Enum) MarshalJSON ¶
func (x ServiceStatus_Enum) MarshalJSON() ([]byte, error)
func (ServiceStatus_Enum) String ¶
func (x ServiceStatus_Enum) String() string
func (*ServiceStatus_Enum) UnmarshalJSON ¶
func (x *ServiceStatus_Enum) UnmarshalJSON(data []byte) error
type ServiceType ¶
type ServiceType struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ServiceType) Descriptor ¶
func (*ServiceType) Descriptor() ([]byte, []int)
func (*ServiceType) ProtoMessage ¶
func (*ServiceType) ProtoMessage()
func (*ServiceType) Reset ¶
func (m *ServiceType) Reset()
func (*ServiceType) String ¶
func (m *ServiceType) String() string
func (*ServiceType) XXX_DiscardUnknown ¶
func (m *ServiceType) XXX_DiscardUnknown()
func (*ServiceType) XXX_Marshal ¶
func (m *ServiceType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceType) XXX_Merge ¶
func (m *ServiceType) XXX_Merge(src proto.Message)
func (*ServiceType) XXX_Size ¶
func (m *ServiceType) XXX_Size() int
func (*ServiceType) XXX_Unmarshal ¶
func (m *ServiceType) XXX_Unmarshal(b []byte) error
type ServiceType_Enum ¶
type ServiceType_Enum int32
const ( ServiceType_NOT_SET ServiceType_Enum = 0 ServiceType_SS_LIBEV ServiceType_Enum = 1 ServiceType_SSR ServiceType_Enum = 2 )
func (ServiceType_Enum) EnumDescriptor ¶
func (ServiceType_Enum) EnumDescriptor() ([]byte, []int)
func (ServiceType_Enum) ImageName ¶
func (x ServiceType_Enum) ImageName() string
func (ServiceType_Enum) MarshalJSON ¶
func (x ServiceType_Enum) MarshalJSON() ([]byte, error)
func (ServiceType_Enum) String ¶
func (x ServiceType_Enum) String() string
func (ServiceType_Enum) Suit ¶
func (x ServiceType_Enum) Suit(m ServiceEncryptionMethod_Enum) bool
func (*ServiceType_Enum) UnmarshalJSON ¶
func (x *ServiceType_Enum) UnmarshalJSON(data []byte) error
type StartServiceRequest ¶
type StartServiceRequest struct { ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StartServiceRequest) Descriptor ¶
func (*StartServiceRequest) Descriptor() ([]byte, []int)
func (*StartServiceRequest) GetContainerId ¶
func (m *StartServiceRequest) GetContainerId() string
func (*StartServiceRequest) ProtoMessage ¶
func (*StartServiceRequest) ProtoMessage()
func (*StartServiceRequest) Reset ¶
func (m *StartServiceRequest) Reset()
func (*StartServiceRequest) String ¶
func (m *StartServiceRequest) String() string
func (*StartServiceRequest) XXX_DiscardUnknown ¶
func (m *StartServiceRequest) XXX_DiscardUnknown()
func (*StartServiceRequest) XXX_Marshal ¶
func (m *StartServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartServiceRequest) XXX_Merge ¶
func (m *StartServiceRequest) XXX_Merge(src proto.Message)
func (*StartServiceRequest) XXX_Size ¶
func (m *StartServiceRequest) XXX_Size() int
func (*StartServiceRequest) XXX_Unmarshal ¶
func (m *StartServiceRequest) XXX_Unmarshal(b []byte) error
type StopServiceRequest ¶
type StopServiceRequest struct { ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StopServiceRequest) Descriptor ¶
func (*StopServiceRequest) Descriptor() ([]byte, []int)
func (*StopServiceRequest) GetContainerId ¶
func (m *StopServiceRequest) GetContainerId() string
func (*StopServiceRequest) ProtoMessage ¶
func (*StopServiceRequest) ProtoMessage()
func (*StopServiceRequest) Reset ¶
func (m *StopServiceRequest) Reset()
func (*StopServiceRequest) String ¶
func (m *StopServiceRequest) String() string
func (*StopServiceRequest) XXX_DiscardUnknown ¶
func (m *StopServiceRequest) XXX_DiscardUnknown()
func (*StopServiceRequest) XXX_Marshal ¶
func (m *StopServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StopServiceRequest) XXX_Merge ¶
func (m *StopServiceRequest) XXX_Merge(src proto.Message)
func (*StopServiceRequest) XXX_Size ¶
func (m *StopServiceRequest) XXX_Size() int
func (*StopServiceRequest) XXX_Unmarshal ¶
func (m *StopServiceRequest) XXX_Unmarshal(b []byte) error
type SyncRequest ¶
type SyncRequest struct { SyncInterval *duration.Duration `protobuf:"bytes,1,opt,name=sync_interval,json=syncInterval,proto3" json:"sync_interval,omitempty"` NodeId string `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SyncRequest) Descriptor ¶
func (*SyncRequest) Descriptor() ([]byte, []int)
func (*SyncRequest) GetNodeId ¶
func (m *SyncRequest) GetNodeId() string
func (*SyncRequest) GetSyncInterval ¶
func (m *SyncRequest) GetSyncInterval() *duration.Duration
func (*SyncRequest) ProtoMessage ¶
func (*SyncRequest) ProtoMessage()
func (*SyncRequest) Reset ¶
func (m *SyncRequest) Reset()
func (*SyncRequest) String ¶
func (m *SyncRequest) String() string
func (*SyncRequest) XXX_DiscardUnknown ¶
func (m *SyncRequest) XXX_DiscardUnknown()
func (*SyncRequest) XXX_Marshal ¶
func (m *SyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SyncRequest) XXX_Merge ¶
func (m *SyncRequest) XXX_Merge(src proto.Message)
func (*SyncRequest) XXX_Size ¶
func (m *SyncRequest) XXX_Size() int
func (*SyncRequest) XXX_Unmarshal ¶
func (m *SyncRequest) XXX_Unmarshal(b []byte) error
type SyncStreamServer ¶
type SyncStreamServer struct { Services []*ServiceInfo `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SyncStreamServer) Descriptor ¶
func (*SyncStreamServer) Descriptor() ([]byte, []int)
func (*SyncStreamServer) GetServices ¶
func (m *SyncStreamServer) GetServices() []*ServiceInfo
func (*SyncStreamServer) ProtoMessage ¶
func (*SyncStreamServer) ProtoMessage()
func (*SyncStreamServer) Reset ¶
func (m *SyncStreamServer) Reset()
func (*SyncStreamServer) String ¶
func (m *SyncStreamServer) String() string
func (*SyncStreamServer) XXX_DiscardUnknown ¶
func (m *SyncStreamServer) XXX_DiscardUnknown()
func (*SyncStreamServer) XXX_Marshal ¶
func (m *SyncStreamServer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SyncStreamServer) XXX_Merge ¶
func (m *SyncStreamServer) XXX_Merge(src proto.Message)
func (*SyncStreamServer) XXX_Size ¶
func (m *SyncStreamServer) XXX_Size() int
func (*SyncStreamServer) XXX_Unmarshal ¶
func (m *SyncStreamServer) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.