rediscluster

Documentation

Index

• type Snapshot
  • func New(cli *redis.ClusterClient, codec es.SnapshotCoder, serviceName string, ...) *Snapshot
  • func (c *Snapshot) Load(ctx context.Context, streamID uuid.UUID, streamType string) (es.Stream, error)
  • func (c *Snapshot) Remove(ctx context.Context, streamType string, streamID uuid.UUID) error
  • func (c *Snapshot) Reset(ctx context.Context, streamType string) error
  • func (c *Snapshot) Should(_ context.Context, es es.Stream) bool
  • func (c *Snapshot) Take(ctx context.Context, es es.Stream) error

Types

type Snapshot

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

func New

func New(cli *redis.ClusterClient, codec es.SnapshotCoder, serviceName string, threshold int) *Snapshot

func (*Snapshot) Load

func (c *Snapshot) Load(ctx context.Context, streamID uuid.UUID, streamType string) (es.Stream, error)

func (*Snapshot) Remove

func (c *Snapshot) Remove(ctx context.Context, streamType string, streamID uuid.UUID) error

func (*Snapshot) Reset

func (c *Snapshot) Reset(ctx context.Context, streamType string) error

func (*Snapshot) Should

func (c *Snapshot) Should(_ context.Context, es es.Stream) bool

func (*Snapshot) Take

func (c *Snapshot) Take(ctx context.Context, es es.Stream) error