Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Datasource ¶ added in v0.8.3
type WaitServer ¶
func NewWaitServer ¶
func NewWaitServer(cfg *WaitServerConfig) (*WaitServer, error)
func (*WaitServer) NotifyAllocated ¶
func (s *WaitServer) NotifyAllocated(machineID string) error
func (*WaitServer) Serve ¶ added in v0.8.3
func (s *WaitServer) Serve() error
func (*WaitServer) Wait ¶
func (s *WaitServer) Wait(req *v1.WaitRequest, srv v1.Wait_WaitServer) error
type WaitServerConfig ¶
type WaitServerConfig struct {
Publisher bus.Publisher
Datasource Datasource
Logger *zap.SugaredLogger
NsqTlsConfig *bus.TLSConfig
NsqlookupdHttpAddress string
GrpcPort int
TlsEnabled bool
CaCertFile string
ServerCertFile string
ServerKeyFile string
ResponseInterval time.Duration
CheckInterval time.Duration
}
Click to show internal directories.
Click to hide internal directories.