xstorage

package

v0.0.0-...-a136232 Latest Latest Go to latest Published: Oct 31, 2022 License: Apache-2.0 Imports: 13 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/acknode/ackstream

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func CfgWithContext(ctx context.Context, cfg *Configs) context.Context
func ConnFromContext(ctx context.Context) (*gocql.Session, error)
func ConnWithContext(ctx context.Context, conn *gocql.Session) context.Context
func Migrate(ctx context.Context, dirs []string) error
func NewConnection(ctx context.Context) (*gocql.Session, error)
type Configs
- func CfgFromContext(ctx context.Context) (*Configs, error)
type Get
- func NewGet(ctx context.Context) (Get, error)
type Put
- func NewPut(ctx context.Context) (Put, error)

Constants ¶

View Source

const CTXKEY_CFG ctxkey = "ackstream.xstorage.configs"

View Source

const CTXKEY_CONN ctxkey = "ackstream.xstorage.connection"

Variables ¶

View Source

var ErrCfgNotFound = errors.New("no configs was set")

View Source

var ErrConnNotFound = errors.New("no connection was initialized")

View Source

var ErrEventInvalid = errors.New("event is not valid")

View Source

var ErrEventQueryInvalid = errors.New("event query is not valid")

Functions ¶

func CfgWithContext ¶

func CfgWithContext(ctx context.Context, cfg *Configs) context.Context

func ConnFromContext ¶

func ConnFromContext(ctx context.Context) (*gocql.Session, error)

func ConnWithContext ¶

func ConnWithContext(ctx context.Context, conn *gocql.Session) context.Context

func Migrate ¶

func Migrate(ctx context.Context, dirs []string) error

func NewConnection ¶

func NewConnection(ctx context.Context) (*gocql.Session, error)

Types ¶

type Configs ¶

type Configs struct {
	Hosts    []string `json:"hosts" mapstructure:"ACKSTREAM_XSTORAGE_HOSTS"`
	Keyspace string   `json:"keyspace" mapstructure:"ACKSTREAM_XSTORAGE_KEYSPACE"`
	Table    string   `json:"table" mapstructure:"ACKSTREAM_XSTORAGE_TABLE"`
}

func CfgFromContext ¶

func CfgFromContext(ctx context.Context) (*Configs, error)

type Get ¶

type Get func(sample *entities.Event) (*entities.Event, error)

func NewGet ¶

func NewGet(ctx context.Context) (Get, error)

type Put ¶

type Put func(event *entities.Event) error

func NewPut ¶

func NewPut(ctx context.Context) (Put, error)

Source Files ¶

View all Source files

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