nats

Documentation

Index

• type Options
• type Results
  • func New(cfg Options, lo *slog.Logger) (*Results, error)
  • func (r *Results) DeleteJob(_ context.Context, id string) error
  • func (r *Results) Get(_ context.Context, id string) ([]byte, error)
  • func (r *Results) GetFailed(_ context.Context) ([]string, error)
  • func (r *Results) GetSuccess(_ context.Context) ([]string, error)
  • func (r *Results) NilError() error
  • func (r *Results) Set(_ context.Context, id string, b []byte) error
  • func (r *Results) SetFailed(_ context.Context, id string) error
  • func (r *Results) SetSuccess(_ context.Context, id string) error

Types

type Options

type Options struct {
	URL         string
	EnabledAuth bool
	Username    string
	Password    string
}

type Results

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

func New

func New(cfg Options, lo *slog.Logger) (*Results, error)

New() returns a new instance of nats-jetstream broker.

func (*Results) DeleteJob

func (r *Results) DeleteJob(_ context.Context, id string) error

func (*Results) Get

func (r *Results) Get(_ context.Context, id string) ([]byte, error)

func (*Results) GetFailed

func (r *Results) GetFailed(_ context.Context) ([]string, error)

func (*Results) GetSuccess

func (r *Results) GetSuccess(_ context.Context) ([]string, error)

func (*Results) NilError

func (r *Results) NilError() error

func (*Results) Set

func (r *Results) Set(_ context.Context, id string, b []byte) error

func (*Results) SetFailed

func (r *Results) SetFailed(_ context.Context, id string) error

func (*Results) SetSuccess

func (r *Results) SetSuccess(_ context.Context, id string) error