backend

Documentation

Index

• type Backend
• type RedisBackend
  • func (b *RedisBackend) AddPartition(contextId uuid.UUID, configuration string) (model.Partition, error)
  • func (b *RedisBackend) CreateContext(name string, livenessIntervalSeconds, maxPartitionsPerWorker int) (model.Context, error)
  • func (b *RedisBackend) DeleteContext(id uuid.UUID) error
  • func (b *RedisBackend) DeletePartition(contextId, partitionId uuid.UUID) error
  • func (b *RedisBackend) DeleteWorker(contextId, workerId uuid.UUID) error
  • func (b *RedisBackend) GetContext(id uuid.UUID) (model.Context, bool, error)
  • func (b *RedisBackend) GetContexts() ([]model.Context, error)
  • func (b *RedisBackend) GetPartition(contextId, partitionId uuid.UUID) (model.Partition, bool, error)
  • func (b *RedisBackend) GetPartitions(contextId uuid.UUID) ([]model.Partition, error)
  • func (b *RedisBackend) GetWorker(contextId, workerId uuid.UUID) (model.Worker, bool, error)
  • func (b *RedisBackend) GetWorkers(contextId uuid.UUID) ([]model.Worker, error)
  • func (b *RedisBackend) Initialize(address, password string, db int)
  • func (b *RedisBackend) RefreshWorker(contextId, workerId uuid.UUID) (model.Worker, bool, error)
  • func (b *RedisBackend) RegisterWorker(contextId uuid.UUID) (model.Worker, error)

Types

type Backend

type Backend interface {
	GetContexts() ([]model.Context, error)
	GetContext(id uuid.UUID) (model.Context, bool, error)
	CreateContext(name string, livenessIntervalSeconds, maxPartitionsPerWorker int) (model.Context, error)
	DeleteContext(id uuid.UUID) error

	GetPartitions(contextId uuid.UUID) ([]model.Partition, error)
	AddPartition(contextId uuid.UUID, configuration string) (model.Partition, error)
	DeletePartition(contextId, partitionId uuid.UUID) error

	RegisterWorker(contextId uuid.UUID) (model.Worker, error)
	GetWorkers(contextId uuid.UUID) ([]model.Worker, error)
	GetWorker(contextId, workerId uuid.UUID) (model.Worker, bool, error)
	RefreshWorker(contextId, workerId uuid.UUID) (model.Worker, bool, error)
	DeleteWorker(contextId, workerId uuid.UUID) error
}

type RedisBackend

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

func (*RedisBackend) AddPartition

func (b *RedisBackend) AddPartition(contextId uuid.UUID, configuration string) (model.Partition, error)

func (*RedisBackend) CreateContext

func (b *RedisBackend) CreateContext(name string, livenessIntervalSeconds, maxPartitionsPerWorker int) (model.Context, error)

func (*RedisBackend) DeleteContext

func (b *RedisBackend) DeleteContext(id uuid.UUID) error

func (*RedisBackend) DeletePartition

func (b *RedisBackend) DeletePartition(contextId, partitionId uuid.UUID) error

func (*RedisBackend) DeleteWorker

func (b *RedisBackend) DeleteWorker(contextId, workerId uuid.UUID) error

func (*RedisBackend) GetContext

func (b *RedisBackend) GetContext(id uuid.UUID) (model.Context, bool, error)

func (*RedisBackend) GetContexts

func (b *RedisBackend) GetContexts() ([]model.Context, error)

func (*RedisBackend) GetPartition

func (b *RedisBackend) GetPartition(contextId, partitionId uuid.UUID) (model.Partition, bool, error)

func (*RedisBackend) GetPartitions

func (b *RedisBackend) GetPartitions(contextId uuid.UUID) ([]model.Partition, error)

func (*RedisBackend) GetWorker

func (b *RedisBackend) GetWorker(contextId, workerId uuid.UUID) (model.Worker, bool, error)

func (*RedisBackend) GetWorkers

func (b *RedisBackend) GetWorkers(contextId uuid.UUID) ([]model.Worker, error)

func (*RedisBackend) Initialize

func (b *RedisBackend) Initialize(address, password string, db int)

func (*RedisBackend) RefreshWorker

func (b *RedisBackend) RefreshWorker(contextId, workerId uuid.UUID) (model.Worker, bool, error)

func (*RedisBackend) RegisterWorker

func (b *RedisBackend) RegisterWorker(contextId uuid.UUID) (model.Worker, error)