message

package
v2.0.0-k8s-migrate-to-... Latest Latest
Warning

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

Go to latest
Published: Jan 15, 2020 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CPHMessageCreator

type CPHMessageCreator struct {
}

func NewDefaultCPHMessageCreator

func NewDefaultCPHMessageCreator() *CPHMessageCreator

func (*CPHMessageCreator) ToPublicationEvent

func (cmc *CPHMessageCreator) ToPublicationEvent(coreAttributes *model.UppCoreContent, payload interface{}) *model.PublicationEvent

func (*CPHMessageCreator) ToPublicationEventMessage

func (cmc *CPHMessageCreator) ToPublicationEventMessage(coreAttributes *model.UppCoreContent, payload interface{}) (*producer.Message, error)

type MessageCreator

type MessageCreator interface {
	ToPublicationEventMessage(coreAttributes *model.UppCoreContent, payload interface{}) (*producer.Message, error)
	ToPublicationEvent(coreAttributes *model.UppCoreContent, payload interface{}) *model.PublicationEvent
}

Jump to

Keyboard shortcuts

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