datastore

Documentation

Index

• type Connection
  • func (c *Connection) Init()
  • func (c *Connection) Validate() error
• type Reference
  • func (d *Reference) Init()
  • func (d *Reference) RetryTime() time.Duration
  • func (d *Reference) TimeToLive() time.Duration
• type Timeout
  • func (t *Timeout) DurationUnit() time.Duration

Types

type Connection

type Connection struct {
	ID string
	//Hosts coma separated list of hostnmae
	Hostnames string
	Port      int
	Timeout   *Timeout
}

Connection represents a connection

func (*Connection) Init

func (c *Connection) Init()

Init initialises connection

func (*Connection) Validate

func (c *Connection) Validate() error

type Reference

type Reference struct {
	Connection   string
	Namespace    string
	Dataset      string
	TimeToLiveMs int `json:",omitempty" yaml:",omitempty"`

	RetryTimeMs int `json:",omitempty" yaml:",omitempty"`

	ReadOnly bool `json:",omitempty" yaml:",omitempty"`
	// contains filtered or unexported fields
}

Reference datastore reference

func (*Reference) Init

func (d *Reference) Init()

func (*Reference) RetryTime

func (d *Reference) RetryTime() time.Duration

func (*Reference) TimeToLive

func (d *Reference) TimeToLive() time.Duration

type Timeout

type Timeout struct {
	Unit       string
	Connection int
	Socket     int
	Total      int
}

Timeout timout setting

func (*Timeout) DurationUnit

func (t *Timeout) DurationUnit() time.Duration