namespace

Documentation

Index

• Variables
• type ConfigSyncer
• type EncryptedNamespace
• type Encryptor
• type Namespace
• type NotFoundError
  • func (err NotFoundError) Error() string
• type ProviderService
• type Repository
• type Service
  • func NewService(cryptoClient Encryptor, repository Repository, providerService ProviderService, ...) *Service
  • func (s *Service) Create(ctx context.Context, ns *Namespace) error
  • func (s *Service) Delete(ctx context.Context, id uint64) error
  • func (s *Service) Get(ctx context.Context, id uint64) (*Namespace, error)
  • func (s *Service) List(ctx context.Context) ([]Namespace, error)
  • func (s *Service) Update(ctx context.Context, ns *Namespace) error
• type Transactor

Variables

var (
	ErrDuplicate = errors.New("urn and provider pair already exist")
	ErrRelation  = errors.New("provider id does not exist")
)

Types

type ConfigSyncer

type ConfigSyncer interface {
	SyncRuntimeConfig(ctx context.Context, namespaceID uint64, namespaceURN string, prov provider.Provider) error
}

type EncryptedNamespace

type EncryptedNamespace struct {
	*Namespace
	CredentialString string
}

type Encryptor

type Encryptor interface {
	Encrypt(str secret.MaskableString) (secret.MaskableString, error)
	Decrypt(str secret.MaskableString) (secret.MaskableString, error)
}

type Namespace

type Namespace struct {
	ID          uint64                 `json:"id"`
	URN         string                 `json:"urn"`
	Name        string                 `json:"name"`
	Provider    provider.Provider      `json:"provider"`
	Credentials map[string]interface{} `json:"credentials"`
	Labels      map[string]string      `json:"labels"`
	CreatedAt   time.Time              `json:"created_at"`
	UpdatedAt   time.Time              `json:"updated_at"`
}

type NotFoundError

type NotFoundError struct {
	ID uint64
}

func (NotFoundError) Error

func (err NotFoundError) Error() string

type ProviderService

type ProviderService interface {
	Get(ctx context.Context, id uint64) (*provider.Provider, error)
}

type Repository

type Repository interface {
	Transactor
	List(context.Context) ([]EncryptedNamespace, error)
	Create(context.Context, *EncryptedNamespace) error
	Get(context.Context, uint64) (*EncryptedNamespace, error)
	Update(context.Context, *EncryptedNamespace) error
	Delete(context.Context, uint64) error
}

type Service

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

Service handles business logic

func NewService

func NewService(cryptoClient Encryptor, repository Repository, providerService ProviderService, registry map[string]ConfigSyncer) *Service

NewService returns secure service struct

func (*Service) Create

func (s *Service) Create(ctx context.Context, ns *Namespace) error

func (*Service) Delete

func (s *Service) Delete(ctx context.Context, id uint64) error

func (*Service) Get

func (s *Service) Get(ctx context.Context, id uint64) (*Namespace, error)

func (*Service) List

func (s *Service) List(ctx context.Context) ([]Namespace, error)

func (*Service) Update

func (s *Service) Update(ctx context.Context, ns *Namespace) error

type Transactor

type Transactor interface {
	WithTransaction(ctx context.Context) context.Context
	Rollback(ctx context.Context, err error) error
	Commit(ctx context.Context) error
}