nats

Documentation

Index

• Variables
• type Client
  • func NewClient(url string) (Client, error)
• type UnsubscribeFunc

Variables

var (
	ErrInconsistentConsumerConfig = errors.New(
		"consumer configuration is inconsistent: requires migration",
	)
)

Types

type Client

type Client interface {
	Close()
	IsConnected() bool
	JetStreamSubscribe(ctx context.Context, sub, dur string, q chan model.Job) error
	JetStreamPublish(string, []byte) error
	Migrate(ctx context.Context, sub, dur string, recreate bool) error
}

Client is the nats client

func NewClient

func NewClient(url string) (Client, error)

NewClient returns a new nats client with default options

type UnsubscribeFunc

type UnsubscribeFunc func() error