publisher

Documentation

Index

• Constants
• type DefaultKnativePublisher
  • func (publisher *DefaultKnativePublisher) Publish(knativeLib *knative.KnativeLib, namespace *string, ...) (error *api.Error, status string, channelName string)
• type KnativePublisher
  • func NewKnativePublisher() KnativePublisher

Constants

const (
	// Failed status label
	Failed = "failed"
	// IgnoredChannelMissing status label
	IgnoredChannelMissing = "ignored_channel_missing"
	// IgnoredChannelNotReady status label
	IgnoredChannelNotReady = "ignored_channel_not_ready"
	// Published status label
	Published = "published"
)

Types

type DefaultKnativePublisher

type DefaultKnativePublisher struct{}

DefaultKnativePublisher is the default KnativePublisher instance.

func (*DefaultKnativePublisher) Publish

func (publisher *DefaultKnativePublisher) Publish(knativeLib *knative.KnativeLib,
	namespace *string, headers *map[string][]string, payload *[]byte, source string,
	eventType string, eventTypeVersion string) (error *api.Error, status string, channelName string)

Publish events using the KnativeLib

type KnativePublisher

type KnativePublisher interface {
	Publish(knativeLib *knative.KnativeLib, namespace *string, headers *map[string][]string,
		payload *[]byte, source string,
		eventType string, eventTypeVersion string) (error *api.Error, status string, channelName string)
}

KnativePublisher encapsulates the publish behaviour.

func NewKnativePublisher

func NewKnativePublisher() KnativePublisher

NewKnativePublisher creates a new KnativePublisher instance.