workers

package
v0.0.0-...-be3d2a3 Latest Latest
Warning

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

 Go to latest Published: Jun 13, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Overview

Copyright 2022 Evan Hazlett

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthWorkers        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWorkers          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWorkers = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterWorkersServer 

func RegisterWorkersServer(s *grpc.Server, srv WorkersServer)

Types

type ControlWorkerRequest 

type ControlWorkerRequest struct {
	WorkerID  string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Requestor string `protobuf:"bytes,2,opt,name=requestor,proto3" json:"requestor,omitempty"`
	// Types that are valid to be assigned to Message:
	//	*ControlWorkerRequest_Stop
	//	*ControlWorkerRequest_Update
	//	*ControlWorkerRequest_Pause
	//	*ControlWorkerRequest_Resume
	Message              isControlWorkerRequest_Message `protobuf_oneof:"message"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*ControlWorkerRequest) Descriptor 

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

func (*ControlWorkerRequest) GetMessage 

func (m *ControlWorkerRequest) GetMessage() isControlWorkerRequest_Message

func (*ControlWorkerRequest) GetPause 

func (m *ControlWorkerRequest) GetPause() *WorkerPause

func (*ControlWorkerRequest) GetRequestor 

func (m *ControlWorkerRequest) GetRequestor() string

func (*ControlWorkerRequest) GetResume 

func (m *ControlWorkerRequest) GetResume() *WorkerResume

func (*ControlWorkerRequest) GetStop 

func (m *ControlWorkerRequest) GetStop() *WorkerStop

func (*ControlWorkerRequest) GetUpdate 

func (m *ControlWorkerRequest) GetUpdate() *WorkerUpdate

func (*ControlWorkerRequest) GetWorkerID 

func (m *ControlWorkerRequest) GetWorkerID() string

func (*ControlWorkerRequest) Marshal 

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

func (*ControlWorkerRequest) MarshalTo 

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

func (*ControlWorkerRequest) MarshalToSizedBuffer 

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

func (*ControlWorkerRequest) ProtoMessage 

func (*ControlWorkerRequest) ProtoMessage()

func (*ControlWorkerRequest) Reset 

func (m *ControlWorkerRequest) Reset()

func (*ControlWorkerRequest) Size 

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

func (*ControlWorkerRequest) String 

func (m *ControlWorkerRequest) String() string

func (*ControlWorkerRequest) Unmarshal 

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

func (*ControlWorkerRequest) XXX_DiscardUnknown 

func (m *ControlWorkerRequest) XXX_DiscardUnknown()

func (*ControlWorkerRequest) XXX_Marshal 

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

func (*ControlWorkerRequest) XXX_Merge 

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

func (*ControlWorkerRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ControlWorkerRequest) XXX_Size 

func (m *ControlWorkerRequest) XXX_Size() int

func (*ControlWorkerRequest) XXX_Unmarshal 

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

type ControlWorkerRequest_Pause 

type ControlWorkerRequest_Pause struct {
	Pause *WorkerPause `protobuf:"bytes,5,opt,name=pause,proto3,oneof" json:"pause,omitempty"`
}

func (*ControlWorkerRequest_Pause) MarshalTo 

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

func (*ControlWorkerRequest_Pause) MarshalToSizedBuffer 

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

func (*ControlWorkerRequest_Pause) Size 

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

type ControlWorkerRequest_Resume 

type ControlWorkerRequest_Resume struct {
	Resume *WorkerResume `protobuf:"bytes,6,opt,name=resume,proto3,oneof" json:"resume,omitempty"`
}

func (*ControlWorkerRequest_Resume) MarshalTo 

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

func (*ControlWorkerRequest_Resume) MarshalToSizedBuffer 

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

func (*ControlWorkerRequest_Resume) Size 

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

type ControlWorkerRequest_Stop 

type ControlWorkerRequest_Stop struct {
	Stop *WorkerStop `protobuf:"bytes,3,opt,name=stop,proto3,oneof" json:"stop,omitempty"`
}

func (*ControlWorkerRequest_Stop) MarshalTo 

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

func (*ControlWorkerRequest_Stop) MarshalToSizedBuffer 

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

func (*ControlWorkerRequest_Stop) Size 

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

type ControlWorkerRequest_Update 

type ControlWorkerRequest_Update struct {
	Update *WorkerUpdate `protobuf:"bytes,4,opt,name=update,proto3,oneof" json:"update,omitempty"`
}

func (*ControlWorkerRequest_Update) MarshalTo 

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

func (*ControlWorkerRequest_Update) MarshalToSizedBuffer 

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

func (*ControlWorkerRequest_Update) Size 

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

type ControlWorkerResponse 

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

func (*ControlWorkerResponse) Descriptor 

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

func (*ControlWorkerResponse) Marshal 

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

func (*ControlWorkerResponse) MarshalTo 

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

func (*ControlWorkerResponse) MarshalToSizedBuffer 

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

func (*ControlWorkerResponse) ProtoMessage 

func (*ControlWorkerResponse) ProtoMessage()

func (*ControlWorkerResponse) Reset 

func (m *ControlWorkerResponse) Reset()

func (*ControlWorkerResponse) Size 

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

func (*ControlWorkerResponse) String 

func (m *ControlWorkerResponse) String() string

func (*ControlWorkerResponse) Unmarshal 

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

func (*ControlWorkerResponse) XXX_DiscardUnknown 

func (m *ControlWorkerResponse) XXX_DiscardUnknown()

func (*ControlWorkerResponse) XXX_Marshal 

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

func (*ControlWorkerResponse) XXX_Merge 

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

func (*ControlWorkerResponse) XXX_Size 

func (m *ControlWorkerResponse) XXX_Size() int

func (*ControlWorkerResponse) XXX_Unmarshal 

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

type ListWorkersRequest 

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

func (*ListWorkersRequest) Descriptor 

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

func (*ListWorkersRequest) Marshal 

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

func (*ListWorkersRequest) MarshalTo 

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

func (*ListWorkersRequest) MarshalToSizedBuffer 

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

func (*ListWorkersRequest) ProtoMessage 

func (*ListWorkersRequest) ProtoMessage()

func (*ListWorkersRequest) Reset 

func (m *ListWorkersRequest) Reset()

func (*ListWorkersRequest) Size 

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

func (*ListWorkersRequest) String 

func (m *ListWorkersRequest) String() string

func (*ListWorkersRequest) Unmarshal 

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

func (*ListWorkersRequest) XXX_DiscardUnknown 

func (m *ListWorkersRequest) XXX_DiscardUnknown()

func (*ListWorkersRequest) XXX_Marshal 

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

func (*ListWorkersRequest) XXX_Merge 

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

func (*ListWorkersRequest) XXX_Size 

func (m *ListWorkersRequest) XXX_Size() int

func (*ListWorkersRequest) XXX_Unmarshal 

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

type ListWorkersResponse 

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

func (*ListWorkersResponse) Descriptor 

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

func (*ListWorkersResponse) GetWorkers 

func (m *ListWorkersResponse) GetWorkers() []*Worker

func (*ListWorkersResponse) Marshal 

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

func (*ListWorkersResponse) MarshalTo 

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

func (*ListWorkersResponse) MarshalToSizedBuffer 

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

func (*ListWorkersResponse) ProtoMessage 

func (*ListWorkersResponse) ProtoMessage()

func (*ListWorkersResponse) Reset 

func (m *ListWorkersResponse) Reset()

func (*ListWorkersResponse) Size 

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

func (*ListWorkersResponse) String 

func (m *ListWorkersResponse) String() string

func (*ListWorkersResponse) Unmarshal 

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

func (*ListWorkersResponse) XXX_DiscardUnknown 

func (m *ListWorkersResponse) XXX_DiscardUnknown()

func (*ListWorkersResponse) XXX_Marshal 

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

func (*ListWorkersResponse) XXX_Merge 

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

func (*ListWorkersResponse) XXX_Size 

func (m *ListWorkersResponse) XXX_Size() int

func (*ListWorkersResponse) XXX_Unmarshal 

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

type UnimplementedWorkersServer 

type UnimplementedWorkersServer struct {
}

UnimplementedWorkersServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkersServer) ControlWorker 

func (*UnimplementedWorkersServer) ControlWorker(ctx context.Context, req *ControlWorkerRequest) (*ControlWorkerResponse, error)

func (*UnimplementedWorkersServer) ListWorkers 

func (*UnimplementedWorkersServer) ListWorkers(ctx context.Context, req *ListWorkersRequest) (*ListWorkersResponse, error)

type Worker 

type Worker struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version              string   `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	CPUs                 uint32   `protobuf:"varint,3,opt,name=cpus,proto3" json:"cpus,omitempty"`
	MemoryTotal          int64    `protobuf:"varint,4,opt,name=memory_total,json=memoryTotal,proto3" json:"memory_total,omitempty"`
	MemoryAvailable      int64    `protobuf:"varint,5,opt,name=memory_available,json=memoryAvailable,proto3" json:"memory_available,omitempty"`
	GPUs                 []string `protobuf:"bytes,6,rep,name=gpus,proto3" json:"gpus,omitempty"`
	Load1                float64  `protobuf:"fixed64,7,opt,name=load1,proto3" json:"load1,omitempty"`
	Load5                float64  `protobuf:"fixed64,8,opt,name=load5,proto3" json:"load5,omitempty"`
	Load15               float64  `protobuf:"fixed64,9,opt,name=load15,proto3" json:"load15,omitempty"`
	Paused               bool     `protobuf:"varint,10,opt,name=paused,proto3" json:"paused,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Worker) Descriptor 

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

func (*Worker) GetCPUs 

func (m *Worker) GetCPUs() uint32

func (*Worker) GetGPUs 

func (m *Worker) GetGPUs() []string

func (*Worker) GetLoad1 

func (m *Worker) GetLoad1() float64

func (*Worker) GetLoad15 

func (m *Worker) GetLoad15() float64

func (*Worker) GetLoad5 

func (m *Worker) GetLoad5() float64

func (*Worker) GetMemoryAvailable 

func (m *Worker) GetMemoryAvailable() int64

func (*Worker) GetMemoryTotal 

func (m *Worker) GetMemoryTotal() int64

func (*Worker) GetName 

func (m *Worker) GetName() string

func (*Worker) GetPaused 

func (m *Worker) GetPaused() bool

func (*Worker) GetVersion 

func (m *Worker) GetVersion() string

func (*Worker) Marshal 

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

func (*Worker) MarshalTo 

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

func (*Worker) MarshalToSizedBuffer 

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

func (*Worker) ProtoMessage 

func (*Worker) ProtoMessage()

func (*Worker) Reset 

func (m *Worker) Reset()

func (*Worker) Size 

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

func (*Worker) String 

func (m *Worker) String() string

func (*Worker) Unmarshal 

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

func (*Worker) XXX_DiscardUnknown 

func (m *Worker) XXX_DiscardUnknown()

func (*Worker) XXX_Marshal 

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

func (*Worker) XXX_Merge 

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

func (*Worker) XXX_Size 

func (m *Worker) XXX_Size() int

func (*Worker) XXX_Unmarshal 

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

type WorkerPause 

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

func (*WorkerPause) Descriptor 

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

func (*WorkerPause) Marshal 

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

func (*WorkerPause) MarshalTo 

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

func (*WorkerPause) MarshalToSizedBuffer 

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

func (*WorkerPause) ProtoMessage 

func (*WorkerPause) ProtoMessage()

func (*WorkerPause) Reset 

func (m *WorkerPause) Reset()

func (*WorkerPause) Size 

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

func (*WorkerPause) String 

func (m *WorkerPause) String() string

func (*WorkerPause) Unmarshal 

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

func (*WorkerPause) XXX_DiscardUnknown 

func (m *WorkerPause) XXX_DiscardUnknown()

func (*WorkerPause) XXX_Marshal 

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

func (*WorkerPause) XXX_Merge 

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

func (*WorkerPause) XXX_Size 

func (m *WorkerPause) XXX_Size() int

func (*WorkerPause) XXX_Unmarshal 

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

type WorkerResume 

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

func (*WorkerResume) Descriptor 

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

func (*WorkerResume) Marshal 

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

func (*WorkerResume) MarshalTo 

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

func (*WorkerResume) MarshalToSizedBuffer 

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

func (*WorkerResume) ProtoMessage 

func (*WorkerResume) ProtoMessage()

func (*WorkerResume) Reset 

func (m *WorkerResume) Reset()

func (*WorkerResume) Size 

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

func (*WorkerResume) String 

func (m *WorkerResume) String() string

func (*WorkerResume) Unmarshal 

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

func (*WorkerResume) XXX_DiscardUnknown 

func (m *WorkerResume) XXX_DiscardUnknown()

func (*WorkerResume) XXX_Marshal 

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

func (*WorkerResume) XXX_Merge 

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

func (*WorkerResume) XXX_Size 

func (m *WorkerResume) XXX_Size() int

func (*WorkerResume) XXX_Unmarshal 

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

type WorkerStop 

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

func (*WorkerStop) Descriptor 

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

func (*WorkerStop) Marshal 

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

func (*WorkerStop) MarshalTo 

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

func (*WorkerStop) MarshalToSizedBuffer 

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

func (*WorkerStop) ProtoMessage 

func (*WorkerStop) ProtoMessage()

func (*WorkerStop) Reset 

func (m *WorkerStop) Reset()

func (*WorkerStop) Size 

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

func (*WorkerStop) String 

func (m *WorkerStop) String() string

func (*WorkerStop) Unmarshal 

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

func (*WorkerStop) XXX_DiscardUnknown 

func (m *WorkerStop) XXX_DiscardUnknown()

func (*WorkerStop) XXX_Marshal 

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

func (*WorkerStop) XXX_Merge 

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

func (*WorkerStop) XXX_Size 

func (m *WorkerStop) XXX_Size() int

func (*WorkerStop) XXX_Unmarshal 

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

type WorkerUpdate 

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

func (*WorkerUpdate) Descriptor 

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

func (*WorkerUpdate) GetURL 

func (m *WorkerUpdate) GetURL() string

func (*WorkerUpdate) Marshal 

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

func (*WorkerUpdate) MarshalTo 

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

func (*WorkerUpdate) MarshalToSizedBuffer 

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

func (*WorkerUpdate) ProtoMessage 

func (*WorkerUpdate) ProtoMessage()

func (*WorkerUpdate) Reset 

func (m *WorkerUpdate) Reset()

func (*WorkerUpdate) Size 

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

func (*WorkerUpdate) String 

func (m *WorkerUpdate) String() string

func (*WorkerUpdate) Unmarshal 

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

func (*WorkerUpdate) XXX_DiscardUnknown 

func (m *WorkerUpdate) XXX_DiscardUnknown()

func (*WorkerUpdate) XXX_Marshal 

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

func (*WorkerUpdate) XXX_Merge 

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

func (*WorkerUpdate) XXX_Size 

func (m *WorkerUpdate) XXX_Size() int

func (*WorkerUpdate) XXX_Unmarshal 

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

type WorkersClient 

type WorkersClient interface {
	ListWorkers(ctx context.Context, in *ListWorkersRequest, opts ...grpc.CallOption) (*ListWorkersResponse, error)
	ControlWorker(ctx context.Context, in *ControlWorkerRequest, opts ...grpc.CallOption) (*ControlWorkerResponse, error)
}

WorkersClient is the client API for Workers service.

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

func NewWorkersClient 

func NewWorkersClient(cc *grpc.ClientConn) WorkersClient

type WorkersServer 

type WorkersServer interface {
	ListWorkers(context.Context, *ListWorkersRequest) (*ListWorkersResponse, error)
	ControlWorker(context.Context, *ControlWorkerRequest) (*ControlWorkerResponse, error)
}

WorkersServer is the server API for Workers service.

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.