pb

package
v0.0.0-...-f7dd217 Latest Latest
Warning

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

 Go to latest Published: Jan 9, 2020 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var WorkerInfo_Status_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "INITIALIZED",
	2: "DISTRIBUTED",
	3: "RUNNING",
	4: "SUCCESS",
	5: "FAILURE",
	6: "ABORTED",
}
View Source 
var WorkerInfo_Status_value = map[string]int32{
	"UNSPECIFIED": 0,
	"INITIALIZED": 1,
	"DISTRIBUTED": 2,
	"RUNNING":     3,
	"SUCCESS":     4,
	"FAILURE":     5,
	"ABORTED":     6,
}

Functions

func RegisterControllerServer 

func RegisterControllerServer(s *grpc.Server, srv ControllerServer)

func RegisterWorkerServer 

func RegisterWorkerServer(s *grpc.Server, srv WorkerServer)

Types

type AddWorkerRequest 

type AddWorkerRequest struct {
	Addresses            []string `protobuf:"bytes,1,rep,name=addresses,proto3" json:"addresses,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddWorkerRequest) Descriptor 

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

func (*AddWorkerRequest) GetAddresses 

func (m *AddWorkerRequest) GetAddresses() []string

func (*AddWorkerRequest) ProtoMessage 

func (*AddWorkerRequest) ProtoMessage()

func (*AddWorkerRequest) Reset 

func (m *AddWorkerRequest) Reset()

func (*AddWorkerRequest) String 

func (m *AddWorkerRequest) String() string

func (*AddWorkerRequest) XXX_DiscardUnknown 

func (m *AddWorkerRequest) XXX_DiscardUnknown()

func (*AddWorkerRequest) XXX_Marshal 

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

func (*AddWorkerRequest) XXX_Merge 

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

func (*AddWorkerRequest) XXX_Size 

func (m *AddWorkerRequest) XXX_Size() int

func (*AddWorkerRequest) XXX_Unmarshal 

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

type AddWorkerResponse 

type AddWorkerResponse struct {
	Workers              []*WorkerInfo `protobuf:"bytes,1,rep,name=workers,proto3" json:"workers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*AddWorkerResponse) Descriptor 

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

func (*AddWorkerResponse) GetWorkers 

func (m *AddWorkerResponse) GetWorkers() []*WorkerInfo

func (*AddWorkerResponse) ProtoMessage 

func (*AddWorkerResponse) ProtoMessage()

func (*AddWorkerResponse) Reset 

func (m *AddWorkerResponse) Reset()

func (*AddWorkerResponse) String 

func (m *AddWorkerResponse) String() string

func (*AddWorkerResponse) XXX_DiscardUnknown 

func (m *AddWorkerResponse) XXX_DiscardUnknown()

func (*AddWorkerResponse) XXX_Marshal 

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

func (*AddWorkerResponse) XXX_Merge 

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

func (*AddWorkerResponse) XXX_Size 

func (m *AddWorkerResponse) XXX_Size() int

func (*AddWorkerResponse) XXX_Unmarshal 

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

type ControllerClient 

type ControllerClient interface {
	Status(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*StatusResponse, error)
	AddWorker(ctx context.Context, in *AddWorkerRequest, opts ...grpc.CallOption) (*AddWorkerResponse, error)
	SetExecuteRequest(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	SetPlugin(ctx context.Context, in *DistributeRequest, opts ...grpc.CallOption) (*DistributeAllResponse, error)
	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)
	Wait(ctx context.Context, in *ControllerWaitRequest, opts ...grpc.CallOption) (Controller_WaitClient, error)
	Stop(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
}

ControllerClient is the client API for Controller service.

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

func NewControllerClient 

func NewControllerClient(cc *grpc.ClientConn) ControllerClient

type ControllerServer 

type ControllerServer interface {
	Status(context.Context, *empty.Empty) (*StatusResponse, error)
	AddWorker(context.Context, *AddWorkerRequest) (*AddWorkerResponse, error)
	SetExecuteRequest(context.Context, *ExecuteRequest) (*empty.Empty, error)
	SetPlugin(context.Context, *DistributeRequest) (*DistributeAllResponse, error)
	Start(context.Context, *StartRequest) (*StartResponse, error)
	Wait(*ControllerWaitRequest, Controller_WaitServer) error
	Stop(context.Context, *empty.Empty) (*empty.Empty, error)
}

ControllerServer is the server API for Controller service.

type ControllerWaitRequest 

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

func (*ControllerWaitRequest) Descriptor 

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

func (*ControllerWaitRequest) GetUuid 

func (m *ControllerWaitRequest) GetUuid() string

func (*ControllerWaitRequest) ProtoMessage 

func (*ControllerWaitRequest) ProtoMessage()

func (*ControllerWaitRequest) Reset 

func (m *ControllerWaitRequest) Reset()

func (*ControllerWaitRequest) String 

func (m *ControllerWaitRequest) String() string

func (*ControllerWaitRequest) XXX_DiscardUnknown 

func (m *ControllerWaitRequest) XXX_DiscardUnknown()

func (*ControllerWaitRequest) XXX_Marshal 

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

func (*ControllerWaitRequest) XXX_Merge 

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

func (*ControllerWaitRequest) XXX_Size 

func (m *ControllerWaitRequest) XXX_Size() int

func (*ControllerWaitRequest) XXX_Unmarshal 

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

type ControllerWaitResponse 

type ControllerWaitResponse struct {
	Uuid                 string        `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	WaitResponse         *WaitResponse `protobuf:"bytes,2,opt,name=wait_response,json=waitResponse,proto3" json:"wait_response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ControllerWaitResponse) Descriptor 

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

func (*ControllerWaitResponse) GetUuid 

func (m *ControllerWaitResponse) GetUuid() string

func (*ControllerWaitResponse) GetWaitResponse 

func (m *ControllerWaitResponse) GetWaitResponse() *WaitResponse

func (*ControllerWaitResponse) ProtoMessage 

func (*ControllerWaitResponse) ProtoMessage()

func (*ControllerWaitResponse) Reset 

func (m *ControllerWaitResponse) Reset()

func (*ControllerWaitResponse) String 

func (m *ControllerWaitResponse) String() string

func (*ControllerWaitResponse) XXX_DiscardUnknown 

func (m *ControllerWaitResponse) XXX_DiscardUnknown()

func (*ControllerWaitResponse) XXX_Marshal 

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

func (*ControllerWaitResponse) XXX_Merge 

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

func (*ControllerWaitResponse) XXX_Size 

func (m *ControllerWaitResponse) XXX_Size() int

func (*ControllerWaitResponse) XXX_Unmarshal 

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

type Controller_WaitClient 

type Controller_WaitClient interface {
	Recv() (*ControllerWaitResponse, error)
	grpc.ClientStream
}

type Controller_WaitServer 

type Controller_WaitServer interface {
	Send(*ControllerWaitResponse) error
	grpc.ServerStream
}

type DistributeAllResponse 

type DistributeAllResponse struct {
	Workers              []*WorkerInfo `protobuf:"bytes,2,rep,name=workers,proto3" json:"workers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*DistributeAllResponse) Descriptor 

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

func (*DistributeAllResponse) GetWorkers 

func (m *DistributeAllResponse) GetWorkers() []*WorkerInfo

func (*DistributeAllResponse) ProtoMessage 

func (*DistributeAllResponse) ProtoMessage()

func (*DistributeAllResponse) Reset 

func (m *DistributeAllResponse) Reset()

func (*DistributeAllResponse) String 

func (m *DistributeAllResponse) String() string

func (*DistributeAllResponse) XXX_DiscardUnknown 

func (m *DistributeAllResponse) XXX_DiscardUnknown()

func (*DistributeAllResponse) XXX_Marshal 

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

func (*DistributeAllResponse) XXX_Merge 

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

func (*DistributeAllResponse) XXX_Size 

func (m *DistributeAllResponse) XXX_Size() int

func (*DistributeAllResponse) XXX_Unmarshal 

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

type DistributeRequest 

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

func (*DistributeRequest) Descriptor 

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

func (*DistributeRequest) GetPlugin 

func (m *DistributeRequest) GetPlugin() []byte

func (*DistributeRequest) ProtoMessage 

func (*DistributeRequest) ProtoMessage()

func (*DistributeRequest) Reset 

func (m *DistributeRequest) Reset()

func (*DistributeRequest) String 

func (m *DistributeRequest) String() string

func (*DistributeRequest) XXX_DiscardUnknown 

func (m *DistributeRequest) XXX_DiscardUnknown()

func (*DistributeRequest) XXX_Marshal 

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

func (*DistributeRequest) XXX_Merge 

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

func (*DistributeRequest) XXX_Size 

func (m *DistributeRequest) XXX_Size() int

func (*DistributeRequest) XXX_Unmarshal 

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

type ExecuteRequest 

type ExecuteRequest struct {
	Concurrency    uint32 `protobuf:"varint,1,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	TimeoutSeconds uint32 `protobuf:"varint,2,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
	// Types that are valid to be assigned to Max:
	//	*ExecuteRequest_Count
	//	*ExecuteRequest_Seconds
	Max                  isExecuteRequest_Max `protobuf_oneof:"max"`
	ExMap                map[string]string    `` /* 164-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ExecuteRequest) Descriptor 

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

func (*ExecuteRequest) GetConcurrency 

func (m *ExecuteRequest) GetConcurrency() uint32

func (*ExecuteRequest) GetCount 

func (m *ExecuteRequest) GetCount() uint32

func (*ExecuteRequest) GetExMap 

func (m *ExecuteRequest) GetExMap() map[string]string

func (*ExecuteRequest) GetMax 

func (m *ExecuteRequest) GetMax() isExecuteRequest_Max

func (*ExecuteRequest) GetSeconds 

func (m *ExecuteRequest) GetSeconds() uint32

func (*ExecuteRequest) GetTimeoutSeconds 

func (m *ExecuteRequest) GetTimeoutSeconds() uint32

func (*ExecuteRequest) ProtoMessage 

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) Reset 

func (m *ExecuteRequest) Reset()

func (*ExecuteRequest) String 

func (m *ExecuteRequest) String() string

func (*ExecuteRequest) XXX_DiscardUnknown 

func (m *ExecuteRequest) XXX_DiscardUnknown()

func (*ExecuteRequest) XXX_Marshal 

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

func (*ExecuteRequest) XXX_Merge 

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

func (*ExecuteRequest) XXX_OneofWrappers 

func (*ExecuteRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ExecuteRequest) XXX_Size 

func (m *ExecuteRequest) XXX_Size() int

func (*ExecuteRequest) XXX_Unmarshal 

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

type ExecuteRequest_Count 

type ExecuteRequest_Count struct {
	Count uint32 `protobuf:"varint,3,opt,name=count,proto3,oneof"`
}

type ExecuteRequest_Seconds 

type ExecuteRequest_Seconds struct {
	Seconds uint32 `protobuf:"varint,4,opt,name=seconds,proto3,oneof"`
}

type Result 

type Result struct {
	ProcessName          string   `protobuf:"bytes,1,opt,name=process_name,json=processName,proto3" json:"process_name,omitempty"`
	IsSuccess            bool     `protobuf:"varint,2,opt,name=is_success,json=isSuccess,proto3" json:"is_success,omitempty"`
	StartTimestampUsec   int64    `protobuf:"varint,3,opt,name=start_timestamp_usec,json=startTimestampUsec,proto3" json:"start_timestamp_usec,omitempty"`
	ElapsedTimeUsec      int64    `protobuf:"varint,4,opt,name=elapsed_time_usec,json=elapsedTimeUsec,proto3" json:"elapsed_time_usec,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Result) Descriptor 

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

func (*Result) GetElapsedTimeUsec 

func (m *Result) GetElapsedTimeUsec() int64

func (*Result) GetIsSuccess 

func (m *Result) GetIsSuccess() bool

func (*Result) GetProcessName 

func (m *Result) GetProcessName() string

func (*Result) GetStartTimestampUsec 

func (m *Result) GetStartTimestampUsec() int64

func (*Result) ProtoMessage 

func (*Result) ProtoMessage()

func (*Result) Reset 

func (m *Result) Reset()

func (*Result) String 

func (m *Result) String() string

func (*Result) XXX_DiscardUnknown 

func (m *Result) XXX_DiscardUnknown()

func (*Result) XXX_Marshal 

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

func (*Result) XXX_Merge 

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

func (*Result) XXX_Size 

func (m *Result) XXX_Size() int

func (*Result) XXX_Unmarshal 

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

type Results 

type Results struct {
	List                 []*Result `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Results) Descriptor 

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

func (*Results) GetList 

func (m *Results) GetList() []*Result

func (*Results) ProtoMessage 

func (*Results) ProtoMessage()

func (*Results) Reset 

func (m *Results) Reset()

func (*Results) String 

func (m *Results) String() string

func (*Results) XXX_DiscardUnknown 

func (m *Results) XXX_DiscardUnknown()

func (*Results) XXX_Marshal 

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

func (*Results) XXX_Merge 

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

func (*Results) XXX_Size 

func (m *Results) XXX_Size() int

func (*Results) XXX_Unmarshal 

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

type StartRequest 

type StartRequest struct {
	Uuids                []string `protobuf:"bytes,1,rep,name=uuids,proto3" json:"uuids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartRequest) Descriptor 

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

func (*StartRequest) GetUuids 

func (m *StartRequest) GetUuids() []string

func (*StartRequest) ProtoMessage 

func (*StartRequest) ProtoMessage()

func (*StartRequest) Reset 

func (m *StartRequest) Reset()

func (*StartRequest) String 

func (m *StartRequest) String() string

func (*StartRequest) XXX_DiscardUnknown 

func (m *StartRequest) XXX_DiscardUnknown()

func (*StartRequest) XXX_Marshal 

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

func (*StartRequest) XXX_Merge 

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

func (*StartRequest) XXX_Size 

func (m *StartRequest) XXX_Size() int

func (*StartRequest) XXX_Unmarshal 

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

type StartResponse 

type StartResponse struct {
	Workers              []*WorkerInfo `protobuf:"bytes,1,rep,name=workers,proto3" json:"workers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*StartResponse) Descriptor 

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

func (*StartResponse) GetWorkers 

func (m *StartResponse) GetWorkers() []*WorkerInfo

func (*StartResponse) ProtoMessage 

func (*StartResponse) ProtoMessage()

func (*StartResponse) Reset 

func (m *StartResponse) Reset()

func (*StartResponse) String 

func (m *StartResponse) String() string

func (*StartResponse) XXX_DiscardUnknown 

func (m *StartResponse) XXX_DiscardUnknown()

func (*StartResponse) XXX_Marshal 

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

func (*StartResponse) XXX_Merge 

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

func (*StartResponse) XXX_Size 

func (m *StartResponse) XXX_Size() int

func (*StartResponse) XXX_Unmarshal 

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

type StatusResponse 

type StatusResponse struct {
	Workers              []*WorkerInfo `protobuf:"bytes,1,rep,name=workers,proto3" json:"workers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*StatusResponse) Descriptor 

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

func (*StatusResponse) GetWorkers 

func (m *StatusResponse) GetWorkers() []*WorkerInfo

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) Reset 

func (m *StatusResponse) Reset()

func (*StatusResponse) String 

func (m *StatusResponse) String() string

func (*StatusResponse) XXX_DiscardUnknown 

func (m *StatusResponse) XXX_DiscardUnknown()

func (*StatusResponse) XXX_Marshal 

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

func (*StatusResponse) XXX_Merge 

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

func (*StatusResponse) XXX_Size 

func (m *StatusResponse) XXX_Size() int

func (*StatusResponse) XXX_Unmarshal 

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

type UnimplementedControllerServer 

type UnimplementedControllerServer struct {
}

UnimplementedControllerServer can be embedded to have forward compatible implementations.

func (*UnimplementedControllerServer) AddWorker 

func (*UnimplementedControllerServer) AddWorker(ctx context.Context, req *AddWorkerRequest) (*AddWorkerResponse, error)

func (*UnimplementedControllerServer) SetExecuteRequest 

func (*UnimplementedControllerServer) SetExecuteRequest(ctx context.Context, req *ExecuteRequest) (*empty.Empty, error)

func (*UnimplementedControllerServer) SetPlugin 

func (*UnimplementedControllerServer) SetPlugin(ctx context.Context, req *DistributeRequest) (*DistributeAllResponse, error)

func (*UnimplementedControllerServer) Start 

func (*UnimplementedControllerServer) Start(ctx context.Context, req *StartRequest) (*StartResponse, error)

func (*UnimplementedControllerServer) Status 

func (*UnimplementedControllerServer) Status(ctx context.Context, req *empty.Empty) (*StatusResponse, error)

func (*UnimplementedControllerServer) Stop 

func (*UnimplementedControllerServer) Stop(ctx context.Context, req *empty.Empty) (*empty.Empty, error)

func (*UnimplementedControllerServer) Wait 

func (*UnimplementedControllerServer) Wait(req *ControllerWaitRequest, srv Controller_WaitServer) error

type UnimplementedWorkerServer 

type UnimplementedWorkerServer struct {
}

UnimplementedWorkerServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkerServer) Distribute 

func (*UnimplementedWorkerServer) Distribute(ctx context.Context, req *DistributeRequest) (*empty.Empty, error)

func (*UnimplementedWorkerServer) Execute 

func (*UnimplementedWorkerServer) Execute(ctx context.Context, req *ExecuteRequest) (*empty.Empty, error)

func (*UnimplementedWorkerServer) Stop 

func (*UnimplementedWorkerServer) Stop(ctx context.Context, req *empty.Empty) (*empty.Empty, error)

func (*UnimplementedWorkerServer) Wait 

func (*UnimplementedWorkerServer) Wait(req *empty.Empty, srv Worker_WaitServer) error

type WaitResponse 

type WaitResponse struct {
	Results              []*Result `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	IsContinue           bool      `protobuf:"varint,2,opt,name=is_continue,json=isContinue,proto3" json:"is_continue,omitempty"`
	Current              uint32    `protobuf:"varint,3,opt,name=current,proto3" json:"current,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*WaitResponse) Descriptor 

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

func (*WaitResponse) GetCurrent 

func (m *WaitResponse) GetCurrent() uint32

func (*WaitResponse) GetIsContinue 

func (m *WaitResponse) GetIsContinue() bool

func (*WaitResponse) GetResults 

func (m *WaitResponse) GetResults() []*Result

func (*WaitResponse) ProtoMessage 

func (*WaitResponse) ProtoMessage()

func (*WaitResponse) Reset 

func (m *WaitResponse) Reset()

func (*WaitResponse) String 

func (m *WaitResponse) String() string

func (*WaitResponse) XXX_DiscardUnknown 

func (m *WaitResponse) XXX_DiscardUnknown()

func (*WaitResponse) XXX_Marshal 

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

func (*WaitResponse) XXX_Merge 

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

func (*WaitResponse) XXX_Size 

func (m *WaitResponse) XXX_Size() int

func (*WaitResponse) XXX_Unmarshal 

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

type WorkerClient 

type WorkerClient interface {
	Distribute(ctx context.Context, in *DistributeRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	Wait(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (Worker_WaitClient, error)
	Stop(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
}

WorkerClient is the client API for Worker service.

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

func NewWorkerClient 

func NewWorkerClient(cc *grpc.ClientConn) WorkerClient

type WorkerInfo 

type WorkerInfo struct {
	Uuid                 string            `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Address              string            `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Status               WorkerInfo_Status `protobuf:"varint,3,opt,name=status,proto3,enum=pb.WorkerInfo_Status" json:"status,omitempty"`
	Current              uint32            `protobuf:"varint,4,opt,name=current,proto3" json:"current,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*WorkerInfo) Descriptor 

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

func (*WorkerInfo) GetAddress 

func (m *WorkerInfo) GetAddress() string

func (*WorkerInfo) GetCurrent 

func (m *WorkerInfo) GetCurrent() uint32

func (*WorkerInfo) GetStatus 

func (m *WorkerInfo) GetStatus() WorkerInfo_Status

func (*WorkerInfo) GetUuid 

func (m *WorkerInfo) GetUuid() string

func (*WorkerInfo) ProtoMessage 

func (*WorkerInfo) ProtoMessage()

func (*WorkerInfo) Reset 

func (m *WorkerInfo) Reset()

func (*WorkerInfo) String 

func (m *WorkerInfo) String() string

func (*WorkerInfo) XXX_DiscardUnknown 

func (m *WorkerInfo) XXX_DiscardUnknown()

func (*WorkerInfo) XXX_Marshal 

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

func (*WorkerInfo) XXX_Merge 

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

func (*WorkerInfo) XXX_Size 

func (m *WorkerInfo) XXX_Size() int

func (*WorkerInfo) XXX_Unmarshal 

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

type WorkerInfo_Status 

type WorkerInfo_Status int32
const (
	WorkerInfo_UNSPECIFIED WorkerInfo_Status = 0
	WorkerInfo_INITIALIZED WorkerInfo_Status = 1
	WorkerInfo_DISTRIBUTED WorkerInfo_Status = 2
	WorkerInfo_RUNNING     WorkerInfo_Status = 3
	WorkerInfo_SUCCESS     WorkerInfo_Status = 4
	WorkerInfo_FAILURE     WorkerInfo_Status = 5
	WorkerInfo_ABORTED     WorkerInfo_Status = 6
)

func (WorkerInfo_Status) EnumDescriptor 

func (WorkerInfo_Status) EnumDescriptor() ([]byte, []int)

func (WorkerInfo_Status) String 

func (x WorkerInfo_Status) String() string

type WorkerServer 

type WorkerServer interface {
	Distribute(context.Context, *DistributeRequest) (*empty.Empty, error)
	Execute(context.Context, *ExecuteRequest) (*empty.Empty, error)
	Wait(*empty.Empty, Worker_WaitServer) error
	Stop(context.Context, *empty.Empty) (*empty.Empty, error)
}

WorkerServer is the server API for Worker service.

type Worker_WaitClient 

type Worker_WaitClient interface {
	Recv() (*WaitResponse, error)
	grpc.ClientStream
}

type Worker_WaitServer 

type Worker_WaitServer interface {
	Send(*WaitResponse) error
	grpc.ServerStream
}

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.