sinks

Documentation

Index

• type ErrorSink
  • func NewErrorSink(ctx context.Context, inChan chan error) *ErrorSink
  • func (es ErrorSink) In() chan<- error
  • func (es ErrorSink) Log()
• type WebhookSink
  • func NewWebhookSink(ctx context.Context, client *resty.Client, operatorWebhook string, ...) *WebhookSink
  • func (hws WebhookSink) In() chan<- StreamMessage[*common.RunCompletionEventData]
  • func (hws WebhookSink) SendEvents()

Types

type ErrorSink

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

func NewErrorSink

func NewErrorSink(ctx context.Context, inChan chan error) *ErrorSink

func (ErrorSink) In

func (es ErrorSink) In() chan<- error

func (ErrorSink) Log

func (es ErrorSink) Log()

type WebhookSink

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

func NewWebhookSink

func NewWebhookSink(ctx context.Context, client *resty.Client, operatorWebhook string, inChan chan StreamMessage[*common.RunCompletionEventData]) *WebhookSink

func (WebhookSink) In

func (hws WebhookSink) In() chan<- StreamMessage[*common.RunCompletionEventData]

func (WebhookSink) SendEvents

func (hws WebhookSink) SendEvents()