master

Documentation

Index

• func MustInitMasterService(creds credentials.TransportCredentials)
• func NewRpcServer(creds credentials.TransportCredentials) *grpc.Server
• func RunRpcServer(s *grpc.Server)
• type Master
  • func NewMasterHandler(creds credentials.TransportCredentials) *Master
  • func (s *Master) Run()
  • func (s *Master) Stop()
• type MasterHandler
  • func GetMasterSerivce() MasterHandler

Functions

func MustInitMasterService

func MustInitMasterService(creds credentials.TransportCredentials)

func NewRpcServer

func NewRpcServer(creds credentials.TransportCredentials) *grpc.Server

func RunRpcServer

func RunRpcServer(s *grpc.Server)

Types

type Master

type Master struct {
	// contains filtered or unexported fields
}

func NewMasterHandler

func NewMasterHandler(creds credentials.TransportCredentials) *Master

func (*Master) Run

func (s *Master) Run()

func (*Master) Stop

func (s *Master) Stop()

type MasterHandler

type MasterHandler interface {
	Run()
	Stop()
}

func GetMasterSerivce

func GetMasterSerivce() MasterHandler