nats

package

v1.0.0-dev.93 Latest Latest Go to latest Published: Aug 15, 2024 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func New[T any](conn *nats.Conn) function.CmdFunc[T]

New returns CmdFunc for cloudevents command.

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

Helper assists in creating event handlers.

func NewHelper[T any](conn *nats.Conn, handler function.Handler[T]) *Helper[T]

NewHelper returns a new Helper with default options.

func NewHelperWithOptions[T any](conn *nats.Conn,
	handler function.Handler[T], options *Options) *Helper[T]

NewHelperWithOptions returns a new Helper with options.

func (h *Helper[T]) Start()

type Options struct {
	Subjects []string
	Queue    string
}

Options can be used to create customized handler.

func DefaultOptions() (*Options, error)

DefaultOptions returns options based in config.