himeji

Documentation

Index

• type Bound
• type Bounds
• type Data
• type Error
  • func (e Error) Error() string
• type Himeji
  • func New(repo RepoFacade) *Himeji
  • func (h *Himeji) Close()
  • func (h *Himeji) Connect() <-chan bool
  • func (h *Himeji) Insert(collection string, data *Data) <-chan bool
  • func (h *Himeji) Query(collection string, query Bounds, result *Data) <-chan bool
  • func (h *Himeji) QueryId(collection string, query string, result *Data) <-chan bool
  • func (h *Himeji) Shutdown()
  • func (h *Himeji) Start()
• type RepoFacade

Types

type Bound

type Bound struct {
	Condition string
	Item      string
	Value     string
}

Bound is a query format

conditions: equal limit

type Bounds

type Bounds []Bound

type Data

type Data struct {
	Value interface{}
}

type Error

type Error string

func (Error) Error

func (e Error) Error() string

type Himeji

type Himeji struct {
	service.ServiceBase
	// contains filtered or unexported fields
}

func New

func New(repo RepoFacade) *Himeji

func (*Himeji) Close

func (h *Himeji) Close()

func (*Himeji) Connect

func (h *Himeji) Connect() <-chan bool

func (*Himeji) Insert

func (h *Himeji) Insert(collection string, data *Data) <-chan bool

func (*Himeji) Query

func (h *Himeji) Query(collection string, query Bounds, result *Data) <-chan bool

func (*Himeji) QueryId

func (h *Himeji) QueryId(collection string, query string, result *Data) <-chan bool

func (*Himeji) Shutdown

func (h *Himeji) Shutdown()

func (*Himeji) Start

func (h *Himeji) Start()

type RepoFacade

type RepoFacade interface {
	Connect(done chan<- bool)
	Close()
	Insert(done chan<- bool, collection string, data *Data)
	Query(done chan<- bool, collection string, query Bounds, result *Data)
	QueryId(done chan<- bool, collection string, query string, result *Data)
}