stores

Documentation

Index

• func LoadReadableStore(name string, options *Options) (models.ReadableStore, error)
• func LoadWritableStore(name string, options *Options) (models.WritableStore, error)
• func RegisterStore(name string, store StoreLoader)
• type Options
  • func CreateOptions(ctx context.Context, param map[string]string, input jobs.ActionMessage) *Options
• type StoreLoader

Functions

func LoadReadableStore

func LoadReadableStore(name string, options *Options) (models.ReadableStore, error)

LoadReadableStore finds an available readable store by name

func LoadWritableStore

func LoadWritableStore(name string, options *Options) (models.WritableStore, error)

GetWritableStore finds a writable store by its name

func RegisterStore

func RegisterStore(name string, store StoreLoader)

RegisterStore registers an available store

Types

type Options

type Options struct {
	Params       map[string]string
	MergeOptions *models.MergeOptions
	ActionInput  jobs.ActionMessage
	Context      context.Context
}

Options passes params and merge options when initializing stores

func CreateOptions

func CreateOptions(ctx context.Context, param map[string]string, input jobs.ActionMessage) *Options

CreateOptions initialize an empty Options object

type StoreLoader

type StoreLoader func(options *Options) (interface{}, error)

StoreLoader must return an initialized store