nsclient

Documentation

Index

• type NatsStreamClient
  • func NatsStreamClientFactory(natsUri string, streamName string) (NatsStreamClient, error)
  • func NewNatsStreamClient(conn *nats.Conn, js jetstream.JetStream, streamName string) (NatsStreamClient, error)
  • func (n *NatsStreamClient) Get(ctx context.Context, subject string, numberOfMessages int, consumerName string) ([][]byte, error)
  • func (n *NatsStreamClient) Publish(ctx context.Context, subject string, payload []byte) error
• type NatsStreamClientInterface

Types

type NatsStreamClient

type NatsStreamClient struct {
	NatsUri    string
	Connection *nats.Conn
	JS         jetstream.JetStream
	// contains filtered or unexported fields
}

func NatsStreamClientFactory

func NatsStreamClientFactory(natsUri string, streamName string) (NatsStreamClient, error)

Create a NatStreamClient without access to the connection or jetstream

func NewNatsStreamClient

func NewNatsStreamClient(conn *nats.Conn, js jetstream.JetStream, streamName string) (NatsStreamClient, error)

func (*NatsStreamClient) Get

func (n *NatsStreamClient) Get(ctx context.Context, subject string, numberOfMessages int, consumerName string) ([][]byte, error)

func (*NatsStreamClient) Publish

func (n *NatsStreamClient) Publish(ctx context.Context, subject string, payload []byte) error

type NatsStreamClientInterface

type NatsStreamClientInterface interface {
	// streamExists(ctx context.Context, js jetstream.JetStream, streamName string) bool
	// appendSubjectToStream(ctx context.Context, js jetstream.JetStream, streamName string, subject string) error
	// subjectExists(config jetstream.StreamConfig, subject string) bool
	// convertSubjectsToUnique(subjects []string)
	// createStream(ctx context.Context, subjects []string)
	Publish(ctx context.Context, subject string, payload []byte) error
	Get(ctx context.Context, subject string, numberOfMessages int, consumerName string) ([][]byte, error)
}