sandboxutils

Documentation

Index

• Variables
• type CloudEventsSandboxOnlyPublisher
  • func NewCloudEventsPublisher() *CloudEventsSandboxOnlyPublisher
  • func (z *CloudEventsSandboxOnlyPublisher) Publish(ctx context.Context, topic string, msg proto.Message) error
  • func (z *CloudEventsSandboxOnlyPublisher) PublishRaw(ctx context.Context, topic string, msgRaw []byte) error
• type SandboxMessage

Variables

var MsgChan chan SandboxMessage

Types

type CloudEventsSandboxOnlyPublisher

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

func NewCloudEventsPublisher

func NewCloudEventsPublisher() *CloudEventsSandboxOnlyPublisher

func (*CloudEventsSandboxOnlyPublisher) Publish

func (z *CloudEventsSandboxOnlyPublisher) Publish(ctx context.Context, topic string, msg proto.Message) error

func (*CloudEventsSandboxOnlyPublisher) PublishRaw

func (z *CloudEventsSandboxOnlyPublisher) PublishRaw(ctx context.Context, topic string, msgRaw []byte) error

PublishRaw will publish a raw byte array as a message with context.

type SandboxMessage

type SandboxMessage struct {
	Msg   proto.Message
	Raw   []byte
	Topic string
}