cursusdbgo

README

Installation

go get github.com/cursusdb/cursusdb-go

OR

go mod download github.com/cursusdb/cursusdb-go

Usage

package main

import (
	"fmt"
	cursusdbgo "github.com/cursusdb/cursusdb-go"
)

func main() {
	var client *cursusdbgo.Client

	client = &cursusdbgo.Client{
		TLS:         false,
		ClusterHost: "0.0.0.0",
		ClusterPort: 7681,
		Username:    "someuser",
		Password:    "somepassword",
		ClusterReadTimeout: time.Now().Add(time.Second * 10),
	}

	err := client.Connect()
	if err != nil {
		fmt.Println(err.Error())
		return
	}

	defer client.Close()

	res, err := client.Query(`ping;`)
	if err != nil {
		fmt.Println(err.Error())
		return
	}

	fmt.Println(res)

}

Documentation

Overview

Package cursusdbgo Go Native Client /////////////////////////////////////////////////////////////////////// Copyright (C) 2023 CursusDB

This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.

You should have received a copy of the GNU General Public License along with this program. If not, see <http://www.gnu.org/licenses/>.

Index

• type Client
  • func (client *Client) Close()
  • func (client *Client) Connect() error
  • func (client *Client) Query(query string) (string, error)

Types

type Client

type Client struct {
	TLS                bool            // TLS enabled?
	ClusterHost        string          // Cluster host
	ClusterPort        uint            // Cluster port
	Username           string          // Database username
	Password           string          // Database password
	Text               *textproto.Conn // Writer and reader
	Conn               net.Conn        // Conn
	ClusterReadTimeout time.Time       // Cluster read timeout
}

Client is the CursusDB cluster client structure

func (*Client) Close

func (client *Client) Close()

Close closes CursusDB cluster connection

func (*Client) Connect

func (client *Client) Connect() error

Connect - Connect to new setup client to a CursusDB cluster

func (*Client) Query

func (client *Client) Query(query string) (string, error)

Query sends query to cluster