servers

Documentation

Index

• func RunGrpc(monitor *Monitor)
• type Monitor
  • func NewServiceMonitor() *Monitor
  • func (monitor *Monitor) ErrorsEncountered() bool
  • func (monitor *Monitor) ShutdownServers()
  • func (monitor *Monitor) StartServers()
  • func (monitor *Monitor) WaitOnShutdown()
• type StalkForecastServer
  • func (server *StalkForecastServer) ForecastPrices(ctx context.Context, ticker *stalkproto.Ticker) (*stalkproto.Forecast, error)

Functions

func RunGrpc

func RunGrpc(
	monitor *Monitor,
)

Types

type Monitor

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

We'll use this to run the services, with a bonus that we can use it during tests as well.

func NewServiceMonitor

func NewServiceMonitor() *Monitor

func (*Monitor) ErrorsEncountered

func (monitor *Monitor) ErrorsEncountered() bool

func (*Monitor) ShutdownServers

func (monitor *Monitor) ShutdownServers()

Sends shutdown signals. Forces shutdown after 10 seconds.

func (*Monitor) StartServers

func (monitor *Monitor) StartServers()

Start monitoring the servers

func (*Monitor) WaitOnShutdown

func (monitor *Monitor) WaitOnShutdown()

BLocks until servers are shut down.

type StalkForecastServer

type StalkForecastServer struct{}

func (*StalkForecastServer) ForecastPrices

func (server *StalkForecastServer) ForecastPrices(
	ctx context.Context, ticker *stalkproto.Ticker,
) (*stalkproto.Forecast, error)