protos

package
v0.0.0-...-48781e9 Latest Latest
Warning

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

Go to latest
Published: Aug 10, 2019 License: MIT Imports: 8 Imported by: 0

Documentation

Index

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

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 (*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 (*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 (*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

Jump to

Keyboard shortcuts

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