publisher

Documentation

Index

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

Constants

const (
	// FAILED status label
	FAILED = "failed"
	// IGNORED status label
	IGNORED = "ignored"
	// 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, channelName *string,
	namespace *string, headers *map[string][]string, payload *[]byte, publishRequest *api.Request) (*api.Error,
	string)

Publish events using the KnativeLib

type KnativePublisher

type KnativePublisher interface {
	Publish(knativeLib *knative.KnativeLib, channelName *string, namespace *string, headers *map[string][]string,
		payload *[]byte, publishRequest *api.Request) (*api.Error, string)
}

KnativePublisher encapsulates the publish behaviour.

func NewKnativePublisher

func NewKnativePublisher() KnativePublisher

NewKnativePublisher creates a new KnativePublisher instance.