storage

Documentation

Index

• type S3Info
• type SecretInfo
• type Source
  • func New() *Source
  • func (s *Source) AsModule() bool
  • func (s *Source) Attach(ctx context.Context, pool *db.Pool) error
  • func (s *Source) Catalog(ctx context.Context) sources.Source
  • func (s *Source) Engine() engines.Engine
  • func (s *Source) IsReadonly() bool
  • func (s *Source) Name() string
  • func (s *Source) RegisterS3(ctx context.Context, info S3Info) error
  • func (s *Source) RegisterSecret(ctx context.Context, info SecretInfo) error
  • func (s *Source) UnregisterS3(ctx context.Context, name string) error
  • func (s *Source) UnregisterSecret(ctx context.Context, name string) error

Types

type S3Info

type S3Info struct {
	Name     string `json:"name"`
	Type     string `json:"type"`
	KeyID    string `json:"key_id"`
	Secret   string `json:"secret"`
	Region   string `json:"region"`
	Endpoint string `json:"endpoint"`
	UseSSL   bool   `json:"use_ssl"`
	URLStyle string `json:"url_style"`
	Scope    string `json:"scope"`
}

type SecretInfo

type SecretInfo struct {
	Name       string         `json:"name"`
	Type       string         `json:"type"`
	Scope      string         `json:"scope"`
	Parameters map[string]any `json:"parameters"`
}

type Source

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

func New

func New() *Source

func (*Source) AsModule

func (s *Source) AsModule() bool

func (*Source) Attach

func (s *Source) Attach(ctx context.Context, pool *db.Pool) error

func (*Source) Catalog

func (s *Source) Catalog(ctx context.Context) sources.Source

func (*Source) Engine

func (s *Source) Engine() engines.Engine

func (*Source) IsReadonly

func (s *Source) IsReadonly() bool

func (*Source) Name

func (s *Source) Name() string

func (*Source) RegisterS3

func (s *Source) RegisterS3(ctx context.Context, info S3Info) error

func (*Source) RegisterSecret

func (s *Source) RegisterSecret(ctx context.Context, info SecretInfo) error

func (*Source) UnregisterS3

func (s *Source) UnregisterS3(ctx context.Context, name string) error

func (*Source) UnregisterSecret

func (s *Source) UnregisterSecret(ctx context.Context, name string) error