client

Oct 22, 2020

Changes in this version

type Client

+ func NewWithContext(ctx context.Context, address string, opts ...Option) (*Client, error)

Jun 3, 2020

Changes in this version

type Option

+ func WithPeerServerOption(option grpc.ServerOption) Option

+ func WithPeerService(service peer.Service) Option

May 21, 2020

Changes in this version

type Client

+ func (c *Client) Group() *peer.Group

type Option

+ func WithJoinTimeout(timeout time.Duration) Option

+ func WithMemberID(memberID string) Option

+ func WithPeerHost(host string) Option

+ func WithPeerPort(port int) Option

+ func WithService(service peer.Service) Option

Apr 9, 2020

Changes in this version

+ type Client struct

+ func New(address string, opts ...Option) (*Client, error)

+ func NewClient(address string, opts ...Option) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) CreateGroup(ctx context.Context, name string, partitions int, partitionSize int, ...) (*PartitionGroup, error)

+ func (c *Client) DeleteGroup(ctx context.Context, name string) error

+ func (c *Client) GetDatabase(ctx context.Context, name string) (*Database, error)

+ func (c *Client) GetDatabases(ctx context.Context) ([]*Database, error)

+ func (c *Client) GetGroup(ctx context.Context, name string) (*PartitionGroup, error)

+ func (c *Client) GetGroups(ctx context.Context) ([]*PartitionGroup, error)

+ type Database struct

+ Name string

+ Namespace string

+ func (d *Database) GetCounter(ctx context.Context, name string) (counter.Counter, error)

+ func (d *Database) GetElection(ctx context.Context, name string, opts ...election.Option) (election.Election, error)

+ func (d *Database) GetIndexedMap(ctx context.Context, name string) (indexedmap.IndexedMap, error)

+ func (d *Database) GetLeaderLatch(ctx context.Context, name string, opts ...leader.Option) (leader.Latch, error)

+ func (d *Database) GetList(ctx context.Context, name string) (list.List, error)

+ func (d *Database) GetLock(ctx context.Context, name string) (lock.Lock, error)

+ func (d *Database) GetLog(ctx context.Context, name string) (log.Log, error)

+ func (d *Database) GetMap(ctx context.Context, name string, opts ..._map.Option) (_map.Map, error)

+ func (d *Database) GetPrimitives(ctx context.Context, opts ...primitive.MetadataOption) ([]primitive.Metadata, error)

+ func (d *Database) GetSet(ctx context.Context, name string) (set.Set, error)

+ func (d *Database) GetValue(ctx context.Context, name string) (value.Value, error)

+ type Option interface

+ func WithApplication(application string) Option

+ func WithNamespace(namespace string) Option

+ func WithScope(scope string) Option

+ func WithSessionTimeout(timeout time.Duration) Option

+ type PartitionGroup struct

+ Name string

+ Namespace string

+ PartitionSize int

+ Partitions int

+ func (g *PartitionGroup) GetCounter(ctx context.Context, name string) (counter.Counter, error)

+ func (g *PartitionGroup) GetElection(ctx context.Context, name string, opts ...election.Option) (election.Election, error)

+ func (g *PartitionGroup) GetIndexedMap(ctx context.Context, name string) (indexedmap.IndexedMap, error)

+ func (g *PartitionGroup) GetLeaderLatch(ctx context.Context, name string, opts ...leader.Option) (leader.Latch, error)

+ func (g *PartitionGroup) GetList(ctx context.Context, name string) (list.List, error)

+ func (g *PartitionGroup) GetLock(ctx context.Context, name string) (lock.Lock, error)

+ func (g *PartitionGroup) GetLog(ctx context.Context, name string) (log.Log, error)

+ func (g *PartitionGroup) GetMap(ctx context.Context, name string, opts ..._map.Option) (_map.Map, error)

+ func (g *PartitionGroup) GetSet(ctx context.Context, name string) (set.Set, error)

+ func (g *PartitionGroup) GetValue(ctx context.Context, name string) (value.Value, error)