jdbc

README

Javazac database client

Go client for Javazac database websocket servers

Getting started

Documentation

Index

• Variables
• type Client
  • func NewClient(endpoint string, options ClientOptions) (*Client, error)
  • func (s *Client) Close()
  • func (s *Client) ConnectToWebsocket() error
  • func (s *Client) GetByPrefix(prefix string) (map[string]string, error)
  • func (s *Client) GetJSON(key string, dst interface{}) error
  • func (s *Client) GetKey(key string) (string, error)
  • func (s *Client) GetKeys(keys []string) (map[string]string, error)
  • func (s *Client) ListKeys(prefix string) ([]string, error)
  • func (s *Client) SetJSON(key string, data interface{}) error
  • func (s *Client) SetJSONs(data map[string]interface{}) error
  • func (s *Client) SetKey(key string, data string) error
  • func (s *Client) SetKeys(data map[string]string) error
  • func (s *Client) SubscribeKey(key string) (chan KeyValuePair, error)
  • func (s *Client) SubscribePrefix(prefix string) (chan KeyValuePair, error)
  • func (s *Client) UnsubscribeKey(key string, chn chan KeyValuePair) error
  • func (s *Client) UnsubscribePrefix(prefix string, chn chan KeyValuePair) error
• type ClientOptions
• type KeyValuePair

Variables

var (
	ErrNotAuthenticated     = errors.New("not authenticated")
	ErrSubscriptionNotFound = errors.New("subscription not found")
	ErrEmptyKey             = errors.New("key empty or unset")
)

Types

type Client

type Client struct {
	Endpoint string
	Logger   logrus.FieldLogger
	// contains filtered or unexported fields
}

func NewClient

func NewClient(endpoint string, options ClientOptions) (*Client, error)

func (*Client) Close

func (s *Client) Close()

func (*Client) ConnectToWebsocket

func (s *Client) ConnectToWebsocket() error

func (*Client) GetByPrefix

func (s *Client) GetByPrefix(prefix string) (map[string]string, error)

func (*Client) GetJSON

func (s *Client) GetJSON(key string, dst interface{}) error

func (*Client) GetKey

func (s *Client) GetKey(key string) (string, error)

func (*Client) GetKeys

func (s *Client) GetKeys(keys []string) (map[string]string, error)

func (*Client) ListKeys

func (s *Client) ListKeys(prefix string) ([]string, error)

func (*Client) SetJSON

func (s *Client) SetJSON(key string, data interface{}) error

func (*Client) SetJSONs

func (s *Client) SetJSONs(data map[string]interface{}) error

func (*Client) SetKey

func (s *Client) SetKey(key string, data string) error

func (*Client) SetKeys

func (s *Client) SetKeys(data map[string]string) error

func (*Client) SubscribeKey

func (s *Client) SubscribeKey(key string) (chan KeyValuePair, error)

func (*Client) SubscribePrefix

func (s *Client) SubscribePrefix(prefix string) (chan KeyValuePair, error)

func (*Client) UnsubscribeKey

func (s *Client) UnsubscribeKey(key string, chn chan KeyValuePair) error

func (*Client) UnsubscribePrefix

func (s *Client) UnsubscribePrefix(prefix string, chn chan KeyValuePair) error

type ClientOptions

type ClientOptions struct {
	Headers http.Header
	Logger  logrus.FieldLogger
}

type KeyValuePair

type KeyValuePair struct {
	Key   string
	Value string
}