storage

Documentation

Index

• Variables
• func StorePolicies(policies models.TreePolicies, path string) error
• type Configuration
• type Constructor
• type DryStorage
  • func InitDryStorage(out string, constr Constructor) (*DryStorage, error)
  • func (d *DryStorage) Read(ctx context.Context, opts ...api.SourceOpt) (models.Rfc7396PatchOperation, error)
  • func (d *DryStorage) Write(ctx context.Context, data models.Rfc7396PatchOperation, opts ...api.SourceOpt) error
• type FileNameProvider
• type MultiStorage
  • func InitMultiStorage(config *MultiStorageConfiguration, constr Constructor) (*MultiStorage, error)
  • func (m *MultiStorage) Read(ctx context.Context, opts ...api.SourceOpt) (models.Rfc7396PatchOperation, error)
  • func (m *MultiStorage) String() string
  • func (m *MultiStorage) Write(ctx context.Context, data models.Rfc7396PatchOperation, opts ...api.SourceOpt) error
• type MultiStorageConfiguration
• type ReadFileOpt
• type ReadFileOpts
• type ServerStorage
  • func (s *ServerStorage) Read(ctx context.Context, opts ...api.SourceOpt) (models.Rfc7396PatchOperation, error)
  • func (s *ServerStorage) String() string
  • func (s *ServerStorage) Write(ctx context.Context, input models.Rfc7396PatchOperation, opts ...api.SourceOpt) error
• type Storage
  • func InitServerStorage(config *Configuration) Storage
  • func InitTenantStorage(config *Configuration) Storage
• type TenantStorage
  • func (t *TenantStorage) Read(ctx context.Context, opts ...api.SourceOpt) (models.Rfc7396PatchOperation, error)
  • func (t *TenantStorage) Write(ctx context.Context, data models.Rfc7396PatchOperation, opts ...api.SourceOpt) error
• type WithID
  • func NewWithID[T any](id string, data T) *WithID[T]
• type Writer
  • func RawWriter(dirPath string) (Writer[[]byte], error)
  • func YAMLWriter[T any](dirPath string) (Writer[T], error)
• type WriterFunc

Variables

var DefaultConfig = Configuration{
	DirPath: "data",
}

var DefaultMultiStorageConfig = func() *MultiStorageConfiguration {
	return &MultiStorageConfiguration{
		DirPath: []string{"data"},
	}
}

Functions

func StorePolicies

func StorePolicies(policies models.TreePolicies, path string) error

Types

type Configuration

type Configuration struct {
	DirPath string `json:"dir_path"`
}

type Constructor

type Constructor func(config *Configuration) Storage

type DryStorage

type DryStorage struct {
	DelegatedWriter WriterFunc
}

func InitDryStorage

func InitDryStorage(out string, constr Constructor) (*DryStorage, error)

func (*DryStorage) Read

func (d *DryStorage) Read(ctx context.Context, opts ...api.SourceOpt) (models.Rfc7396PatchOperation, error)

func (*DryStorage) Write

func (d *DryStorage) Write(ctx context.Context, data models.Rfc7396PatchOperation, opts ...api.SourceOpt) error

type FileNameProvider

type FileNameProvider[T any] func(id string, it T) string

type MultiStorage

type MultiStorage struct {
	Storages []Storage
	Config   *MultiStorageConfiguration
}

func InitMultiStorage

func InitMultiStorage(config *MultiStorageConfiguration, constr Constructor) (*MultiStorage, error)

func (*MultiStorage) Read

func (m *MultiStorage) Read(ctx context.Context, opts ...api.SourceOpt) (models.Rfc7396PatchOperation, error)

Read data from all storages and merge them

func (*MultiStorage) String

func (m *MultiStorage) String() string

func (*MultiStorage) Write

func (m *MultiStorage) Write(ctx context.Context, data models.Rfc7396PatchOperation, opts ...api.SourceOpt) error

Write for simplicity stores data in first storage only, it is responsibility of the user to move entities to other storages

type MultiStorageConfiguration

type MultiStorageConfiguration struct {
	DirPath []string `json:"dir_path"`
}

type ReadFileOpt

type ReadFileOpt func(opts *ReadFileOpts)

type ReadFileOpts

type ReadFileOpts struct {
}

type ServerStorage

type ServerStorage struct {
	Config *Configuration
}

func (*ServerStorage) Read

func (s *ServerStorage) Read(ctx context.Context, opts ...api.SourceOpt) (models.Rfc7396PatchOperation, error)

func (*ServerStorage) String

func (s *ServerStorage) String() string

func (*ServerStorage) Write

func (s *ServerStorage) Write(ctx context.Context, input models.Rfc7396PatchOperation, opts ...api.SourceOpt) error

type Storage

type Storage interface {
	Write(ctx context.Context, data models.Rfc7396PatchOperation, opts ...api.SourceOpt) error
	Read(ctx context.Context, opts ...api.SourceOpt) (models.Rfc7396PatchOperation, error)
}

func InitServerStorage

func InitServerStorage(config *Configuration) Storage

func InitTenantStorage

func InitTenantStorage(config *Configuration) Storage

type TenantStorage

type TenantStorage struct {
	Config        *Configuration
	ServerStorage Storage
}

func (*TenantStorage) Read

func (t *TenantStorage) Read(ctx context.Context, opts ...api.SourceOpt) (models.Rfc7396PatchOperation, error)

func (*TenantStorage) Write

func (t *TenantStorage) Write(ctx context.Context, data models.Rfc7396PatchOperation, opts ...api.SourceOpt) error

type WithID

type WithID[T any] struct {
	ID string `json:"id"`
	// nolint
	Other T `json:",inline,squash"`
}

func NewWithID

func NewWithID[T any](id string, data T) *WithID[T]

type Writer

type Writer[T any] func(name string, it T) error

func RawWriter

func RawWriter(dirPath string) (Writer[[]byte], error)

func YAMLWriter

func YAMLWriter[T any](dirPath string) (Writer[T], error)

type WriterFunc

type WriterFunc func(ctx context.Context, data models.Rfc7396PatchOperation, opts ...api.SourceOpt) error