dstash

Documentation

Index

• Variables
• func ToBytes(v interface{}) []byte
• func ToString(v interface{}) string
• func UnmarshalValue(kind reflect.Kind, buf []byte) interface{}
• type Client
  • func NewDefaultClient() *Client
  • func (c *Client) BatchIndex(batch map[string]struct{}) error
  • func (c *Client) BatchLookup(batch map[interface{}]interface{}) (map[interface{}]interface{}, error)
  • func (c *Client) BatchPut(batch map[interface{}]interface{}) error
  • func (m *Client) Connect() (err error)
  • func (c *Client) Disconnect() error
  • func (c *Client) Index(str string) error
  • func (c *Client) Items(keyType, valueType reflect.Kind) (map[interface{}]interface{}, error)
  • func (c *Client) Lookup(key interface{}, valueType reflect.Kind) (interface{}, error)
  • func (c *Client) Put(k interface{}, v interface{}) error
  • func (c *Client) Search(searchTerms string) (map[uint64]struct{}, error)

Variables

var (
	//Deadline int = 60
	Deadline time.Duration = time.Duration(60)
)

Functions

func ToBytes

func ToBytes(v interface{}) []byte

func ToString

func ToString(v interface{}) string

func UnmarshalValue

func UnmarshalValue(kind reflect.Kind, buf []byte) interface{}

Types

type Client

type Client struct {
	ServiceName        string
	Quorum             int
	Replicas           int
	ConsulAgentAddr    string
	ServicePort        int
	ServerHostOverride string
	// contains filtered or unexported fields
}

func NewDefaultClient

func NewDefaultClient() *Client

func (*Client) BatchIndex

func (c *Client) BatchIndex(batch map[string]struct{}) error

func (*Client) BatchLookup

func (c *Client) BatchLookup(batch map[interface{}]interface{}) (map[interface{}]interface{}, error)

func (*Client) BatchPut

func (c *Client) BatchPut(batch map[interface{}]interface{}) error

func (*Client) Connect

func (m *Client) Connect() (err error)

func (*Client) Disconnect

func (c *Client) Disconnect() error

func (*Client) Index

func (c *Client) Index(str string) error

func (*Client) Items

func (c *Client) Items(keyType, valueType reflect.Kind) (map[interface{}]interface{}, error)

func (*Client) Lookup

func (c *Client) Lookup(key interface{}, valueType reflect.Kind) (interface{}, error)

func (*Client) Put

func (c *Client) Put(k interface{}, v interface{}) error

func (*Client) Search

func (c *Client) Search(searchTerms string) (map[uint64]struct{}, error)