shards

Documentation

Index

• type MockRepository
  • func NewMockRepository() *MockRepository
  • func (r *MockRepository) Add(create service.ShardMapping, run database.RunInTx) error
  • func (r *MockRepository) List() ([]service.ShardMapping, error)
  • func (r *MockRepository) Lookup(shardKey string) (string, error)
• type Repository
  • func NewRepository(db *sql.DB, static map[string]service.ShardMapping) Repository
• type ShardMappingController
  • func NewShardMappingController(logger log.Logger, service ShardMappingService) *ShardMappingController
  • func (c *ShardMappingController) AppendRoutes(router *mux.Router) *mux.Router
  • func (c *ShardMappingController) Create(w http.ResponseWriter, r *http.Request)
  • func (c *ShardMappingController) Get(w http.ResponseWriter, r *http.Request)
  • func (c *ShardMappingController) List(w http.ResponseWriter, r *http.Request)
• type ShardMappingService
  • func NewShardMappingService(time stime.TimeService, logger log.Logger, repository Repository) (ShardMappingService, error)

Types

type MockRepository

type MockRepository struct {
	Shards map[string]service.ShardMapping
}

func NewMockRepository

func NewMockRepository() *MockRepository

func (*MockRepository) Add

func (r *MockRepository) Add(create service.ShardMapping, run database.RunInTx) error

func (*MockRepository) List

func (r *MockRepository) List() ([]service.ShardMapping, error)

func (*MockRepository) Lookup

func (r *MockRepository) Lookup(shardKey string) (string, error)

type Repository

type Repository interface {
	Lookup(shardKey string) (string, error)
	List() ([]service.ShardMapping, error)
	Add(create service.ShardMapping, run database.RunInTx) error
}

func NewRepository

func NewRepository(db *sql.DB, static map[string]service.ShardMapping) Repository

type ShardMappingController

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

func NewShardMappingController

func NewShardMappingController(logger log.Logger, service ShardMappingService) *ShardMappingController

func (*ShardMappingController) AppendRoutes

func (c *ShardMappingController) AppendRoutes(router *mux.Router) *mux.Router

func (*ShardMappingController) Create

func (c *ShardMappingController) Create(w http.ResponseWriter, r *http.Request)

func (*ShardMappingController) Get

func (c *ShardMappingController) Get(w http.ResponseWriter, r *http.Request)

func (*ShardMappingController) List

func (c *ShardMappingController) List(w http.ResponseWriter, r *http.Request)

type ShardMappingService

type ShardMappingService interface {
	Create(create *service.ShardMapping) (*service.ShardMapping, error)
	List() ([]service.ShardMapping, error)
	Lookup(shardKey string) (string, error)
}

func NewShardMappingService

func NewShardMappingService(time stime.TimeService, logger log.Logger, repository Repository) (ShardMappingService, error)