cache

Documentation

Index

• type Cache
  • func NewInMemoryCache() Cache
  • func NewPersistedCache(ctx context.Context, ip, port string) (Cache, error)
• type InMemoryCache
  • func (c *InMemoryCache) HasBeenProcessed(ctx context.Context, k, v string) (bool, error)
• type PersistedCache
  • func (c *PersistedCache) HasBeenProcessed(ctx context.Context, k, v string) (bool, error)

Types

type Cache

type Cache interface {
	HasBeenProcessed(ctx context.Context, k, v string) (bool, error)
}

func NewInMemoryCache

func NewInMemoryCache() Cache

func NewPersistedCache

func NewPersistedCache(ctx context.Context, ip, port string) (Cache, error)

type InMemoryCache

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

func (*InMemoryCache) HasBeenProcessed

func (c *InMemoryCache) HasBeenProcessed(ctx context.Context, k, v string) (bool, error)

type PersistedCache

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

func (*PersistedCache) HasBeenProcessed

func (c *PersistedCache) HasBeenProcessed(ctx context.Context, k, v string) (bool, error)