republish

Documentation

Index

• Constants
• Variables
• func SetRepublishStream(sinkStream stream.Sink) error

Constants

const (
	EntityType = "republish"
)

Variables

var (
	ErrActionMetadataNil        = fmt.Errorf("action metadata is nil")
	ErrActionTypeNotFound       = fmt.Errorf("action type not found")
	ErrActionMetadataTopicEmpty = fmt.Errorf("action metadata topic empty")
	ErrRepublishTopicEmpty      = fmt.Errorf("republish topic empty")
	ErrRepublishNewTopicEmpty   = fmt.Errorf("republish new topic empty")
	ErrRepublishSendError       = fmt.Errorf("republish send error")
	ErrRepublishSinkStreamError = fmt.Errorf("republish Stream nil")
)

var (
	Execute = utils.Execute
)

Functions

func SetRepublishStream

func SetRepublishStream(sinkStream stream.Sink) error