Versions in this module Expand all Collapse all v1 v1.2.0 Jul 21, 2023 Changes in this version + type Config struct + Addr string + Password string + Timeout time.Duration + type IClient interface + Get func(ctx context.Context, name string) (data string, pos int64, err error) + Put func(ctx context.Context, name, data string) (pos int64, err error) + Reset func(ctx context.Context, name string) error + SetMaxQueue func(ctx context.Context, name string, max int) error + SetSyncTime func(ctx context.Context, name string, duration time.Duration) error + Status func(ctx context.Context, name string) (*Status, error) + View func(ctx context.Context, name string, pos int64) (string, error) + func NewClient(config *Config) IClient + type IHandler interface + GetClient func() (IClient, error) + Handle func(ctx context.Context, data string, pos int64) error + OnBefore func(ctx context.Context) error + OnFailed func(ctx context.Context, data string, err error) + QueueName func() string + type Status struct + GetLap int64 + GetPos int64 + MaxQueue int64 + Name string + PutLap int64 + PutPos int64 + Unread int64 + func (s Status) String() string
Go to main page