grpc

package
v0.8.2 Latest Latest
Warning

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

Go to latest
Published: Aug 7, 2020 License: AGPL-3.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Serve

func Serve(ws *WaitServer) error

Types

type WaitServer

type WaitServer struct {
	bus.Publisher

	GrpcPort       int
	TlsEnabled     bool
	CaCertFile     string
	ServerCertFile string
	ServerKeyFile  string
	// 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) Wait

func (s *WaitServer) Wait(req *v1.WaitRequest, srv v1.Wait_WaitServer) error

type WaitServerConfig

type WaitServerConfig struct {
	Publisher             bus.Publisher
	Datasource            *datastore.RethinkStore
	Logger                *zap.SugaredLogger
	NsqTlsConfig          *bus.TLSConfig
	NsqlookupdHttpAddress string
	GrpcPort              int
	TlsEnabled            bool
	CaCertFile            string
	ServerCertFile        string
	ServerKeyFile         string
}

Jump to

Keyboard shortcuts

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