messages

Documentation

Index

• Constants
• type Closeable
• type CloudEventNotifier
  • func (n *CloudEventNotifier) Close()
  • func (n *CloudEventNotifier) NonBlockPush(eventType, externalComponent, externalID string, data map[string]interface{})
• type EchoNotifier
  • func (n *EchoNotifier) Close()
  • func (n *EchoNotifier) NonBlockPush(eventType, externalComponent, externalID string, data map[string]interface{})
• type Notifier
  • func NewCloudEventNotifier(config config.MQ, logger *zap.Logger) (Notifier, error)
  • func NewEchoNotifier(logger *zap.Logger) (Notifier, error)

Constants

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

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)