shards

Documentation

Index

• type InMemoryRepository
  • func NewInMemoryRepository(shards ...service.ShardMapping) *InMemoryRepository
  • func (r *InMemoryRepository) Add(create service.ShardMapping, _ database.RunInTx) error
  • func (r *InMemoryRepository) List() ([]service.ShardMapping, error)
  • func (r *InMemoryRepository) Lookup(shardKey string) (string, error)
• type Repository
  • func NewRepository(db *sql.DB, static []service.ShardMapping) Repository
  • func NewSpannerRepository(client *spanner.Client, static []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 InMemoryRepository

type InMemoryRepository struct {
	Shards []service.ShardMapping
}

func NewInMemoryRepository

func NewInMemoryRepository(shards ...service.ShardMapping) *InMemoryRepository

func (*InMemoryRepository) Add

func (r *InMemoryRepository) Add(create service.ShardMapping, _ database.RunInTx) error

func (*InMemoryRepository) List

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

func (*InMemoryRepository) Lookup

func (r *InMemoryRepository) 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 []service.ShardMapping) Repository

func NewSpannerRepository

func NewSpannerRepository(client *spanner.Client, static []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)