relay

Documentation

Index

• func NewEventService(ctx context.Context, opts EventServiceOpts) relay.EventServiceServer
• type EventService
  • func (e *EventService) FetchReconfigureEvents(req *relay.FetchReconfigureEventsRequest, ...) error
• type EventServiceOpts
• type StatusService
  • func NewStatusService(opts StatusServiceOpts) *StatusService
  • func (s StatusService) UpdateExpectedHash(ctx context.Context, req *relay.UpdateExpectedHashRequest) (*relay.UpdateExpectedHashResponse, error)
  • func (s StatusService) UpdateNodeStatus(ctx context.Context, req *relay.UpdateNodeStatusRequest) (*relay.UpdateNodeStatusResponse, error)
• type StatusServiceOpts

Functions

func NewEventService

func NewEventService(ctx context.Context, opts EventServiceOpts) relay.EventServiceServer

Types

type EventService

type EventService struct {
	relay.UnimplementedEventServiceServer
	// contains filtered or unexported fields
}

func (*EventService) FetchReconfigureEvents

func (e *EventService) FetchReconfigureEvents(req *relay.FetchReconfigureEventsRequest,
	stream relay.EventService_FetchReconfigureEventsServer,
) error

type EventServiceOpts

type EventServiceOpts struct {
	Store  store.Store
	Logger *zap.Logger
}

type StatusService

type StatusService struct {
	relay.UnimplementedStatusServiceServer
	// contains filtered or unexported fields
}

func NewStatusService

func NewStatusService(opts StatusServiceOpts) *StatusService

func (StatusService) UpdateExpectedHash

func (s StatusService) UpdateExpectedHash(ctx context.Context,
	req *relay.UpdateExpectedHashRequest,
) (*relay.UpdateExpectedHashResponse, error)

func (StatusService) UpdateNodeStatus

func (s StatusService) UpdateNodeStatus(
	ctx context.Context,
	req *relay.UpdateNodeStatusRequest,
) (*relay.UpdateNodeStatusResponse, error)

type StatusServiceOpts

type StatusServiceOpts struct {
	StoreLoader util.StoreLoader
	Logger      *zap.Logger
}