ignite

Documentation

Overview

Package ignite contains an implementation of the `gokv.Store` interface for Apache Ignite.

Index

• Variables
• type Client
  • func NewClient(options Options) (Client, error)
  • func (c Client) Close() error
  • func (c Client) Delete(k string) error
  • func (c Client) Get(k string, v any) (found bool, err error)
  • func (c Client) Set(k string, v any) error
• type Options

Variables

var DefaultOptions = Options{
	Host:      "localhost",
	Port:      10800,
	CacheName: "gokv",
	Codec:     encoding.JSON,
}

DefaultOptions is an Options object with default values. Host: "localhost", Port: 10800, CacheName: "gokv", Codec: encoding.JSON

Types

type Client

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

Client is a gokv.Store implementation for Apache Ignite.

func NewClient

func NewClient(options Options) (Client, error)

NewClient creates a new Apache Ignite client.

You must call the Close() method on the client when you're done working with it.

func (Client) Close

func (c Client) Close() error

Close closes the client. It must be called to shut down all connections to the Apache Ignite server.

func (Client) Delete

func (c Client) Delete(k string) error

Delete deletes the stored value for the given key. Deleting a non-existing key-value pair does NOT lead to an error. The key must not be "".

func (Client) Get

func (c Client) Get(k string, v any) (found bool, err error)

Get retrieves the stored value for the given key. You need to pass a pointer to the value, so in case of a struct the automatic unmarshalling can populate the fields of the object that v points to with the values of the retrieved object's values. If no value is found it returns (false, nil). The key must not be "" and the pointer must not be nil.

func (Client) Set

func (c Client) Set(k string, v any) error

Set stores the given value for the given key. Values are automatically marshalled to JSON or gob (depending on the configuration). The key must not be "" and the value must not be nil.

type Options

type Options struct {
	// Server address without port.
	// Optional ("localhost" by default).
	Host string
	// Server binary protocol connector port.
	// See https://apacheignite.readme.io/docs/binary-client-protocol#section-tcp-socket.
	// Optional (10800 by default).
	Port int
	// Username.
	// Optional ("" by default).
	Username string
	// Password.
	// Optional ("" by default).
	Password string
	// Name of the cache.
	// Optional ("gokv" by default).
	CacheName string
	// Encoding format.
	// Optional (encoding.JSON by default).
	Codec encoding.Codec
}

Options are the options for the Apache Ignite client.