Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

events

package

Go to main page

Versions in this module

v2

v2.1.1

Feb 26, 2025

v2.1.0

Jan 30, 2025

v2.0.0

Nov 12, 2024

Changes in this version

+ var ErrNatsConfig = errors.New("error in NATs Jetstream configuration")

+ var ErrNatsConn = errors.New("error opening nats connection")

+ var ErrNatsJetstream = errors.New("error in NATS Jetstream")

+ var ErrNatsJetstreamAddConsumer = errors.New("error adding consumer on NATS Jetstream")

+ var ErrNatsJetstreamAddStream = errors.New("error adding stream to NATS Jetstream")

+ var ErrNatsJetstreamUpdateConsumer = errors.New("error updating consumer configuration on NATS Jetstream")

+ var ErrNatsMsgPull = errors.New("error fetching message from NATS Jetstream")

+ var ErrSubscription = errors.New("error subscribing to stream")

+ func AsNatsConnection(n *NatsJetstream) *nats.Conn

+ func AsNatsJetStreamContext(n *NatsJetstream) nats.JetStreamContext

+ func AsNatsMsg(m Message) (*nats.Msg, error)

+ func MustNatsMsg(m Message) *nats.Msg

+ type EventType string

+ const Create

+ const Delete

+ const Update

+ type Message interface

+ Ack func() error

+ Data func() []byte

+ ExtractOtelTraceContext func(ctx context.Context) context.Context

+ InProgress func() error

+ Nak func() error

+ Subject func() string

+ Term func() error

+ type MockMessage struct

+ func NewMockMessage(t interface{ ... }) *MockMessage

+ func (_m *MockMessage) Ack() error

+ func (_m *MockMessage) Data() []byte

+ func (_m *MockMessage) EXPECT() *MockMessage_Expecter

+ func (_m *MockMessage) ExtractOtelTraceContext(ctx context.Context) context.Context

+ func (_m *MockMessage) InProgress() error

+ func (_m *MockMessage) Nak() error

+ func (_m *MockMessage) Subject() string

+ func (_m *MockMessage) Term() error

+ type MockMessage_Ack_Call struct

+ func (_c *MockMessage_Ack_Call) Return(_a0 error) *MockMessage_Ack_Call

+ func (_c *MockMessage_Ack_Call) Run(run func()) *MockMessage_Ack_Call

+ func (_c *MockMessage_Ack_Call) RunAndReturn(run func() error) *MockMessage_Ack_Call

+ type MockMessage_Data_Call struct

+ func (_c *MockMessage_Data_Call) Return(_a0 []byte) *MockMessage_Data_Call

+ func (_c *MockMessage_Data_Call) Run(run func()) *MockMessage_Data_Call

+ func (_c *MockMessage_Data_Call) RunAndReturn(run func() []byte) *MockMessage_Data_Call

+ type MockMessage_Expecter struct

+ func (_e *MockMessage_Expecter) Ack() *MockMessage_Ack_Call

+ func (_e *MockMessage_Expecter) Data() *MockMessage_Data_Call

+ func (_e *MockMessage_Expecter) ExtractOtelTraceContext(ctx interface{}) *MockMessage_ExtractOtelTraceContext_Call

+ func (_e *MockMessage_Expecter) InProgress() *MockMessage_InProgress_Call

+ func (_e *MockMessage_Expecter) Nak() *MockMessage_Nak_Call

+ func (_e *MockMessage_Expecter) Subject() *MockMessage_Subject_Call

+ func (_e *MockMessage_Expecter) Term() *MockMessage_Term_Call

+ type MockMessage_ExtractOtelTraceContext_Call struct

+ func (_c *MockMessage_ExtractOtelTraceContext_Call) Return(_a0 context.Context) *MockMessage_ExtractOtelTraceContext_Call

+ func (_c *MockMessage_ExtractOtelTraceContext_Call) Run(run func(ctx context.Context)) *MockMessage_ExtractOtelTraceContext_Call

+ func (_c *MockMessage_ExtractOtelTraceContext_Call) RunAndReturn(run func(context.Context) context.Context) *MockMessage_ExtractOtelTraceContext_Call

+ type MockMessage_InProgress_Call struct

+ func (_c *MockMessage_InProgress_Call) Return(_a0 error) *MockMessage_InProgress_Call

+ func (_c *MockMessage_InProgress_Call) Run(run func()) *MockMessage_InProgress_Call

+ func (_c *MockMessage_InProgress_Call) RunAndReturn(run func() error) *MockMessage_InProgress_Call

+ type MockMessage_Nak_Call struct

+ func (_c *MockMessage_Nak_Call) Return(_a0 error) *MockMessage_Nak_Call

+ func (_c *MockMessage_Nak_Call) Run(run func()) *MockMessage_Nak_Call

+ func (_c *MockMessage_Nak_Call) RunAndReturn(run func() error) *MockMessage_Nak_Call

+ type MockMessage_Subject_Call struct

+ func (_c *MockMessage_Subject_Call) Return(_a0 string) *MockMessage_Subject_Call

+ func (_c *MockMessage_Subject_Call) Run(run func()) *MockMessage_Subject_Call

+ func (_c *MockMessage_Subject_Call) RunAndReturn(run func() string) *MockMessage_Subject_Call

+ type MockMessage_Term_Call struct

+ func (_c *MockMessage_Term_Call) Return(_a0 error) *MockMessage_Term_Call

+ func (_c *MockMessage_Term_Call) Run(run func()) *MockMessage_Term_Call

+ func (_c *MockMessage_Term_Call) RunAndReturn(run func() error) *MockMessage_Term_Call

+ type MockStream struct

+ func NewMockStream(t interface{ ... }) *MockStream

+ func (_m *MockStream) Close() error

+ func (_m *MockStream) EXPECT() *MockStream_Expecter

+ func (_m *MockStream) Open() error

+ func (_m *MockStream) Publish(ctx context.Context, subject string, msg []byte) error

+ func (_m *MockStream) PublishOverwrite(ctx context.Context, subject string, msg []byte) error

+ func (_m *MockStream) PullMsg(ctx context.Context, batch int) ([]Message, error)

+ func (_m *MockStream) Subscribe(ctx context.Context) (MsgCh, error)

+ type MockStream_Close_Call struct

+ func (_c *MockStream_Close_Call) Return(_a0 error) *MockStream_Close_Call

+ func (_c *MockStream_Close_Call) Run(run func()) *MockStream_Close_Call

+ func (_c *MockStream_Close_Call) RunAndReturn(run func() error) *MockStream_Close_Call

+ type MockStream_Expecter struct

+ func (_e *MockStream_Expecter) Close() *MockStream_Close_Call

+ func (_e *MockStream_Expecter) Open() *MockStream_Open_Call

+ func (_e *MockStream_Expecter) Publish(ctx interface{}, subject interface{}, msg interface{}) *MockStream_Publish_Call

+ func (_e *MockStream_Expecter) PublishOverwrite(ctx interface{}, subject interface{}, msg interface{}) *MockStream_PublishOverwrite_Call

+ func (_e *MockStream_Expecter) PullMsg(ctx interface{}, batch interface{}) *MockStream_PullMsg_Call

+ func (_e *MockStream_Expecter) Subscribe(ctx interface{}) *MockStream_Subscribe_Call

+ type MockStream_Open_Call struct

+ func (_c *MockStream_Open_Call) Return(_a0 error) *MockStream_Open_Call

+ func (_c *MockStream_Open_Call) Run(run func()) *MockStream_Open_Call

+ func (_c *MockStream_Open_Call) RunAndReturn(run func() error) *MockStream_Open_Call

+ type MockStream_PublishOverwrite_Call struct

+ func (_c *MockStream_PublishOverwrite_Call) Return(_a0 error) *MockStream_PublishOverwrite_Call

+ func (_c *MockStream_PublishOverwrite_Call) Run(run func(ctx context.Context, subject string, msg []byte)) *MockStream_PublishOverwrite_Call

+ func (_c *MockStream_PublishOverwrite_Call) RunAndReturn(run func(context.Context, string, []byte) error) *MockStream_PublishOverwrite_Call

+ type MockStream_Publish_Call struct

+ func (_c *MockStream_Publish_Call) Return(_a0 error) *MockStream_Publish_Call

+ func (_c *MockStream_Publish_Call) Run(run func(ctx context.Context, subject string, msg []byte)) *MockStream_Publish_Call

+ func (_c *MockStream_Publish_Call) RunAndReturn(run func(context.Context, string, []byte) error) *MockStream_Publish_Call

+ type MockStream_PullMsg_Call struct

+ func (_c *MockStream_PullMsg_Call) Return(_a0 []Message, _a1 error) *MockStream_PullMsg_Call

+ func (_c *MockStream_PullMsg_Call) Run(run func(ctx context.Context, batch int)) *MockStream_PullMsg_Call

+ func (_c *MockStream_PullMsg_Call) RunAndReturn(run func(context.Context, int) ([]Message, error)) *MockStream_PullMsg_Call

+ type MockStream_Subscribe_Call struct

+ func (_c *MockStream_Subscribe_Call) Return(_a0 MsgCh, _a1 error) *MockStream_Subscribe_Call

+ func (_c *MockStream_Subscribe_Call) Run(run func(ctx context.Context)) *MockStream_Subscribe_Call

+ func (_c *MockStream_Subscribe_Call) RunAndReturn(run func(context.Context) (MsgCh, error)) *MockStream_Subscribe_Call

+ type MsgCh chan Message

+ type NatsConsumerOptions struct

+ AckWait time.Duration

+ FilterSubject string

+ MaxAckPending int

+ Name string

+ Pull bool

+ QueueGroup string

+ SubscribeSubjects []string

+ type NatsJetstream struct

+ func NewJetstreamFromConn(c *nats.Conn) *NatsJetstream

+ func NewNatsBroker(params StreamParameters) (*NatsJetstream, error)

+ func (n *NatsJetstream) Close() error

+ func (n *NatsJetstream) Open() error

+ func (n *NatsJetstream) Publish(ctx context.Context, subjectSuffix string, data []byte) error

+ func (n *NatsJetstream) PublishOverwrite(ctx context.Context, subjectSuffix string, data []byte) error

+ func (n *NatsJetstream) PullMsg(_ context.Context, batch int) ([]Message, error)

+ func (n *NatsJetstream) Subscribe(ctx context.Context) (MsgCh, error)

+ type NatsOptions struct

+ AppName string

+ ConnectTimeout time.Duration

+ Consumer *NatsConsumerOptions

+ CredsFile string

+ KVReplicationFactor int

+ PublisherSubjectPrefix string

+ Stream *NatsStreamOptions

+ StreamPass string

+ StreamURNNamespace string

+ StreamUser string

+ SubscribeSubjects []string

+ URL string

+ type NatsStreamOptions struct

+ Acknowledgements bool

+ DuplicateWindow time.Duration

+ Name string

+ Retention string

+ Subjects []string

+ type ResourceType string

+ type Stream interface

+ Close func() error

+ Open func() error

+ Publish func(ctx context.Context, subject string, msg []byte) error

+ PublishOverwrite func(ctx context.Context, subject string, msg []byte) error

+ PullMsg func(ctx context.Context, batch int) ([]Message, error)

+ Subscribe func(ctx context.Context) (MsgCh, error)

+ func NewStream(parameters StreamParameters) (Stream, error)

+ type StreamParameters interface

Other modules containing this package

github.com/metal-toolbox/rivets