blob

Documentation

Index

• type Bucket
  • func NewStore(ctx context.Context, storagePath, storageSecret string) (Bucket, error)
• type Resource
• type ResourceBackend
• type ResourceBackends
• type ResourceType
• type Resources
• type ResourcesRepository
  • func NewResourcesRepository(logger log.Logger, b Bucket) *ResourcesRepository
  • func (repo *ResourcesRepository) Close() error
  • func (repo *ResourcesRepository) GetAll(ctx context.Context) ([]resource.YAML, error)
  • func (repo *ResourcesRepository) GetRelationsForNamespace(ctx context.Context, namespaceID string) (map[string]bool, error)
  • func (repo *ResourcesRepository) InitCache(ctx context.Context, refreshDelay time.Duration) error
• type SchemaRepository
  • func NewSchemaConfigRepository(b Bucket) *SchemaRepository
  • func (s *SchemaRepository) GetDefinition(ctx context.Context) (*schema.ServiceDefinition, error)

Types

type Bucket

type Bucket interface {
	WriteAll(ctx context.Context, key string, p []byte, opts *blob.WriterOptions) error
	ReadAll(ctx context.Context, key string) ([]byte, error)
	List(opts *blob.ListOptions) *blob.ListIterator
	Delete(ctx context.Context, key string) error
	Close() error
}

func NewStore

func NewStore(ctx context.Context, storagePath, storageSecret string) (Bucket, error)

type Resource

type Resource struct {
	Name    string
	Actions map[string][]string
}

type ResourceBackend

type ResourceBackend struct {
	Name          string         `json:"name" yaml:"name"`
	ResourceTypes []ResourceType `json:"resource_types" yaml:"resource_types"`
}

type ResourceBackends

type ResourceBackends struct {
	Backends []ResourceBackend `json:"backends" yaml:"backends"`
}

type ResourceType

type ResourceType struct {
	Name    string              `json:"name" yaml:"name"`
	Actions map[string][]string `json:"actions" yaml:"actions"`
}

type Resources

type Resources struct {
	Resources []Resource
}

type ResourcesRepository

type ResourcesRepository struct {
	Bucket Bucket
	// contains filtered or unexported fields
}

TODO(kushsharma): marked for deletion

func NewResourcesRepository

func NewResourcesRepository(logger log.Logger, b Bucket) *ResourcesRepository

func (*ResourcesRepository) Close

func (repo *ResourcesRepository) Close() error

func (*ResourcesRepository) GetAll

func (repo *ResourcesRepository) GetAll(ctx context.Context) ([]resource.YAML, error)

func (*ResourcesRepository) GetRelationsForNamespace

func (repo *ResourcesRepository) GetRelationsForNamespace(ctx context.Context, namespaceID string) (map[string]bool, error)

func (*ResourcesRepository) InitCache

func (repo *ResourcesRepository) InitCache(ctx context.Context, refreshDelay time.Duration) error

type SchemaRepository

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

func NewSchemaConfigRepository

func NewSchemaConfigRepository(b Bucket) *SchemaRepository

func (*SchemaRepository) GetDefinition

func (s *SchemaRepository) GetDefinition(ctx context.Context) (*schema.ServiceDefinition, error)

GetDefinition returns the service definition from the bucket