branches

Documentation

Index

• Variables
• type Config
  • func NewConfig(name string, commit ksuid.KSUID) *Config
  • func (c *Config) Key() string
• type Store
  • func CreateStore(ctx context.Context, engine storage.Engine, logger *zap.Logger, ...) (*Store, error)
  • func OpenStore(ctx context.Context, engine storage.Engine, logger *zap.Logger, ...) (*Store, error)
  • func (s *Store) Add(ctx context.Context, config *Config) error
  • func (s *Store) All(ctx context.Context) ([]Config, error)
  • func (s *Store) LookupByName(ctx context.Context, name string) (*Config, error)
  • func (s *Store) Remove(ctx context.Context, config Config) error
  • func (s *Store) Update(ctx context.Context, config *Config, c journal.Constraint) error

Variables

var (
	ErrExists   = errors.New("branch already exists")
	ErrNotFound = errors.New("branch not found")
)

Types

type Config

type Config struct {
	Ts     nano.Ts     `zed:"ts"`
	Name   string      `zed:"name"`
	Commit ksuid.KSUID `zed:"commit"`
}

func NewConfig

func NewConfig(name string, commit ksuid.KSUID) *Config

func (*Config) Key

func (c *Config) Key() string

type Store

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

func CreateStore

func CreateStore(ctx context.Context, engine storage.Engine, logger *zap.Logger, path *storage.URI) (*Store, error)

func OpenStore

func OpenStore(ctx context.Context, engine storage.Engine, logger *zap.Logger, path *storage.URI) (*Store, error)

func (*Store) Add

func (s *Store) Add(ctx context.Context, config *Config) error

func (*Store) All

func (s *Store) All(ctx context.Context) ([]Config, error)

func (*Store) LookupByName

func (s *Store) LookupByName(ctx context.Context, name string) (*Config, error)

func (*Store) Remove

func (s *Store) Remove(ctx context.Context, config Config) error

Remove deletes a branch from the configuration journal. We make sure the last commit is the same as the reference config; otherwise, there was a race and someone did something with this branch in the meantime so we abort.

func (*Store) Update

func (s *Store) Update(ctx context.Context, config *Config, c journal.Constraint) error