redis

Documentation

Index

• type Storage
  • func NewStorage(ctx context.Context, connectUrl string, options ...storage.Option) (*Storage, error)
  • func (st *Storage) Close() error
  • func (st *Storage) Stream(options ...any) (eventstream.Streamer, error)
• type Stream
  • func (s *Stream) Check(ctx context.Context, msg message.Message) bool
  • func (s *Stream) Close() error
  • func (s *Stream) ID() string
  • func (s *Stream) Put(ctx context.Context, msg message.Message) error
  • func (s *Stream) Run(ctx context.Context) error

Types

type Storage

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

Storage for the redis

func NewStorage

func NewStorage(ctx context.Context, connectUrl string, options ...storage.Option) (*Storage, error)

NewStorage from connection URL

func (*Storage) Close

func (st *Storage) Close() error

Close vertica connection

func (*Storage) Stream

func (st *Storage) Stream(options ...any) (eventstream.Streamer, error)

Stream vertica processor

type Stream

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

Stream for the redis key value

func (*Stream) Check

func (s *Stream) Check(ctx context.Context, msg message.Message) bool

Check if message suits for the stream

func (*Stream) Close

func (s *Stream) Close() error

Close stream

func (*Stream) ID

func (s *Stream) ID() string

ID returns unical stream identificator

func (*Stream) Put

func (s *Stream) Put(ctx context.Context, msg message.Message) error

Put message to the stream to process information

func (*Stream) Run

func (s *Stream) Run(ctx context.Context) error

Run processing loop