service

Documentation

Index

• type BleveDocument
• type Option
  • func Config(val *config.Config) Option
  • func Database(val *config.Config) Option
  • func Logger(val log.Logger) Option
  • func Nodes(val *config.Config) Option
  • func Table(val *config.Config) Option
• type Options
• type Service
  • func New(opts ...Option) (s *Service, err error)
  • func (s *Service) Databases(c context.Context, dbreq *storesvc.DatabasesRequest, ...) error
  • func (s *Service) Delete(c context.Context, dreq *storesvc.DeleteRequest, dres *storesvc.DeleteResponse) error
  • func (s *Service) List(context.Context, *storesvc.ListRequest, storesvc.Store_ListStream) error
  • func (s *Service) Read(c context.Context, rreq *storesvc.ReadRequest, rres *storesvc.ReadResponse) error
  • func (s *Service) Tables(ctx context.Context, in *storesvc.TablesRequest, out *storesvc.TablesResponse) error
  • func (s *Service) Write(c context.Context, wreq *storesvc.WriteRequest, wres *storesvc.WriteResponse) error

Types

type BleveDocument

type BleveDocument struct {
	Metadata map[string]*storemsg.Field `json:"metadata"`
	Database string                     `json:"database"`
	Table    string                     `json:"table"`
}

BleveDocument wraps the generated Record.Metadata and adds a property that is used to distinguish documents in the index.

type Option

type Option func(o *Options)

Option defines a single option function.

func Config

func Config(val *config.Config) Option

Config configures the Config option.

func Database

func Database(val *config.Config) Option

Database configures the database option.

func Logger

func Logger(val log.Logger) Option

Logger provides a function to set the logger option.

func Nodes

func Nodes(val *config.Config) Option

Nodes configures the Nodes option.

func Table

func Table(val *config.Config) Option

Table configures the Table option.

type Options

type Options struct {
	Logger log.Logger
	Config *config.Config

	Database, Table string
	Nodes           []string
}

Options defines the available options for this package.

type Service

type Service struct {
	Config *config.Config
	// contains filtered or unexported fields
}

Service implements the AccountsServiceHandler interface

func New

func New(opts ...Option) (s *Service, err error)

New returns a new instance of Service

func (*Service) Databases

func (s *Service) Databases(c context.Context, dbreq *storesvc.DatabasesRequest, dbres *storesvc.DatabasesResponse) error

Databases implements the StoreHandler interface.

func (*Service) Delete

func (s *Service) Delete(c context.Context, dreq *storesvc.DeleteRequest, dres *storesvc.DeleteResponse) error

Delete implements the StoreHandler interface.

func (*Service) List

func (s *Service) List(context.Context, *storesvc.ListRequest, storesvc.Store_ListStream) error

List implements the StoreHandler interface.

func (*Service) Read

func (s *Service) Read(c context.Context, rreq *storesvc.ReadRequest, rres *storesvc.ReadResponse) error

Read implements the StoreHandler interface.

func (*Service) Tables

func (s *Service) Tables(ctx context.Context, in *storesvc.TablesRequest, out *storesvc.TablesResponse) error

Tables implements the StoreHandler interface.

func (*Service) Write

func (s *Service) Write(c context.Context, wreq *storesvc.WriteRequest, wres *storesvc.WriteResponse) error

Write implements the StoreHandler interface.