natsjetstream

package

v1.0.1 Latest Latest Go to latest Published: Jul 6, 2026 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewJetStream(nc *nats.Conn) *JetStream

func (this_ *JetStream) AddStream(name string, desc string, maxBytes int64) *berror.ErrMsg

func (this_ *JetStream) AddStreamIfNoExist(name string, desc string, maxBytes int64) *berror.ErrMsg

func (this_ *JetStream) Close()

func (this_ *JetStream) ConsumerInfo(stream string, name string) (*nats.ConsumerInfo, *berror.ErrMsg)

func (this_ *JetStream) DeleteConsumer(stream string, name string) *berror.ErrMsg

func (this_ *JetStream) DeleteStreamIfExist(name string) *berror.ErrMsg

func (this_ *JetStream) JetStream() nats.JetStream

func (this_ *JetStream) Publish(subj string, data []byte) *berror.ErrMsg

func (this_ *JetStream) PullWithAll(stream string, name string) (*Puller, *berror.ErrMsg)

PullWithAll Pull all data

func (this_ *JetStream) PullWithNewest(stream string, name string) (*Puller, *berror.ErrMsg)

PullWithNewest Pull the latest data

func (this_ *JetStream) PullWithSeq(stream string, name string, seq uint64) (*Puller, *berror.ErrMsg)

PullWithSeq Start pulling data from the specified Sequence

func (this_ *JetStream) PullWithTime(stream string, name string, time time.Time) (*Puller, *berror.ErrMsg)

PullWithTime Start pulling data from the specified time

func (this_ *JetStream) UpdateConsumer(stream string, name string, seq uint64) *berror.ErrMsg

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

func (this_ *Puller) Close()

func (this_ *Puller) Fetch(max int, maxWait time.Duration) ([]*nats.Msg, *berror.ErrMsg)