service

Documentation

Index

• type MasterServiceV2
  • func GetMasterServiceV2() (res *MasterServiceV2, err error)
  • func (svc *MasterServiceV2) GetAddress() (address interfaces.Address)
  • func (svc *MasterServiceV2) GetConfigPath() (path string)
  • func (svc *MasterServiceV2) GetConfigService() (cfgSvc interfaces.NodeConfigService)
  • func (svc *MasterServiceV2) GetServer() (svr interfaces.GrpcServer)
  • func (svc *MasterServiceV2) Init() (err error)
  • func (svc *MasterServiceV2) Monitor()
  • func (svc *MasterServiceV2) Register() (err error)
  • func (svc *MasterServiceV2) SetAddress(address interfaces.Address)
  • func (svc *MasterServiceV2) SetConfigPath(path string)
  • func (svc *MasterServiceV2) SetMonitorInterval(duration time.Duration)
  • func (svc *MasterServiceV2) Start()
  • func (svc *MasterServiceV2) Stop()
  • func (svc *MasterServiceV2) StopOnError()
  • func (svc *MasterServiceV2) Wait()
• type Option
  • func WithAddress(address interfaces.Address) Option
  • func WithConfigPath(path string) Option
  • func WithHeartbeatInterval(duration time.Duration) Option
  • func WithMonitorInterval(duration time.Duration) Option
  • func WithStopOnError() Option
• type WorkerServiceV2
  • func GetWorkerServiceV2() (res *WorkerServiceV2, err error)
  • func (svc *WorkerServiceV2) GetAddress() (address interfaces.Address)
  • func (svc *WorkerServiceV2) GetConfigPath() (path string)
  • func (svc *WorkerServiceV2) GetConfigService() (cfgSvc interfaces.NodeConfigService)
  • func (svc *WorkerServiceV2) Init() (err error)
  • func (svc *WorkerServiceV2) Recv()
  • func (svc *WorkerServiceV2) Register()
  • func (svc *WorkerServiceV2) ReportStatus()
  • func (svc *WorkerServiceV2) SetAddress(address interfaces.Address)
  • func (svc *WorkerServiceV2) SetConfigPath(path string)
  • func (svc *WorkerServiceV2) SetHeartbeatInterval(duration time.Duration)
  • func (svc *WorkerServiceV2) Start()
  • func (svc *WorkerServiceV2) Stop()
  • func (svc *WorkerServiceV2) Wait()

Types

type MasterServiceV2

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

func GetMasterServiceV2

func GetMasterServiceV2() (res *MasterServiceV2, err error)

func (*MasterServiceV2) GetAddress

func (svc *MasterServiceV2) GetAddress() (address interfaces.Address)

func (*MasterServiceV2) GetConfigPath

func (svc *MasterServiceV2) GetConfigPath() (path string)

func (*MasterServiceV2) GetConfigService

func (svc *MasterServiceV2) GetConfigService() (cfgSvc interfaces.NodeConfigService)

func (*MasterServiceV2) GetServer

func (svc *MasterServiceV2) GetServer() (svr interfaces.GrpcServer)

func (*MasterServiceV2) Init

func (svc *MasterServiceV2) Init() (err error)

func (*MasterServiceV2) Monitor

func (svc *MasterServiceV2) Monitor()

func (*MasterServiceV2) Register

func (svc *MasterServiceV2) Register() (err error)

func (*MasterServiceV2) SetAddress

func (svc *MasterServiceV2) SetAddress(address interfaces.Address)

func (*MasterServiceV2) SetConfigPath

func (svc *MasterServiceV2) SetConfigPath(path string)

func (*MasterServiceV2) SetMonitorInterval

func (svc *MasterServiceV2) SetMonitorInterval(duration time.Duration)

func (*MasterServiceV2) Start

func (svc *MasterServiceV2) Start()

func (*MasterServiceV2) Stop

func (svc *MasterServiceV2) Stop()

func (*MasterServiceV2) StopOnError

func (svc *MasterServiceV2) StopOnError()

func (*MasterServiceV2) Wait

func (svc *MasterServiceV2) Wait()

type Option

type Option func(svc interfaces.NodeService)

func WithAddress

func WithAddress(address interfaces.Address) Option

func WithConfigPath

func WithConfigPath(path string) Option

func WithHeartbeatInterval

func WithHeartbeatInterval(duration time.Duration) Option

func WithMonitorInterval

func WithMonitorInterval(duration time.Duration) Option

func WithStopOnError

func WithStopOnError() Option

type WorkerServiceV2

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

func GetWorkerServiceV2

func GetWorkerServiceV2() (res *WorkerServiceV2, err error)

func (*WorkerServiceV2) GetAddress

func (svc *WorkerServiceV2) GetAddress() (address interfaces.Address)

func (*WorkerServiceV2) GetConfigPath

func (svc *WorkerServiceV2) GetConfigPath() (path string)

func (*WorkerServiceV2) GetConfigService

func (svc *WorkerServiceV2) GetConfigService() (cfgSvc interfaces.NodeConfigService)

func (*WorkerServiceV2) Init

func (svc *WorkerServiceV2) Init() (err error)

func (*WorkerServiceV2) Recv

func (svc *WorkerServiceV2) Recv()

func (*WorkerServiceV2) Register

func (svc *WorkerServiceV2) Register()

func (*WorkerServiceV2) ReportStatus

func (svc *WorkerServiceV2) ReportStatus()

func (*WorkerServiceV2) SetAddress

func (svc *WorkerServiceV2) SetAddress(address interfaces.Address)

func (*WorkerServiceV2) SetConfigPath

func (svc *WorkerServiceV2) SetConfigPath(path string)

func (*WorkerServiceV2) SetHeartbeatInterval

func (svc *WorkerServiceV2) SetHeartbeatInterval(duration time.Duration)

func (*WorkerServiceV2) Start

func (svc *WorkerServiceV2) Start()

func (*WorkerServiceV2) Stop

func (svc *WorkerServiceV2) Stop()

func (*WorkerServiceV2) Wait

func (svc *WorkerServiceV2) Wait()