store

Documentation

Overview

The store pkg is responsible for coordinating bucket transfer between the receivers (front-end) and readers & outlets (back-end).

Index

• type MemStore
  • func NewMemStore() *MemStore
  • func (m *MemStore) Get(b *bucket.Bucket) error
  • func (s *MemStore) Health() bool
  • func (m *MemStore) MaxPartitions() uint64
  • func (m *MemStore) Put(b *bucket.Bucket) error
  • func (m *MemStore) Scan(schedule time.Time) (<-chan *bucket.Bucket, error)
• type RedisStore
  • func NewRedisStore(server, pass string, maxPartitions uint64) *RedisStore
  • func (s *RedisStore) Get(b *bucket.Bucket) error
  • func (s *RedisStore) Health() bool
  • func (s *RedisStore) MaxPartitions() uint64
  • func (s *RedisStore) Put(b *bucket.Bucket) error
  • func (s *RedisStore) Scan(schedule time.Time) (<-chan *bucket.Bucket, error)
• type Store

Types

type MemStore

type MemStore struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewMemStore

func NewMemStore() *MemStore

func (*MemStore) Get

func (m *MemStore) Get(b *bucket.Bucket) error

func (*MemStore) Health

func (s *MemStore) Health() bool

func (*MemStore) MaxPartitions

func (m *MemStore) MaxPartitions() uint64

func (*MemStore) Put

func (m *MemStore) Put(b *bucket.Bucket) error

func (*MemStore) Scan

func (m *MemStore) Scan(schedule time.Time) (<-chan *bucket.Bucket, error)

type RedisStore

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

func NewRedisStore

func NewRedisStore(server, pass string, maxPartitions uint64) *RedisStore

func (*RedisStore) Get

func (s *RedisStore) Get(b *bucket.Bucket) error

func (*RedisStore) Health

func (s *RedisStore) Health() bool

func (*RedisStore) MaxPartitions

func (s *RedisStore) MaxPartitions() uint64

func (*RedisStore) Put

func (s *RedisStore) Put(b *bucket.Bucket) error

func (*RedisStore) Scan

func (s *RedisStore) Scan(schedule time.Time) (<-chan *bucket.Bucket, error)

type Store

type Store interface {
	MaxPartitions() uint64
	Put(*bucket.Bucket) error
	Get(*bucket.Bucket) error
	Scan(time.Time) (<-chan *bucket.Bucket, error)
	Health() bool
}