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) Now() time.Time
  • func (m *MemStore) Put(b *bucket.Bucket) error
  • func (m *MemStore) Scan(schedule time.Time) (<-chan *bucket.Bucket, error)
  • func (m *MemStore) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type RedisStore
  • func NewRedisStore(cfg *conf.D) *RedisStore
  • func (s *RedisStore) Flush()
  • func (s *RedisStore) Get(b *bucket.Bucket) error
  • func (s *RedisStore) Health() bool
  • func (s *RedisStore) MaxPartitions() uint64
  • func (s *RedisStore) Now() time.Time
  • func (s *RedisStore) Put(b *bucket.Bucket) error
  • func (s *RedisStore) Scan(schedule time.Time) (<-chan *bucket.Bucket, error)
  • func (s *RedisStore) ServeHTTP(w http.ResponseWriter, r *http.Request)
• 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) Now

func (m *MemStore) Now() time.Time

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)

func (*MemStore) ServeHTTP

func (m *MemStore) ServeHTTP(w http.ResponseWriter, r *http.Request)

type RedisStore

type RedisStore struct {
	Mchan *metchan.Channel
	// contains filtered or unexported fields
}

func NewRedisStore

func NewRedisStore(cfg *conf.D) *RedisStore

func (*RedisStore) Flush

func (s *RedisStore) Flush()

func (*RedisStore) Get

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

func (*RedisStore) Health

func (s *RedisStore) Health() bool

Sends a PING request to Redis.

func (*RedisStore) MaxPartitions

func (s *RedisStore) MaxPartitions() uint64

func (*RedisStore) Now

func (s *RedisStore) Now() time.Time

Reads the TIME from Redis.

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)

func (*RedisStore) ServeHTTP

func (s *RedisStore) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Store

type Store interface {
	MaxPartitions() uint64
	Put(*bucket.Bucket) error
	Get(*bucket.Bucket) error
	Scan(time.Time) (<-chan *bucket.Bucket, error)
	Now() time.Time
	ServeHTTP(w http.ResponseWriter, r *http.Request)
}