redis

Documentation

Index

• type Projection
  • func New(client *redis.Client, serviceName string) (*Projection, error)
  • func (c *Projection) IsEventProcessed(ctx context.Context, e es.Event) bool
  • func (c *Projection) Process(ctx context.Context, e es.Event) error

Types

type Projection

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

func New

func New(client *redis.Client, serviceName string) (*Projection, error)

func (*Projection) IsEventProcessed

func (c *Projection) IsEventProcessed(ctx context.Context, e es.Event) bool

func (*Projection) Process

func (c *Projection) Process(ctx context.Context, e es.Event) error