events

Documentation

Index

• func Emit(ctx context.Context, buses []messagebus.Client, msg protoreflect.ProtoMessage, ...) error
• func Extract(event *eventspb.CloudEvent, data protoreflect.ProtoMessage) error
• func New(msg protoreflect.ProtoMessage) (*eventspb.CloudEvent, error)
• func Validate(msg protoreflect.ProtoMessage) error
• type EventManager
  • func NewEventManager(ctx c.Context, registryAddress string) (EventManager, error)

Functions

func Emit

func Emit(ctx context.Context, buses []messagebus.Client, msg protoreflect.ProtoMessage, preview bool) error

func Extract

func Extract(event *eventspb.CloudEvent, data protoreflect.ProtoMessage) error

Extract extracts the data from a CloudEvent into the underlying proto message

func New

func New(msg protoreflect.ProtoMessage) (*eventspb.CloudEvent, error)

New creates a new CloudEvent from a proto message

func Validate

func Validate(msg protoreflect.ProtoMessage) error

Types

type EventManager

type EventManager interface {
	CreateAndSendEvent(ctx c.Context, event protoreflect.ProtoMessage) error
	Close()
}

func NewEventManager

func NewEventManager(ctx c.Context, registryAddress string) (EventManager, error)