repo

Documentation

Index

• func Replay(events []ddd.Event) ddd.Aggregate
• type Agent
• type Created
  • func (e Created) EventType() string
• type DefaultAgent
  • func (a DefaultAgent) CheckIndex(name, endpoint, token string) bool
  • func (a DefaultAgent) GetChart(name, version, endpoint, token string) ([]byte, error)
  • func (a DefaultAgent) GetChartFromOCIV2(name, version, endpoint, username, password string) ([]byte, error)
• type Destroyed
  • func (e Destroyed) EventType() string
• type ReadRepository
  • func NewReadRepository(s storage.Storage) *ReadRepository
  • func (rr *ReadRepository) All() ([]*Repo, error)
  • func (rr *ReadRepository) Load(uuid string) (*Repo, error)
• type Repo
  • func Create(uuid, name, endpoint, token, username, password string, t Type, helmOCI bool, ...) (*Repo, error)
  • func (r *Repo) Destroy(timestamp int64) error
  • func (r *Repo) Destroyed() bool
  • func (r *Repo) Endpoint() string
  • func (r *Repo) Events() []ddd.Event
  • func (r *Repo) HelmOCI() bool
  • func (r *Repo) Name() string
  • func (r *Repo) Password() string
  • func (r *Repo) Token() string
  • func (r *Repo) Type() Type
  • func (r *Repo) UUID() string
  • func (r *Repo) Update(name, endpoint, token, username, password string, t Type, helmOCI bool, ...) error
  • func (r *Repo) Username() string
  • func (r *Repo) Version() int
• type Service
  • func NewService(a auth.Agent, g git.Agent, r Agent, s storage.Storage) *Service
  • func (s Service) All(ctx context.Context, req *pb.ReadRepos) (*pb.ReposRead, error)
  • func (s Service) Create(ctx context.Context, cmd *pb.CreateRepo) (*pb.RepoCreated, error)
  • func (s Service) Destroy(ctx context.Context, cmd *pb.DestroyRepo) (*pb.RepoDestroyed, error)
  • func (s Service) File(ctx context.Context, req *pb.ReadFile) (*pb.FileRead, error)
  • func (s Service) Read(ctx context.Context, req *pb.ReadRepo) (*pb.RepoRead, error)
  • func (s Service) Ready() error
  • func (s Service) Update(ctx context.Context, cmd *pb.UpdateRepo) (*pb.RepoUpdated, error)
• type Type
• type Updated
  • func (e Updated) EventType() string

Functions

func Replay

func Replay(events []ddd.Event) ddd.Aggregate

Replay recreates the repo from a series of events

Types

type Agent

type Agent interface {
	CheckIndex(name, endpoint, token string) bool
	GetChart(name, version, endpoint, token string) ([]byte, error)
	GetChartFromOCIV2(name, version, endpoint, username, password string) ([]byte, error)
}

Agent is the interface we use to talk to helm packages

type Created

type Created struct {
	Timestamp int64
	UUID      string
	Name      string
	Endpoint  string
	Token     string
	Username  string
	Password  string
	Type      Type
	HelmOCI   bool
}

Created is the event for when a new repo is created

func (Created) EventType

func (e Created) EventType() string

EventType marks this as an event

type DefaultAgent

type DefaultAgent struct{}

DefaultAgent is the default implementation of the Agent interface

func (DefaultAgent) CheckIndex

func (a DefaultAgent) CheckIndex(name, endpoint, token string) bool

CheckIndex checks the index.yaml file at the repo's endpoint

func (DefaultAgent) GetChart

func (a DefaultAgent) GetChart(name, version, endpoint, token string) ([]byte, error)

GetChart downloads a single chart from a particular chart repo

func (DefaultAgent) GetChartFromOCIV2

func (a DefaultAgent) GetChartFromOCIV2(name, version, endpoint, username, password string) ([]byte, error)

GetChartFromOCIV2 gets a chart from a V2 compliant OCI registry

type Destroyed

type Destroyed struct {
	Timestamp int64
}

Destroyed is the event for when a repo is destroyed

func (Destroyed) EventType

func (e Destroyed) EventType() string

EventType marks this as an event

type ReadRepository

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

ReadRepository is the repository for dealing with repo reads

func NewReadRepository

func NewReadRepository(s storage.Storage) *ReadRepository

NewReadRepository creates a repository with the given storage

func (*ReadRepository) All

func (rr *ReadRepository) All() ([]*Repo, error)

All gets all repos

func (*ReadRepository) Load

func (rr *ReadRepository) Load(uuid string) (*Repo, error)

Load gets one repo

type Repo

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

Repo represents a repository, for now helm only

func Create

func Create(uuid, name, endpoint, token, username, password string, t Type, helmOCI bool, timestamp int64) (*Repo, error)

Create handles create commands

func (*Repo) Destroy

func (r *Repo) Destroy(timestamp int64) error

Destroy handles destroy commands

func (*Repo) Destroyed

func (r *Repo) Destroyed() bool

Destroyed determines if this repo has been destroyed

func (*Repo) Endpoint

func (r *Repo) Endpoint() string

Endpoint gets the repo's endpoint

func (*Repo) Events

func (r *Repo) Events() []ddd.Event

Events gets all events from this repo

func (*Repo) HelmOCI

func (r *Repo) HelmOCI() bool

HelmOCI returns whether this is an OCI repo

func (*Repo) Name

func (r *Repo) Name() string

Name gets the repo's name

func (*Repo) Password

func (r *Repo) Password() string

Password gets the repo's password

func (*Repo) Token

func (r *Repo) Token() string

Token gets the repo's access token

func (*Repo) Type

func (r *Repo) Type() Type

Type gets the repo type (helm, git, etc.)

func (*Repo) UUID

func (r *Repo) UUID() string

UUID gets the repo's unique id

func (*Repo) Update

func (r *Repo) Update(name, endpoint, token, username, password string, t Type, helmOCI bool, timestamp int64) error

Update handles update commands

func (*Repo) Username

func (r *Repo) Username() string

Username gets the repo's username

func (*Repo) Version

func (r *Repo) Version() int

Version gets all the

type Service

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

Service is the implementation for twirp to use

func NewService

func NewService(a auth.Agent, g git.Agent, r Agent, s storage.Storage) *Service

NewService creates the service

func (Service) All

func (s Service) All(ctx context.Context, req *pb.ReadRepos) (*pb.ReposRead, error)

All gets all repos currently configured and their status

func (Service) Create

func (s Service) Create(ctx context.Context, cmd *pb.CreateRepo) (*pb.RepoCreated, error)

Create adds a repo to the list of configurations

func (Service) Destroy

func (s Service) Destroy(ctx context.Context, cmd *pb.DestroyRepo) (*pb.RepoDestroyed, error)

Destroy removes a repo from the list of configurations

func (Service) File

func (s Service) File(ctx context.Context, req *pb.ReadFile) (*pb.FileRead, error)

File gets the contents of a file from the git repo

func (Service) Read

func (s Service) Read(ctx context.Context, req *pb.ReadRepo) (*pb.RepoRead, error)

Read reads out a repo

func (Service) Ready

func (s Service) Ready() error

Ready implements the ReadyService method so this service can be part of a health check routine

func (Service) Update

func (s Service) Update(ctx context.Context, cmd *pb.UpdateRepo) (*pb.RepoUpdated, error)

Update edits an already existing repo

type Type

type Type int64

Type represents the kind of repo

const (
	// HELM repo
	HELM Type = 0

	// GIT repo
	GIT Type = 1
)

type Updated

type Updated struct {
	Timestamp int64
	Name      string
	Endpoint  string
	Token     string
	Username  string
	Password  string
	Type      Type
	HelmOCI   bool
}

Updated is the event for when a repo is updated

func (Updated) EventType

func (e Updated) EventType() string

EventType marks this as an event