publisher

Documentation

Index

• type AnyEvent
• type NatsPublisher
  • func (n *NatsPublisher[T]) Publish(ctx context.Context, record T, meta common.MetaData, ...) error
• type PublishOptions
• type Publisher
  • func NewNatsPublisher[T any](con *nats.Conn, subject string, interceptors ...UnaryPublisherInterceptorFunc) Publisher[T]
• type UnaryPublisherFunc
• type UnaryPublisherInterceptorFunc

Types

type AnyEvent

type AnyEvent interface {
	SetHeader(header string, value string)
	GetHeader(header string) []string
	GetBody() []byte
	GetDestination() string
	GetDestinationType() string
}

type NatsPublisher

type NatsPublisher[T any] struct {
	// contains filtered or unexported fields
}

func (*NatsPublisher[T]) Publish

func (n *NatsPublisher[T]) Publish(
	ctx context.Context,
	record T,
	meta common.MetaData,
	publishOptions *PublishOptions,
) error

type PublishOptions

type PublishOptions struct {
	Headers       map[string][]string
	CustomSubject string
}

type Publisher

type Publisher[T any] interface {
	Publish(
		ctx context.Context,
		record T,
		meta common.MetaData,
		headers *PublishOptions,
	) error
}

func NewNatsPublisher

func NewNatsPublisher[T any](
	con *nats.Conn,
	subject string,
	interceptors ...UnaryPublisherInterceptorFunc,
) Publisher[T]

type UnaryPublisherFunc

type UnaryPublisherFunc = func(ctx context.Context, event AnyEvent)

type UnaryPublisherInterceptorFunc

type UnaryPublisherInterceptorFunc = func(next UnaryPublisherFunc) UnaryPublisherFunc