statuschecker

Documentation

Index

• type FullStatus
• type Handle
  • func New(log logrus.FieldLogger, delay time.Duration, ...) (*Handle, error)
  • func NewDumb() *Handle
  • func (h *Handle) Errors() chan error
  • func (h *Handle) Run(ctx context.Context)
  • func (h *Handle) Statuses() chan *FullStatus
  • func (h *Handle) Stop()
• type NewClientFn
• type ServerStatusCheckerInterface

Types

type FullStatus

type FullStatus struct {
	Nodes  *observer.GetNodesResponse
	Status *observer.ServerStatusResponse
}

type Handle

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

func New

func New(
	log logrus.FieldLogger,
	delay time.Duration,
	connPool grpc_client.ConnectionPool,
	callProps grpc_client.CallPropertiesProvider,
) (*Handle, error)

func NewDumb

func NewDumb() *Handle

func (*Handle) Errors

func (h *Handle) Errors() chan error

func (*Handle) Run

func (h *Handle) Run(ctx context.Context)

func (*Handle) Statuses

func (h *Handle) Statuses() chan *FullStatus

func (*Handle) Stop

func (h *Handle) Stop()

type NewClientFn

type NewClientFn = func(context.Context, int) (observer.ObserverClient, error)

type ServerStatusCheckerInterface

type ServerStatusCheckerInterface interface {
	Run(context.Context)
	Stop()

	Errors() chan error
	Statuses() chan *FullStatus
}