Retracted: Withdrawn; the module proxy serves these against commits that no longer exist here.
Documentation
¶
Index ¶
- type RedisSource
- func (s *RedisSource) Ack(ctx context.Context, msg hermod.Message) error
- func (s *RedisSource) Close() error
- func (s *RedisSource) IsReady(ctx context.Context) error
- func (s *RedisSource) Ping(ctx context.Context) error
- func (s *RedisSource) Read(ctx context.Context) (hermod.Message, error)
- func (s *RedisSource) 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 RedisSource ¶
type RedisSource struct {
// contains filtered or unexported fields
}
RedisSource implements the hermod.Source interface for Redis Streams.
func NewRedisSource ¶
func NewRedisSource(addr string, password string, stream string, group string) *RedisSource
func (*RedisSource) Close ¶
func (s *RedisSource) Close() error
Source Files
Click to show internal directories.
Click to hide internal directories.