handler

Documentation

Index

• type Db
  • func (e *Db) Count(ctx context.Context, req *db_pb.CountRequest) (*db_pb.CountResponse, error)
  • func (e *Db) Create(ctx context.Context, req *db_pb.CreateRequest) (*db_pb.CreateResponse, error)
  • func (e *Db) Delete(ctx context.Context, req *db_pb.DeleteRequest) (*db_pb.DeleteResponse, error)
  • func (e *Db) DropTable(ctx context.Context, req *db_pb.DropTableRequest) (*db_pb.DropTableResponse, error)
  • func (e *Db) Init()
  • func (e *Db) ListTables(ctx context.Context, req *db_pb.ListTablesRequest) (*db_pb.ListTablesResponse, error)
  • func (e *Db) Read(ctx context.Context, req *db_pb.ReadRequest) (*db_pb.ReadResponse, error)
  • func (e *Db) RenameTable(ctx context.Context, req *db_pb.RenameTableRequest) (*db_pb.RenameTableResponse, error)
  • func (e *Db) Truncate(ctx context.Context, req *db_pb.TruncateRequest) (*db_pb.TruncateResponse, error)
  • func (e *Db) Update(ctx context.Context, req *db_pb.UpdateRequest) (*db_pb.UpdateResponse, error)
• type Query
  • func Parse(q string) ([]Query, error)
• type Record

Types

type Db

type Db struct {
	Db *orm.Client `dix:""`
}

func (*Db) Count

func (e *Db) Count(ctx context.Context, req *db_pb.CountRequest) (*db_pb.CountResponse, error)

func (*Db) Create

func (e *Db) Create(ctx context.Context, req *db_pb.CreateRequest) (*db_pb.CreateResponse, error)

Call is a single request handler called via client.Call or the generated client code

func (*Db) Delete

func (e *Db) Delete(ctx context.Context, req *db_pb.DeleteRequest) (*db_pb.DeleteResponse, error)

func (*Db) DropTable

func (e *Db) DropTable(ctx context.Context, req *db_pb.DropTableRequest) (*db_pb.DropTableResponse, error)

func (*Db) Init

func (e *Db) Init()

func (*Db) ListTables

func (e *Db) ListTables(ctx context.Context, req *db_pb.ListTablesRequest) (*db_pb.ListTablesResponse, error)

func (*Db) Read

func (e *Db) Read(ctx context.Context, req *db_pb.ReadRequest) (*db_pb.ReadResponse, error)

func (*Db) RenameTable

func (e *Db) RenameTable(ctx context.Context, req *db_pb.RenameTableRequest) (*db_pb.RenameTableResponse, error)

func (*Db) Truncate

func (e *Db) Truncate(ctx context.Context, req *db_pb.TruncateRequest) (*db_pb.TruncateResponse, error)

func (*Db) Update

func (e *Db) Update(ctx context.Context, req *db_pb.UpdateRequest) (*db_pb.UpdateResponse, error)

type Query

type Query struct {
	Field string
	Op    int
	Value interface{}
}

func Parse

func Parse(q string) ([]Query, error)

type Record

type Record struct {
	ID   string
	Data datatypes.JSON `json:"data"`

	CreatedAt time.Time
	UpdatedAt time.Time
	// contains filtered or unexported fields
}