blob

Documentation

Index

• type Bucket
  • func NewStore(ctx context.Context, storagePath, storageSecret string) (Bucket, error)
• type RuleRepository
  • func NewRuleRepository(logger log.Logger, b Bucket) *RuleRepository
  • func (repo *RuleRepository) Close() error
  • func (repo *RuleRepository) GetAll(ctx context.Context) ([]rule.Ruleset, error)
  • func (repo *RuleRepository) InitCache(ctx context.Context, refreshDelay time.Duration) error
  • func (repo *RuleRepository) Upsert(ctx context.Context, name string, config rule.Ruleset) (rule.Config, error)
• type SchemaConfig
  • func NewSchemaConfigRepository(b Bucket) *SchemaConfig
  • func (s *SchemaConfig) GetSchema(ctx context.Context) (schema.NamespaceConfigMapType, error)
  • func (repo *SchemaConfig) UpsertResourceConfigs(ctx context.Context, name string, config schema.NamespaceConfigMapType) (schema.Config, 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 RuleRepository

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

func NewRuleRepository

func NewRuleRepository(logger log.Logger, b Bucket) *RuleRepository

func (*RuleRepository) Close

func (repo *RuleRepository) Close() error

func (*RuleRepository) GetAll

func (repo *RuleRepository) GetAll(ctx context.Context) ([]rule.Ruleset, error)

func (*RuleRepository) InitCache

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

func (*RuleRepository) Upsert

func (repo *RuleRepository) Upsert(ctx context.Context, name string, config rule.Ruleset) (rule.Config, error)

type SchemaConfig

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

func NewSchemaConfigRepository

func NewSchemaConfigRepository(b Bucket) *SchemaConfig

func (*SchemaConfig) GetSchema

func (s *SchemaConfig) GetSchema(ctx context.Context) (schema.NamespaceConfigMapType, error)

func (*SchemaConfig) UpsertResourceConfigs

func (repo *SchemaConfig) UpsertResourceConfigs(ctx context.Context, name string, config schema.NamespaceConfigMapType) (schema.Config, error)