watchers

Documentation

Index

• type BProtocolDispatcher
  • func NewBProtocolDispatcher(callback compute.Callback) *BProtocolDispatcher
  • func (d *BProtocolDispatcher) HandleEvent(ctx context.Context, event watcher.Event) error
• type CallbackMock
  • func (c CallbackMock) OnBidComplete(ctx context.Context, result legacy.BidResult)
  • func (c CallbackMock) OnComputeFailure(ctx context.Context, err legacy.ComputeError)
  • func (c CallbackMock) OnRunComplete(ctx context.Context, result legacy.RunResult)
• type ExecutionLogger
  • func NewExecutionLogger(logger zerolog.Logger) *ExecutionLogger
  • func (e *ExecutionLogger) HandleEvent(ctx context.Context, event watcher.Event) error
• type ExecutionUpsertHandler
  • func NewExecutionUpsertHandler(executor compute.Executor, bidder compute.Bidder) *ExecutionUpsertHandler
  • func (h *ExecutionUpsertHandler) HandleEvent(ctx context.Context, event watcher.Event) error
• type NCLMessageCreator
  • func NewNCLMessageCreator() *NCLMessageCreator
  • func (d *NCLMessageCreator) CreateMessage(event watcher.Event) (*envelope.Message, error)

Types

type BProtocolDispatcher

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

BProtocolDispatcher handles forwarding messages based on execution state changes

func NewBProtocolDispatcher

func NewBProtocolDispatcher(callback compute.Callback) *BProtocolDispatcher

NewBProtocolDispatcher creates a new BProtocolDispatcher with the given callback

func (*BProtocolDispatcher) HandleEvent

func (d *BProtocolDispatcher) HandleEvent(ctx context.Context, event watcher.Event) error

HandleEvent processes a watcher event and publishes appropriate messages

type CallbackMock

type CallbackMock struct {
	OnBidCompleteHandler    func(ctx context.Context, result legacy.BidResult)
	OnComputeFailureHandler func(ctx context.Context, err legacy.ComputeError)
	OnRunCompleteHandler    func(ctx context.Context, result legacy.RunResult)
}

func (CallbackMock) OnBidComplete

func (c CallbackMock) OnBidComplete(ctx context.Context, result legacy.BidResult)

OnBidComplete implements Callback

func (CallbackMock) OnComputeFailure

func (c CallbackMock) OnComputeFailure(ctx context.Context, err legacy.ComputeError)

OnComputeFailure implements Callback

func (CallbackMock) OnRunComplete

func (c CallbackMock) OnRunComplete(ctx context.Context, result legacy.RunResult)

OnRunComplete implements Callback

type ExecutionLogger

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

ExecutionLogger handles logging of execution-related events with detailed state transition information

func NewExecutionLogger

func NewExecutionLogger(logger zerolog.Logger) *ExecutionLogger

NewExecutionLogger creates a new ExecutionLogger instance

func (*ExecutionLogger) HandleEvent

func (e *ExecutionLogger) HandleEvent(ctx context.Context, event watcher.Event) error

HandleEvent processes incoming events and logs detailed execution information

type ExecutionUpsertHandler

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

func NewExecutionUpsertHandler

func NewExecutionUpsertHandler(executor compute.Executor, bidder compute.Bidder) *ExecutionUpsertHandler

func (*ExecutionUpsertHandler) HandleEvent

func (h *ExecutionUpsertHandler) HandleEvent(ctx context.Context, event watcher.Event) error

type NCLMessageCreator

type NCLMessageCreator struct {
}

func NewNCLMessageCreator

func NewNCLMessageCreator() *NCLMessageCreator

func (*NCLMessageCreator) CreateMessage

func (d *NCLMessageCreator) CreateMessage(event watcher.Event) (*envelope.Message, error)