repository

Documentation

Overview

Package repository provides interfaces for implementing storage solutions for types

Index

• Variables
• type Codec
• type DB
• type ProtoCodec
  • func (c ProtoCodec[T]) Decode(b []byte) (T, error)
• type Repo
  • func NewBackendRepo[T *backendv1.Backend](db DB) *Repo[*backendv1.Backend]
  • func NewCertificateAuthorityRepo[T *cav1.CertificateAuthority](db DB) *Repo[*cav1.CertificateAuthority]
  • func NewCertificateRepo[T *certv1.Certificate](db DB) *Repo[*certv1.Certificate]
  • func NewCredentialRepo[T *credentialv1.Credential](db DB) *Repo[*credentialv1.Credential]
  • func NewPolicyRepo[T *policyv1.Policy](db DB) *Repo[*policyv1.Policy]
  • func NewRepo[T Resource](db DB, codec Codec[T], prefix, iprefix, idxprefix []byte) *Repo[T]
  • func NewRouteRepo[T *routev1.Route](db DB) *Repo[*routev1.Route]
  • func (r *Repo[T]) Create(ctx context.Context, resource T) (T, error)
  • func (r Repo[T]) Delete(ctx context.Context, id keys.ID) error
  • func (r Repo[T]) Get(ctx context.Context, id keys.ID) (T, error)
  • func (r Repo[T]) List(ctx context.Context, limit int32) ([]T, error)
  • func (r Repo[T]) Update(ctx context.Context, id keys.ID, resource T) (T, error)
• type Resource
• type Txn

Variables

var (
	ErrNotFound  = errors.New("item not found")
	ErrIdxExists = errors.New("index already exists")
)

var BackendCodec = ProtoCodec[*backendv1.Backend]{
	New: func() *backendv1.Backend { return &backendv1.Backend{} },
}

var CertificateAuthorityCodec = ProtoCodec[*cav1.CertificateAuthority]{
	New: func() *cav1.CertificateAuthority { return &cav1.CertificateAuthority{} },
}

var CertificateCodec = ProtoCodec[*certv1.Certificate]{
	New: func() *certv1.Certificate { return &certv1.Certificate{} },
}

var CredentialCodec = ProtoCodec[*credentialv1.Credential]{
	New: func() *credentialv1.Credential { return &credentialv1.Credential{} },
}

var PolicyCodec = ProtoCodec[*policyv1.Policy]{
	New: func() *policyv1.Policy { return &policyv1.Policy{} },
}

var RouteCodec = ProtoCodec[*routev1.Route]{
	New: func() *routev1.Route { return &routev1.Route{} },
}

Types

type Codec

type Codec[T proto.Message] interface {
	Decode([]byte) (T, error)
}

type DB

type DB interface {
	View(ctx context.Context, fn func(txn Txn) error) error
	Update(ctx context.Context, fn func(txn Txn) error) error
}

type ProtoCodec

type ProtoCodec[T proto.Message] struct {
	New func() T
}

func (ProtoCodec[T]) Decode

func (c ProtoCodec[T]) Decode(b []byte) (T, error)

type Repo

type Repo[T Resource] struct {
	Codec Codec[T]
	// contains filtered or unexported fields
}

func NewBackendRepo

func NewBackendRepo[T *backendv1.Backend](db DB) *Repo[*backendv1.Backend]

func NewCertificateAuthorityRepo

func NewCertificateAuthorityRepo[T *cav1.CertificateAuthority](db DB) *Repo[*cav1.CertificateAuthority]

func NewCertificateRepo

func NewCertificateRepo[T *certv1.Certificate](db DB) *Repo[*certv1.Certificate]

func NewCredentialRepo

func NewCredentialRepo[T *credentialv1.Credential](db DB) *Repo[*credentialv1.Credential]

func NewPolicyRepo

func NewPolicyRepo[T *policyv1.Policy](db DB) *Repo[*policyv1.Policy]

func NewRepo

func NewRepo[T Resource](db DB, codec Codec[T], prefix, iprefix, idxprefix []byte) *Repo[T]

func NewRepo[T proto.Message](db *badger.DB, codec Codec[T], prefix, iprefix []byte) *Repo[T] {

func NewRouteRepo

func NewRouteRepo[T *routev1.Route](db DB) *Repo[*routev1.Route]

func (*Repo[T]) Create

func (r *Repo[T]) Create(ctx context.Context, resource T) (T, error)

func (Repo[T]) Delete

func (r Repo[T]) Delete(ctx context.Context, id keys.ID) error

func (Repo[T]) Get

func (r Repo[T]) Get(ctx context.Context, id keys.ID) (T, error)

func (Repo[T]) List

func (r Repo[T]) List(ctx context.Context, limit int32) ([]T, error)

func (Repo[T]) Update

func (r Repo[T]) Update(ctx context.Context, id keys.ID, resource T) (T, error)

type Resource

type Resource interface {
	proto.Message
	GetMeta() *metav1.Meta
}

type Txn

type Txn interface {
	Get(key []byte) ([]byte, error)       // returns a COPY of value
	List([]byte, int32) ([][]byte, error) // returns a COPY of value
	Set(key, val []byte) error
	Delete(key []byte) error
	Keys([]byte) ([][]byte, error)
}