Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 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
}
Source Files
Click to show internal directories.
Click to hide internal directories.