storage

package

v0.5.8 Latest Latest Go to latest Published: Dec 7, 2023 License: MIT Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/shono-io/leeroy

Links

Open Source Insights

Documentation ¶

Index ¶

func ArangodbConfigFields() []*service.ConfigField
func CopyMeta(src, dst *service.Message)
func ElasticsearchConfigFields() []*service.ConfigField
func IsArangodbConfigured(conf *service.ParsedConfig) bool
func IsElasticsearchConfigured(conf *service.ParsedConfig) bool
type ArangodbClient
type Client
- func NewArangodbClientFromConfig(conf *service.ParsedConfig, mgr *service.Resources) (Client, error)
- func NewElasticsearchClientFromConfig(conf *service.ParsedConfig, mgr *service.Resources) (Client, error)
type Cursor
type ElasticsearchClient
type PagingOpts
type Query

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ArangodbConfigFields ¶

func ArangodbConfigFields() []*service.ConfigField

func CopyMeta ¶

func CopyMeta(src, dst *service.Message)

func ElasticsearchConfigFields ¶

func ElasticsearchConfigFields() []*service.ConfigField

func IsArangodbConfigured ¶

func IsArangodbConfigured(conf *service.ParsedConfig) bool

func IsElasticsearchConfigured ¶

func IsElasticsearchConfigured(conf *service.ParsedConfig) bool

Types ¶

type ArangodbClient ¶

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

func (ArangodbClient) Add ¶

func (c ArangodbClient) Add(ctx context.Context, collection string, key string, value map[string]any) error

func (ArangodbClient) Close ¶

func (c ArangodbClient) Close() error

func (ArangodbClient) Delete ¶

func (c ArangodbClient) Delete(ctx context.Context, collection string, key string) error

func (ArangodbClient) Get ¶

func (c ArangodbClient) Get(ctx context.Context, collection string, key string) (map[string]any, error)

func (ArangodbClient) List ¶

func (c ArangodbClient) List(ctx context.Context, collection string, q any, pitEnabled bool, paging *PagingOpts) (Cursor, error)

func (ArangodbClient) Merge ¶

func (c ArangodbClient) Merge(ctx context.Context, collection string, key string, value map[string]any) (map[string]any, error)

func (ArangodbClient) ParseQuery ¶

func (c ArangodbClient) ParseQuery(config string) (any, error)

func (ArangodbClient) Set ¶

func (c ArangodbClient) Set(ctx context.Context, collection string, key string, value map[string]any) error

type Client ¶

type Client interface {
	ParseQuery(config string) (any, error)
	List(ctx context.Context, collection string, q any, pitEnabled bool, paging *PagingOpts) (Cursor, error)
	Get(ctx context.Context, collection string, key string) (map[string]any, error)
	Set(ctx context.Context, collection string, key string, value map[string]any) error
	Merge(ctx context.Context, collection string, key string, value map[string]any) (map[string]any, error)
	Add(ctx context.Context, collection string, key string, value map[string]any) error
	Delete(ctx context.Context, collection string, key string) error
	Close() error
}

func NewArangodbClientFromConfig ¶

func NewArangodbClientFromConfig(conf *service.ParsedConfig, mgr *service.Resources) (Client, error)

func NewElasticsearchClientFromConfig ¶

func NewElasticsearchClientFromConfig(conf *service.ParsedConfig, mgr *service.Resources) (Client, error)

type Cursor ¶

type Cursor interface {
	HasNext() bool
	Read() (map[string]any, error)
	Close() error
}

type ElasticsearchClient ¶

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

func (*ElasticsearchClient) Add ¶

func (c *ElasticsearchClient) Add(ctx context.Context, collection string, key string, value map[string]any) error

func (*ElasticsearchClient) Close ¶

func (c *ElasticsearchClient) Close() error

func (*ElasticsearchClient) Delete ¶

func (c *ElasticsearchClient) Delete(ctx context.Context, collection string, key string) error

func (*ElasticsearchClient) Get ¶

func (c *ElasticsearchClient) Get(ctx context.Context, collection string, key string) (map[string]any, error)

func (*ElasticsearchClient) List ¶

func (c *ElasticsearchClient) List(ctx context.Context, collection string, q any, pitEnabled bool, paging *PagingOpts) (Cursor, error)

func (*ElasticsearchClient) Merge ¶

func (c *ElasticsearchClient) Merge(ctx context.Context, collection string, key string, value map[string]any) (map[string]any, error)

func (*ElasticsearchClient) ParseQuery ¶

func (c *ElasticsearchClient) ParseQuery(config string) (any, error)

func (*ElasticsearchClient) Set ¶

func (c *ElasticsearchClient) Set(ctx context.Context, collection string, key string, value map[string]any) error

type PagingOpts ¶

type PagingOpts struct {
	Offset int64
	Size   int64
}

type Query ¶

type Query interface {
	Parse(config string) error
}

Source Files ¶

View all Source files

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