grpc

package
v0.9.2 Latest Latest
Warning

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

Go to latest
Published: Sep 23, 2020 License: AGPL-3.0 Imports: 21 Imported by: 0

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 Datasource interface {
	FindMachineByID(machineID string) (*metal.Machine, error)
	UpdateMachine(old, new *metal.Machine) error
}

type WaitServer

type WaitServer struct {
	bus.Publisher
	// contains filtered or unexported fields
}

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL