builder

Documentation

Index

• Constants
• Variables
• func DoesEmptySegmentsExist(segments []string) bool
• type CloudEventBuilder
  • func NewEventMeshBuilder(prefix string, eventMeshNamespace string, cleaner cleaner.Cleaner, ...) CloudEventBuilder
  • func NewGenericBuilder(typePrefix string, cleaner cleaner.Cleaner, ...) CloudEventBuilder
• type EventMeshBuilder
  • func (emb *EventMeshBuilder) Build(event ceevent.Event) (*ceevent.Event, error)
• type GenericBuilder
  • func (gb *GenericBuilder) Build(event ceevent.Event) (*ceevent.Event, error)
  • func (gb *GenericBuilder) GetAppNameOrSource(source string, namedLogger *zap.SugaredLogger) string

Constants

const (
	OriginalTypeHeaderName = "originaltype"
)

Variables

var ErrEventTypeCannotHaveEmptySegments = errors.New("event type cannot have empty segments after cleaning")

Functions

func DoesEmptySegmentsExist

func DoesEmptySegmentsExist(segments []string) bool

Types

type CloudEventBuilder

type CloudEventBuilder interface {
	Build(event ceevent.Event) (*ceevent.Event, error)
}

func NewEventMeshBuilder

func NewEventMeshBuilder(prefix string, eventMeshNamespace string, cleaner cleaner.Cleaner,
	applicationLister *application.Lister, logger *logger.Logger,
) CloudEventBuilder

func NewGenericBuilder

func NewGenericBuilder(typePrefix string, cleaner cleaner.Cleaner, applicationLister *application.Lister,
	logger *logger.Logger,
) CloudEventBuilder

type EventMeshBuilder

type EventMeshBuilder struct {
	// contains filtered or unexported fields
}

func (*EventMeshBuilder) Build

func (emb *EventMeshBuilder) Build(event ceevent.Event) (*ceevent.Event, error)

type GenericBuilder

type GenericBuilder struct {
	// contains filtered or unexported fields
}

func (*GenericBuilder) Build

func (gb *GenericBuilder) Build(event ceevent.Event) (*ceevent.Event, error)

func (*GenericBuilder) GetAppNameOrSource

func (gb *GenericBuilder) GetAppNameOrSource(source string, namedLogger *zap.SugaredLogger) string

GetAppNameOrSource returns the application name if exists, otherwise returns source name.