Documentation
¶
Index ¶
- func NewCloudEventsPublisher(sender interfaces.Sender, scope promutils.Scope, eventTypes []string) interfaces.Publisher
- func NewCloudEventsWrappedPublisher(db repositoryInterfaces.Repository, sender interfaces.Sender, ...) interfaces.Publisher
- type CloudEventWrappedPublisher
- func (c *CloudEventWrappedPublisher) Publish(ctx context.Context, notificationType string, msg proto.Message) error
- func (c *CloudEventWrappedPublisher) TransformNodeExecutionEvent(ctx context.Context, rawEvent *event.NodeExecutionEvent) (*event.CloudEventNodeExecution, error)
- func (c *CloudEventWrappedPublisher) TransformTaskExecutionEvent(ctx context.Context, rawEvent *event.TaskExecutionEvent) (*event.CloudEventTaskExecution, error)
- func (c *CloudEventWrappedPublisher) TransformWorkflowExecutionEvent(ctx context.Context, rawEvent *event.WorkflowExecutionEvent) (*event.CloudEventWorkflowExecution, error)
- type KafkaSender
- type PubSubSender
- type Publisher
- type Receiver
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCloudEventsPublisher ¶
func NewCloudEventsPublisher(sender interfaces.Sender, scope promutils.Scope, eventTypes []string) interfaces.Publisher
func NewCloudEventsWrappedPublisher ¶
func NewCloudEventsWrappedPublisher( db repositoryInterfaces.Repository, sender interfaces.Sender, scope promutils.Scope, storageClient *storage.DataStore, urlData dataInterfaces.RemoteURLInterface, remoteDataConfig runtimeInterfaces.RemoteDataConfig) interfaces.Publisher
Types ¶
type CloudEventWrappedPublisher ¶
type CloudEventWrappedPublisher struct {
// contains filtered or unexported fields
}
func (*CloudEventWrappedPublisher) TransformNodeExecutionEvent ¶
func (c *CloudEventWrappedPublisher) TransformNodeExecutionEvent(ctx context.Context, rawEvent *event.NodeExecutionEvent) (*event.CloudEventNodeExecution, error)
func (*CloudEventWrappedPublisher) TransformTaskExecutionEvent ¶
func (c *CloudEventWrappedPublisher) TransformTaskExecutionEvent(ctx context.Context, rawEvent *event.TaskExecutionEvent) (*event.CloudEventTaskExecution, error)
func (*CloudEventWrappedPublisher) TransformWorkflowExecutionEvent ¶
func (c *CloudEventWrappedPublisher) TransformWorkflowExecutionEvent(ctx context.Context, rawEvent *event.WorkflowExecutionEvent) (*event.CloudEventWorkflowExecution, error)
type KafkaSender ¶
type KafkaSender struct {
Client cloudevents.Client
}
KafkaSender Implementation of Sender
func (*KafkaSender) Send ¶
func (s *KafkaSender) Send(ctx context.Context, notificationType string, event cloudevents.Event) error
type PubSubSender ¶
PubSubSender Implementation of Sender
func (*PubSubSender) Send ¶
func (s *PubSubSender) Send(ctx context.Context, notificationType string, event cloudevents.Event) error
Source Files
Click to show internal directories.
Click to hide internal directories.