messages

package
v0.0.0-...-6ed6c48 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 28, 2022 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TopicImageStatus = "omni-repository-image-status"
	SourceUrl        = "github.com/omnibuildplatform/omni-repository"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Closeable

type Closeable interface {
	Close()
}

type CloudEventNotifier

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

func (*CloudEventNotifier) Close

func (n *CloudEventNotifier) Close()

func (*CloudEventNotifier) NonBlockPush

func (n *CloudEventNotifier) NonBlockPush(eventType, externalComponent, externalID string, data map[string]interface{})

type EchoNotifier

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

func (*EchoNotifier) Close

func (n *EchoNotifier) Close()

func (*EchoNotifier) NonBlockPush

func (n *EchoNotifier) NonBlockPush(eventType, externalComponent, externalID string, data map[string]interface{})

type Notifier

type Notifier interface {
	Closeable
	NonBlockPush(eventType, externalComponent, externalID string, data map[string]interface{})
}

func NewCloudEventNotifier

func NewCloudEventNotifier(config config.MQ, logger *zap.Logger) (Notifier, error)

func NewEchoNotifier

func NewEchoNotifier(logger *zap.Logger) (Notifier, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL