rpc

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Nov 15, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterEngineManagerServiceServer 

func RegisterEngineManagerServiceServer(s *grpc.Server, srv EngineManagerServiceServer)

func RegisterProcessManagerServiceServer 

func RegisterProcessManagerServiceServer(s *grpc.Server, srv ProcessManagerServiceServer)

Types

type EngineCreateRequest 

type EngineCreateRequest struct {
	Spec                 *EngineSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*EngineCreateRequest) Descriptor 

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

func (*EngineCreateRequest) GetSpec 

func (m *EngineCreateRequest) GetSpec() *EngineSpec

func (*EngineCreateRequest) ProtoMessage 

func (*EngineCreateRequest) ProtoMessage()

func (*EngineCreateRequest) Reset 

func (m *EngineCreateRequest) Reset()

func (*EngineCreateRequest) String 

func (m *EngineCreateRequest) String() string

func (*EngineCreateRequest) XXX_DiscardUnknown 

func (m *EngineCreateRequest) XXX_DiscardUnknown()

func (*EngineCreateRequest) XXX_Marshal 

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

func (*EngineCreateRequest) XXX_Merge 

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

func (*EngineCreateRequest) XXX_Size 

func (m *EngineCreateRequest) XXX_Size() int

func (*EngineCreateRequest) XXX_Unmarshal 

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

type EngineListResponse 

type EngineListResponse struct {
	Engines              map[string]*EngineResponse `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*EngineListResponse) Descriptor 

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

func (*EngineListResponse) GetEngines 

func (m *EngineListResponse) GetEngines() map[string]*EngineResponse

func (*EngineListResponse) ProtoMessage 

func (*EngineListResponse) ProtoMessage()

func (*EngineListResponse) Reset 

func (m *EngineListResponse) Reset()

func (*EngineListResponse) String 

func (m *EngineListResponse) String() string

func (*EngineListResponse) XXX_DiscardUnknown 

func (m *EngineListResponse) XXX_DiscardUnknown()

func (*EngineListResponse) XXX_Marshal 

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

func (*EngineListResponse) XXX_Merge 

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

func (*EngineListResponse) XXX_Size 

func (m *EngineListResponse) XXX_Size() int

func (*EngineListResponse) XXX_Unmarshal 

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

type EngineManagerServiceClient 

type EngineManagerServiceClient interface {
	EngineCreate(ctx context.Context, in *EngineCreateRequest, opts ...grpc.CallOption) (*EngineResponse, error)
	EngineDelete(ctx context.Context, in *EngineRequest, opts ...grpc.CallOption) (*EngineResponse, error)
	EngineGet(ctx context.Context, in *EngineRequest, opts ...grpc.CallOption) (*EngineResponse, error)
	EngineList(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*EngineListResponse, error)
	EngineUpgrade(ctx context.Context, in *EngineUpgradeRequest, opts ...grpc.CallOption) (*EngineResponse, error)
	EngineLog(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (EngineManagerService_EngineLogClient, error)
	EngineWatch(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (EngineManagerService_EngineWatchClient, error)
	FrontendStart(ctx context.Context, in *FrontendStartRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	FrontendShutdown(ctx context.Context, in *EngineRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	FrontendStartCallback(ctx context.Context, in *EngineRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	FrontendShutdownCallback(ctx context.Context, in *EngineRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

EngineManagerServiceClient is the client API for EngineManagerService service.

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

func NewEngineManagerServiceClient 

func NewEngineManagerServiceClient(cc *grpc.ClientConn) EngineManagerServiceClient

type EngineManagerServiceServer 

type EngineManagerServiceServer interface {
	EngineCreate(context.Context, *EngineCreateRequest) (*EngineResponse, error)
	EngineDelete(context.Context, *EngineRequest) (*EngineResponse, error)
	EngineGet(context.Context, *EngineRequest) (*EngineResponse, error)
	EngineList(context.Context, *empty.Empty) (*EngineListResponse, error)
	EngineUpgrade(context.Context, *EngineUpgradeRequest) (*EngineResponse, error)
	EngineLog(*LogRequest, EngineManagerService_EngineLogServer) error
	EngineWatch(*empty.Empty, EngineManagerService_EngineWatchServer) error
	FrontendStart(context.Context, *FrontendStartRequest) (*empty.Empty, error)
	FrontendShutdown(context.Context, *EngineRequest) (*empty.Empty, error)
	FrontendStartCallback(context.Context, *EngineRequest) (*empty.Empty, error)
	FrontendShutdownCallback(context.Context, *EngineRequest) (*empty.Empty, error)
}

EngineManagerServiceServer is the server API for EngineManagerService service.

type EngineManagerService_EngineLogClient 

type EngineManagerService_EngineLogClient interface {
	Recv() (*LogResponse, error)
	grpc.ClientStream
}

type EngineManagerService_EngineLogServer 

type EngineManagerService_EngineLogServer interface {
	Send(*LogResponse) error
	grpc.ServerStream
}

type EngineManagerService_EngineWatchClient 

type EngineManagerService_EngineWatchClient interface {
	Recv() (*EngineResponse, error)
	grpc.ClientStream
}

type EngineManagerService_EngineWatchServer 

type EngineManagerService_EngineWatchServer interface {
	Send(*EngineResponse) error
	grpc.ServerStream
}

type EngineRequest 

type EngineRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EngineRequest) Descriptor 

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

func (*EngineRequest) GetName 

func (m *EngineRequest) GetName() string

func (*EngineRequest) ProtoMessage 

func (*EngineRequest) ProtoMessage()

func (*EngineRequest) Reset 

func (m *EngineRequest) Reset()

func (*EngineRequest) String 

func (m *EngineRequest) String() string

func (*EngineRequest) XXX_DiscardUnknown 

func (m *EngineRequest) XXX_DiscardUnknown()

func (*EngineRequest) XXX_Marshal 

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

func (*EngineRequest) XXX_Merge 

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

func (*EngineRequest) XXX_Size 

func (m *EngineRequest) XXX_Size() int

func (*EngineRequest) XXX_Unmarshal 

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

type EngineResponse 

type EngineResponse struct {
	Spec                 *EngineSpec   `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	Status               *EngineStatus `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Deleted              bool          `protobuf:"varint,3,opt,name=deleted,proto3" json:"deleted,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*EngineResponse) Descriptor 

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

func (*EngineResponse) GetDeleted 

func (m *EngineResponse) GetDeleted() bool

func (*EngineResponse) GetSpec 

func (m *EngineResponse) GetSpec() *EngineSpec

func (*EngineResponse) GetStatus 

func (m *EngineResponse) GetStatus() *EngineStatus

func (*EngineResponse) ProtoMessage 

func (*EngineResponse) ProtoMessage()

func (*EngineResponse) Reset 

func (m *EngineResponse) Reset()

func (*EngineResponse) String 

func (m *EngineResponse) String() string

func (*EngineResponse) XXX_DiscardUnknown 

func (m *EngineResponse) XXX_DiscardUnknown()

func (*EngineResponse) XXX_Marshal 

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

func (*EngineResponse) XXX_Merge 

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

func (*EngineResponse) XXX_Size 

func (m *EngineResponse) XXX_Size() int

func (*EngineResponse) XXX_Unmarshal 

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

type EngineSpec 

type EngineSpec struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	VolumeName           string   `protobuf:"bytes,2,opt,name=volume_name,json=volumeName,proto3" json:"volume_name,omitempty"`
	Binary               string   `protobuf:"bytes,3,opt,name=binary,proto3" json:"binary,omitempty"`
	Listen               string   `protobuf:"bytes,4,opt,name=listen,proto3" json:"listen,omitempty"`
	ListenIp             string   `protobuf:"bytes,5,opt,name=listen_ip,json=listenIp,proto3" json:"listen_ip,omitempty"`
	Size                 int64    `protobuf:"varint,6,opt,name=size,proto3" json:"size,omitempty"`
	Frontend             string   `protobuf:"bytes,7,opt,name=frontend,proto3" json:"frontend,omitempty"`
	Backends             []string `protobuf:"bytes,8,rep,name=backends,proto3" json:"backends,omitempty"`
	Replicas             []string `protobuf:"bytes,9,rep,name=replicas,proto3" json:"replicas,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EngineSpec) Descriptor 

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

func (*EngineSpec) GetBackends 

func (m *EngineSpec) GetBackends() []string

func (*EngineSpec) GetBinary 

func (m *EngineSpec) GetBinary() string

func (*EngineSpec) GetFrontend 

func (m *EngineSpec) GetFrontend() string

func (*EngineSpec) GetListen 

func (m *EngineSpec) GetListen() string

func (*EngineSpec) GetListenIp 

func (m *EngineSpec) GetListenIp() string

func (*EngineSpec) GetName 

func (m *EngineSpec) GetName() string

func (*EngineSpec) GetReplicas 

func (m *EngineSpec) GetReplicas() []string

func (*EngineSpec) GetSize 

func (m *EngineSpec) GetSize() int64

func (*EngineSpec) GetVolumeName 

func (m *EngineSpec) GetVolumeName() string

func (*EngineSpec) ProtoMessage 

func (*EngineSpec) ProtoMessage()

func (*EngineSpec) Reset 

func (m *EngineSpec) Reset()

func (*EngineSpec) String 

func (m *EngineSpec) String() string

func (*EngineSpec) XXX_DiscardUnknown 

func (m *EngineSpec) XXX_DiscardUnknown()

func (*EngineSpec) XXX_Marshal 

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

func (*EngineSpec) XXX_Merge 

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

func (*EngineSpec) XXX_Size 

func (m *EngineSpec) XXX_Size() int

func (*EngineSpec) XXX_Unmarshal 

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

type EngineStatus 

type EngineStatus struct {
	ProcessStatus        *ProcessStatus `protobuf:"bytes,1,opt,name=process_status,json=processStatus,proto3" json:"process_status,omitempty"`
	Endpoint             string         `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*EngineStatus) Descriptor 

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

func (*EngineStatus) GetEndpoint 

func (m *EngineStatus) GetEndpoint() string

func (*EngineStatus) GetProcessStatus 

func (m *EngineStatus) GetProcessStatus() *ProcessStatus

func (*EngineStatus) ProtoMessage 

func (*EngineStatus) ProtoMessage()

func (*EngineStatus) Reset 

func (m *EngineStatus) Reset()

func (*EngineStatus) String 

func (m *EngineStatus) String() string

func (*EngineStatus) XXX_DiscardUnknown 

func (m *EngineStatus) XXX_DiscardUnknown()

func (*EngineStatus) XXX_Marshal 

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

func (*EngineStatus) XXX_Merge 

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

func (*EngineStatus) XXX_Size 

func (m *EngineStatus) XXX_Size() int

func (*EngineStatus) XXX_Unmarshal 

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

type EngineUpgradeRequest 

type EngineUpgradeRequest struct {
	Spec                 *EngineSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*EngineUpgradeRequest) Descriptor 

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

func (*EngineUpgradeRequest) GetSpec 

func (m *EngineUpgradeRequest) GetSpec() *EngineSpec

func (*EngineUpgradeRequest) ProtoMessage 

func (*EngineUpgradeRequest) ProtoMessage()

func (*EngineUpgradeRequest) Reset 

func (m *EngineUpgradeRequest) Reset()

func (*EngineUpgradeRequest) String 

func (m *EngineUpgradeRequest) String() string

func (*EngineUpgradeRequest) XXX_DiscardUnknown 

func (m *EngineUpgradeRequest) XXX_DiscardUnknown()

func (*EngineUpgradeRequest) XXX_Marshal 

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

func (*EngineUpgradeRequest) XXX_Merge 

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

func (*EngineUpgradeRequest) XXX_Size 

func (m *EngineUpgradeRequest) XXX_Size() int

func (*EngineUpgradeRequest) XXX_Unmarshal 

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

type FrontendStartRequest 

type FrontendStartRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Frontend             string   `protobuf:"bytes,2,opt,name=frontend,proto3" json:"frontend,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FrontendStartRequest) Descriptor 

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

func (*FrontendStartRequest) GetFrontend 

func (m *FrontendStartRequest) GetFrontend() string

func (*FrontendStartRequest) GetName 

func (m *FrontendStartRequest) GetName() string

func (*FrontendStartRequest) ProtoMessage 

func (*FrontendStartRequest) ProtoMessage()

func (*FrontendStartRequest) Reset 

func (m *FrontendStartRequest) Reset()

func (*FrontendStartRequest) String 

func (m *FrontendStartRequest) String() string

func (*FrontendStartRequest) XXX_DiscardUnknown 

func (m *FrontendStartRequest) XXX_DiscardUnknown()

func (*FrontendStartRequest) XXX_Marshal 

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

func (*FrontendStartRequest) XXX_Merge 

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

func (*FrontendStartRequest) XXX_Size 

func (m *FrontendStartRequest) XXX_Size() int

func (*FrontendStartRequest) XXX_Unmarshal 

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

type LogRequest 

type LogRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogRequest) Descriptor 

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

func (*LogRequest) GetName 

func (m *LogRequest) GetName() string

func (*LogRequest) ProtoMessage 

func (*LogRequest) ProtoMessage()

func (*LogRequest) Reset 

func (m *LogRequest) Reset()

func (*LogRequest) String 

func (m *LogRequest) String() string

func (*LogRequest) XXX_DiscardUnknown 

func (m *LogRequest) XXX_DiscardUnknown()

func (*LogRequest) XXX_Marshal 

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

func (*LogRequest) XXX_Merge 

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

func (*LogRequest) XXX_Size 

func (m *LogRequest) XXX_Size() int

func (*LogRequest) XXX_Unmarshal 

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

type LogResponse 

type LogResponse struct {
	Line                 string   `protobuf:"bytes,2,opt,name=line,proto3" json:"line,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogResponse) Descriptor 

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

func (*LogResponse) GetLine 

func (m *LogResponse) GetLine() string

func (*LogResponse) ProtoMessage 

func (*LogResponse) ProtoMessage()

func (*LogResponse) Reset 

func (m *LogResponse) Reset()

func (*LogResponse) String 

func (m *LogResponse) String() string

func (*LogResponse) XXX_DiscardUnknown 

func (m *LogResponse) XXX_DiscardUnknown()

func (*LogResponse) XXX_Marshal 

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

func (*LogResponse) XXX_Merge 

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

func (*LogResponse) XXX_Size 

func (m *LogResponse) XXX_Size() int

func (*LogResponse) XXX_Unmarshal 

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

type ProcessCreateRequest 

type ProcessCreateRequest struct {
	Spec                 *ProcessSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ProcessCreateRequest) Descriptor 

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

func (*ProcessCreateRequest) GetSpec 

func (m *ProcessCreateRequest) GetSpec() *ProcessSpec

func (*ProcessCreateRequest) ProtoMessage 

func (*ProcessCreateRequest) ProtoMessage()

func (*ProcessCreateRequest) Reset 

func (m *ProcessCreateRequest) Reset()

func (*ProcessCreateRequest) String 

func (m *ProcessCreateRequest) String() string

func (*ProcessCreateRequest) XXX_DiscardUnknown 

func (m *ProcessCreateRequest) XXX_DiscardUnknown()

func (*ProcessCreateRequest) XXX_Marshal 

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

func (*ProcessCreateRequest) XXX_Merge 

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

func (*ProcessCreateRequest) XXX_Size 

func (m *ProcessCreateRequest) XXX_Size() int

func (*ProcessCreateRequest) XXX_Unmarshal 

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

type ProcessDeleteRequest 

type ProcessDeleteRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProcessDeleteRequest) Descriptor 

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

func (*ProcessDeleteRequest) GetName 

func (m *ProcessDeleteRequest) GetName() string

func (*ProcessDeleteRequest) ProtoMessage 

func (*ProcessDeleteRequest) ProtoMessage()

func (*ProcessDeleteRequest) Reset 

func (m *ProcessDeleteRequest) Reset()

func (*ProcessDeleteRequest) String 

func (m *ProcessDeleteRequest) String() string

func (*ProcessDeleteRequest) XXX_DiscardUnknown 

func (m *ProcessDeleteRequest) XXX_DiscardUnknown()

func (*ProcessDeleteRequest) XXX_Marshal 

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

func (*ProcessDeleteRequest) XXX_Merge 

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

func (*ProcessDeleteRequest) XXX_Size 

func (m *ProcessDeleteRequest) XXX_Size() int

func (*ProcessDeleteRequest) XXX_Unmarshal 

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

type ProcessGetRequest 

type ProcessGetRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProcessGetRequest) Descriptor 

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

func (*ProcessGetRequest) GetName 

func (m *ProcessGetRequest) GetName() string

func (*ProcessGetRequest) ProtoMessage 

func (*ProcessGetRequest) ProtoMessage()

func (*ProcessGetRequest) Reset 

func (m *ProcessGetRequest) Reset()

func (*ProcessGetRequest) String 

func (m *ProcessGetRequest) String() string

func (*ProcessGetRequest) XXX_DiscardUnknown 

func (m *ProcessGetRequest) XXX_DiscardUnknown()

func (*ProcessGetRequest) XXX_Marshal 

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

func (*ProcessGetRequest) XXX_Merge 

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

func (*ProcessGetRequest) XXX_Size 

func (m *ProcessGetRequest) XXX_Size() int

func (*ProcessGetRequest) XXX_Unmarshal 

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

type ProcessListRequest 

type ProcessListRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProcessListRequest) Descriptor 

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

func (*ProcessListRequest) ProtoMessage 

func (*ProcessListRequest) ProtoMessage()

func (*ProcessListRequest) Reset 

func (m *ProcessListRequest) Reset()

func (*ProcessListRequest) String 

func (m *ProcessListRequest) String() string

func (*ProcessListRequest) XXX_DiscardUnknown 

func (m *ProcessListRequest) XXX_DiscardUnknown()

func (*ProcessListRequest) XXX_Marshal 

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

func (*ProcessListRequest) XXX_Merge 

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

func (*ProcessListRequest) XXX_Size 

func (m *ProcessListRequest) XXX_Size() int

func (*ProcessListRequest) XXX_Unmarshal 

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

type ProcessListResponse 

type ProcessListResponse struct {
	Processes            map[string]*ProcessResponse `` /* 159-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*ProcessListResponse) Descriptor 

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

func (*ProcessListResponse) GetProcesses 

func (m *ProcessListResponse) GetProcesses() map[string]*ProcessResponse

func (*ProcessListResponse) ProtoMessage 

func (*ProcessListResponse) ProtoMessage()

func (*ProcessListResponse) Reset 

func (m *ProcessListResponse) Reset()

func (*ProcessListResponse) String 

func (m *ProcessListResponse) String() string

func (*ProcessListResponse) XXX_DiscardUnknown 

func (m *ProcessListResponse) XXX_DiscardUnknown()

func (*ProcessListResponse) XXX_Marshal 

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

func (*ProcessListResponse) XXX_Merge 

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

func (*ProcessListResponse) XXX_Size 

func (m *ProcessListResponse) XXX_Size() int

func (*ProcessListResponse) XXX_Unmarshal 

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

type ProcessManagerServiceClient 

type ProcessManagerServiceClient interface {
	ProcessCreate(ctx context.Context, in *ProcessCreateRequest, opts ...grpc.CallOption) (*ProcessResponse, error)
	ProcessDelete(ctx context.Context, in *ProcessDeleteRequest, opts ...grpc.CallOption) (*ProcessResponse, error)
	ProcessGet(ctx context.Context, in *ProcessGetRequest, opts ...grpc.CallOption) (*ProcessResponse, error)
	ProcessList(ctx context.Context, in *ProcessListRequest, opts ...grpc.CallOption) (*ProcessListResponse, error)
	ProcessLog(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (ProcessManagerService_ProcessLogClient, error)
	ProcessWatch(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (ProcessManagerService_ProcessWatchClient, error)
}

ProcessManagerServiceClient is the client API for ProcessManagerService service.

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

func NewProcessManagerServiceClient 

func NewProcessManagerServiceClient(cc *grpc.ClientConn) ProcessManagerServiceClient

type ProcessManagerServiceServer 

type ProcessManagerServiceServer interface {
	ProcessCreate(context.Context, *ProcessCreateRequest) (*ProcessResponse, error)
	ProcessDelete(context.Context, *ProcessDeleteRequest) (*ProcessResponse, error)
	ProcessGet(context.Context, *ProcessGetRequest) (*ProcessResponse, error)
	ProcessList(context.Context, *ProcessListRequest) (*ProcessListResponse, error)
	ProcessLog(*LogRequest, ProcessManagerService_ProcessLogServer) error
	ProcessWatch(*empty.Empty, ProcessManagerService_ProcessWatchServer) error
}

ProcessManagerServiceServer is the server API for ProcessManagerService service.

type ProcessManagerService_ProcessLogClient 

type ProcessManagerService_ProcessLogClient interface {
	Recv() (*LogResponse, error)
	grpc.ClientStream
}

type ProcessManagerService_ProcessLogServer 

type ProcessManagerService_ProcessLogServer interface {
	Send(*LogResponse) error
	grpc.ServerStream
}

type ProcessManagerService_ProcessWatchClient 

type ProcessManagerService_ProcessWatchClient interface {
	Recv() (*ProcessResponse, error)
	grpc.ClientStream
}

type ProcessManagerService_ProcessWatchServer 

type ProcessManagerService_ProcessWatchServer interface {
	Send(*ProcessResponse) error
	grpc.ServerStream
}

type ProcessResponse 

type ProcessResponse struct {
	Spec                 *ProcessSpec   `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	Status               *ProcessStatus `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Deleted              bool           `protobuf:"varint,3,opt,name=deleted,proto3" json:"deleted,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ProcessResponse) Descriptor 

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

func (*ProcessResponse) GetDeleted 

func (m *ProcessResponse) GetDeleted() bool

func (*ProcessResponse) GetSpec 

func (m *ProcessResponse) GetSpec() *ProcessSpec

func (*ProcessResponse) GetStatus 

func (m *ProcessResponse) GetStatus() *ProcessStatus

func (*ProcessResponse) ProtoMessage 

func (*ProcessResponse) ProtoMessage()

func (*ProcessResponse) Reset 

func (m *ProcessResponse) Reset()

func (*ProcessResponse) String 

func (m *ProcessResponse) String() string

func (*ProcessResponse) XXX_DiscardUnknown 

func (m *ProcessResponse) XXX_DiscardUnknown()

func (*ProcessResponse) XXX_Marshal 

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

func (*ProcessResponse) XXX_Merge 

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

func (*ProcessResponse) XXX_Size 

func (m *ProcessResponse) XXX_Size() int

func (*ProcessResponse) XXX_Unmarshal 

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

type ProcessSpec 

type ProcessSpec struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Binary               string   `protobuf:"bytes,2,opt,name=binary,proto3" json:"binary,omitempty"`
	Args                 []string `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	PortCount            int32    `protobuf:"varint,4,opt,name=port_count,json=portCount,proto3" json:"port_count,omitempty"`
	PortArgs             []string `protobuf:"bytes,5,rep,name=port_args,json=portArgs,proto3" json:"port_args,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProcessSpec) Descriptor 

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

func (*ProcessSpec) GetArgs 

func (m *ProcessSpec) GetArgs() []string

func (*ProcessSpec) GetBinary 

func (m *ProcessSpec) GetBinary() string

func (*ProcessSpec) GetName 

func (m *ProcessSpec) GetName() string

func (*ProcessSpec) GetPortArgs 

func (m *ProcessSpec) GetPortArgs() []string

func (*ProcessSpec) GetPortCount 

func (m *ProcessSpec) GetPortCount() int32

func (*ProcessSpec) ProtoMessage 

func (*ProcessSpec) ProtoMessage()

func (*ProcessSpec) Reset 

func (m *ProcessSpec) Reset()

func (*ProcessSpec) String 

func (m *ProcessSpec) String() string

func (*ProcessSpec) XXX_DiscardUnknown 

func (m *ProcessSpec) XXX_DiscardUnknown()

func (*ProcessSpec) XXX_Marshal 

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

func (*ProcessSpec) XXX_Merge 

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

func (*ProcessSpec) XXX_Size 

func (m *ProcessSpec) XXX_Size() int

func (*ProcessSpec) XXX_Unmarshal 

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

type ProcessStatus 

type ProcessStatus struct {
	State                string   `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	ErrorMsg             string   `protobuf:"bytes,2,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	PortStart            int32    `protobuf:"varint,3,opt,name=port_start,json=portStart,proto3" json:"port_start,omitempty"`
	PortEnd              int32    `protobuf:"varint,4,opt,name=port_end,json=portEnd,proto3" json:"port_end,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProcessStatus) Descriptor 

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

func (*ProcessStatus) GetErrorMsg 

func (m *ProcessStatus) GetErrorMsg() string

func (*ProcessStatus) GetPortEnd 

func (m *ProcessStatus) GetPortEnd() int32

func (*ProcessStatus) GetPortStart 

func (m *ProcessStatus) GetPortStart() int32

func (*ProcessStatus) GetState 

func (m *ProcessStatus) GetState() string

func (*ProcessStatus) ProtoMessage 

func (*ProcessStatus) ProtoMessage()

func (*ProcessStatus) Reset 

func (m *ProcessStatus) Reset()

func (*ProcessStatus) String 

func (m *ProcessStatus) String() string

func (*ProcessStatus) XXX_DiscardUnknown 

func (m *ProcessStatus) XXX_DiscardUnknown()

func (*ProcessStatus) XXX_Marshal 

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

func (*ProcessStatus) XXX_Merge 

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

func (*ProcessStatus) XXX_Size 

func (m *ProcessStatus) XXX_Size() int

func (*ProcessStatus) XXX_Unmarshal 

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

type UnimplementedEngineManagerServiceServer 

type UnimplementedEngineManagerServiceServer struct {
}

UnimplementedEngineManagerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedEngineManagerServiceServer) EngineCreate 

func (*UnimplementedEngineManagerServiceServer) EngineCreate(ctx context.Context, req *EngineCreateRequest) (*EngineResponse, error)

func (*UnimplementedEngineManagerServiceServer) EngineDelete 

func (*UnimplementedEngineManagerServiceServer) EngineDelete(ctx context.Context, req *EngineRequest) (*EngineResponse, error)

func (*UnimplementedEngineManagerServiceServer) EngineGet 

func (*UnimplementedEngineManagerServiceServer) EngineGet(ctx context.Context, req *EngineRequest) (*EngineResponse, error)

func (*UnimplementedEngineManagerServiceServer) EngineList 

func (*UnimplementedEngineManagerServiceServer) EngineList(ctx context.Context, req *empty.Empty) (*EngineListResponse, error)

func (*UnimplementedEngineManagerServiceServer) EngineLog 

func (*UnimplementedEngineManagerServiceServer) EngineLog(req *LogRequest, srv EngineManagerService_EngineLogServer) error

func (*UnimplementedEngineManagerServiceServer) EngineUpgrade 

func (*UnimplementedEngineManagerServiceServer) EngineUpgrade(ctx context.Context, req *EngineUpgradeRequest) (*EngineResponse, error)

func (*UnimplementedEngineManagerServiceServer) EngineWatch 

func (*UnimplementedEngineManagerServiceServer) EngineWatch(req *empty.Empty, srv EngineManagerService_EngineWatchServer) error

func (*UnimplementedEngineManagerServiceServer) FrontendShutdown 

func (*UnimplementedEngineManagerServiceServer) FrontendShutdown(ctx context.Context, req *EngineRequest) (*empty.Empty, error)

func (*UnimplementedEngineManagerServiceServer) FrontendShutdownCallback 

func (*UnimplementedEngineManagerServiceServer) FrontendShutdownCallback(ctx context.Context, req *EngineRequest) (*empty.Empty, error)

func (*UnimplementedEngineManagerServiceServer) FrontendStart 

func (*UnimplementedEngineManagerServiceServer) FrontendStart(ctx context.Context, req *FrontendStartRequest) (*empty.Empty, error)

func (*UnimplementedEngineManagerServiceServer) FrontendStartCallback 

func (*UnimplementedEngineManagerServiceServer) FrontendStartCallback(ctx context.Context, req *EngineRequest) (*empty.Empty, error)

type UnimplementedProcessManagerServiceServer 

type UnimplementedProcessManagerServiceServer struct {
}

UnimplementedProcessManagerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedProcessManagerServiceServer) ProcessCreate 

func (*UnimplementedProcessManagerServiceServer) ProcessCreate(ctx context.Context, req *ProcessCreateRequest) (*ProcessResponse, error)

func (*UnimplementedProcessManagerServiceServer) ProcessDelete 

func (*UnimplementedProcessManagerServiceServer) ProcessDelete(ctx context.Context, req *ProcessDeleteRequest) (*ProcessResponse, error)

func (*UnimplementedProcessManagerServiceServer) ProcessGet 

func (*UnimplementedProcessManagerServiceServer) ProcessGet(ctx context.Context, req *ProcessGetRequest) (*ProcessResponse, error)

func (*UnimplementedProcessManagerServiceServer) ProcessList 

func (*UnimplementedProcessManagerServiceServer) ProcessList(ctx context.Context, req *ProcessListRequest) (*ProcessListResponse, error)

func (*UnimplementedProcessManagerServiceServer) ProcessLog 

func (*UnimplementedProcessManagerServiceServer) ProcessLog(req *LogRequest, srv ProcessManagerService_ProcessLogServer) error

func (*UnimplementedProcessManagerServiceServer) ProcessWatch 

func (*UnimplementedProcessManagerServiceServer) ProcessWatch(req *empty.Empty, srv ProcessManagerService_ProcessWatchServer) 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.