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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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)
Source Files
Click to show internal directories.
Click to hide internal directories.