blob

package
v0.9.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 30, 2024 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 PlanRepository added in v0.8.0

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

func NewPlanRepository added in v0.8.0

func NewPlanRepository(b Bucket) *PlanRepository

func (*PlanRepository) Get added in v0.8.0

func (s *PlanRepository) Get(ctx context.Context) (plan.File, error)

Get returns the plans from the bucket

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL