client

package
v0.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 17, 2020 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

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

Client is an Atomix client

func New 

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

New returns a new Atomix client

func NewClient 

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

NewClient returns a new Atomix client Deprected: use New instead

func (*Client) Close 

func (c *Client) Close() error

Close closes the client

func (*Client) CreateGroup 

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

CreateGroup creates a new partition group Deprecated: Groups have been replaced with Databases and can only be modified by the controller

func (*Client) DeleteGroup 

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

DeleteGroup deletes a partition group via the controller Deprecated: Groups have been replaced with Databases and can only be modified by the controller

func (*Client) GetDatabase 

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

GetDatabase gets a database client by name from the client's namespace

func (*Client) GetDatabases 

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

GetDatabases returns a list of all databases in the client's namespace

func (*Client) GetGroup 

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

GetGroup returns a partition group primitive client Deprecated: Groups have been replaced with Databases. Use GetDatabase instead.

func (*Client) GetGroups 

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

GetGroups returns a list of all partition group in the client's namespace Deprecated: Groups have been replaced with Databases. Use GetDatabases instead.

type Database 

type Database struct {
	Namespace string
	Name      string
	// contains filtered or unexported fields
}

Database manages the primitives in a set of partitions

func (*Database) GetCounter 

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

GetCounter gets or creates a Counter with the given name

func (*Database) GetElection 

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

GetElection gets or creates an Election with the given name

func (*Database) GetIndexedMap 

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

GetIndexedMap gets or creates a Map with the given name

func (*Database) GetLeaderLatch 

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

GetLeaderLatch gets or creates a LeaderLatch with the given name

func (*Database) GetList 

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

GetList gets or creates a List with the given name

func (*Database) GetLock 

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

GetLock gets or creates a Lock with the given name

func (*Database) GetLog 

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

GetLog gets or creates a Log with the given name

func (*Database) GetMap 

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

GetMap gets or creates a Map with the given name

func (*Database) GetPrimitives 

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

GetPrimitives gets a list of primitives in the database

func (*Database) GetSet 

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

GetSet gets or creates a Set with the given name

func (*Database) GetValue 

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

GetValue gets or creates a Value with the given name

type Option 

type Option interface {
	// contains filtered or unexported methods
}

Option provides a client option

func WithApplication 

func WithApplication(application string) Option

WithApplication configures the application name for the client Deprecated: Use WithScope instead

func WithNamespace 

func WithNamespace(namespace string) Option

WithNamespace configures the client's partition group namespace

func WithScope 

func WithScope(scope string) Option

WithScope configures the application scope for the client

func WithSessionTimeout 

func WithSessionTimeout(timeout time.Duration) Option

WithSessionTimeout sets the session timeout for the client

type PartitionGroup 

type PartitionGroup struct {
	Namespace     string
	Name          string
	Partitions    int
	PartitionSize int
	// contains filtered or unexported fields
}

PartitionGroup manages the primitives in a partition group Deprecated: PartitionGroup has been replaced by the Database abstraction

func (*PartitionGroup) GetCounter 

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

GetCounter gets or creates a Counter with the given name

func (*PartitionGroup) GetElection 

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

GetElection gets or creates an Election with the given name

func (*PartitionGroup) GetIndexedMap 

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

GetIndexedMap gets or creates a Map with the given name

func (*PartitionGroup) GetLeaderLatch 

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

GetLeaderLatch gets or creates a LeaderLatch with the given name

func (*PartitionGroup) GetList 

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

GetList gets or creates a List with the given name

func (*PartitionGroup) GetLock 

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

GetLock gets or creates a Lock with the given name

func (*PartitionGroup) GetLog 

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

GetLog gets or creates a Log with the given name

func (*PartitionGroup) GetMap 

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

GetMap gets or creates a Map with the given name

func (*PartitionGroup) GetSet 

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

GetSet gets or creates a Set with the given name

func (*PartitionGroup) GetValue 

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

GetValue gets or creates a Value with the given name

Source Files

View all Source files

Directories

Path Synopsis
net

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.