Retracted: Withdrawn; the module proxy serves these against commits that no longer exist here.
Documentation
¶
Index ¶
- type NatsJetStreamSource
- func (s *NatsJetStreamSource) Ack(ctx context.Context, msg hermod.Message) error
- func (s *NatsJetStreamSource) Close() error
- func (s *NatsJetStreamSource) Ping(ctx context.Context) error
- func (s *NatsJetStreamSource) Read(ctx context.Context) (hermod.Message, error)
- func (s *NatsJetStreamSource) Sample(ctx context.Context, table string) (hermod.Message, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NatsJetStreamSource ¶
type NatsJetStreamSource struct {
// contains filtered or unexported fields
}
func NewNatsJetStreamSource ¶
func NewNatsJetStreamSource(url, subject, queue, durable, username, password, token string) (*NatsJetStreamSource, error)
func (*NatsJetStreamSource) Close ¶
func (s *NatsJetStreamSource) Close() error
Source Files
Click to show internal directories.
Click to hide internal directories.