repo

Documentation

Index

• Variables
• func Close()
• func Init() error
• func Open(url string) error
• func Read(req *prompb.ReadRequest, w io.Writer) error
• func Write(req *prompb.WriteRequest) error
• type Driver

Variables

var ErrUnknownDriver = errors.New("unknown driver")

ErrUnknownDriver indicates that given sql driver is not supported.

var ErrWriteQueueIsAlreadyClosed = errors.New("write queue is already closed")

Functions

func Close

func Close()

Close all resources

func Init

func Init() error

Init drivers

func Open

func Open(url string) error

Open database

func Read

func Read(req *prompb.ReadRequest, w io.Writer) error

Read handles read request

func Write

func Write(req *prompb.WriteRequest) error

Write handles write request

Types

type Driver

type Driver interface {
	Init() error
	Read(req *prompb.ReadRequest, w io.Writer) error
	Write(req *prompb.WriteRequest) error
	Close()
}

Driver abstract underlying database.