server

Documentation

Overview

Package server is a generated protocol buffer package.

It is generated from these files:

server.proto

It has these top-level messages:

RegisterWorkerRequest
RegisterWorkerReply

Index

• func RegisterServerServer(s *grpc.Server, srv ServerServer)
• type RegisterWorkerReply
  • func (*RegisterWorkerReply) Descriptor() ([]byte, []int)
  • func (m *RegisterWorkerReply) GetState() string
  • func (*RegisterWorkerReply) ProtoMessage()
  • func (m *RegisterWorkerReply) Reset()
  • func (m *RegisterWorkerReply) String() string
• type RegisterWorkerRequest
  • func (*RegisterWorkerRequest) Descriptor() ([]byte, []int)
  • func (m *RegisterWorkerRequest) GetAddress() string
  • func (*RegisterWorkerRequest) ProtoMessage()
  • func (m *RegisterWorkerRequest) Reset()
  • func (m *RegisterWorkerRequest) String() string
• type ServerClient
  • func NewServerClient(cc *grpc.ClientConn) ServerClient
• type ServerServer

Functions

func RegisterServerServer

func RegisterServerServer(s *grpc.Server, srv ServerServer)

Types

type RegisterWorkerReply

type RegisterWorkerReply struct {
	State string `protobuf:"bytes,1,opt,name=state" json:"state,omitempty"`
}

Worker registering reply

func (*RegisterWorkerReply) Descriptor

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

func (*RegisterWorkerReply) GetState

func (m *RegisterWorkerReply) GetState() string

func (*RegisterWorkerReply) ProtoMessage

func (*RegisterWorkerReply) ProtoMessage()

func (*RegisterWorkerReply) Reset

func (m *RegisterWorkerReply) Reset()

func (*RegisterWorkerReply) String

func (m *RegisterWorkerReply) String() string

type RegisterWorkerRequest

type RegisterWorkerRequest struct {
	Address string `protobuf:"bytes,1,opt,name=address" json:"address,omitempty"`
}

Worker registering request

func (*RegisterWorkerRequest) Descriptor

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

func (*RegisterWorkerRequest) GetAddress

func (m *RegisterWorkerRequest) GetAddress() string

func (*RegisterWorkerRequest) ProtoMessage

func (*RegisterWorkerRequest) ProtoMessage()

func (*RegisterWorkerRequest) Reset

func (m *RegisterWorkerRequest) Reset()

func (*RegisterWorkerRequest) String

func (m *RegisterWorkerRequest) String() string

type ServerClient

type ServerClient interface {
	// Register a worker
	RegisterWorker(ctx context.Context, in *RegisterWorkerRequest, opts ...grpc.CallOption) (*RegisterWorkerReply, error)
}

func NewServerClient

func NewServerClient(cc *grpc.ClientConn) ServerClient

type ServerServer

type ServerServer interface {
	// Register a worker
	RegisterWorker(context.Context, *RegisterWorkerRequest) (*RegisterWorkerReply, error)
}