executor

Documentation

Index

• type Executor
  • func New(dialect string) *Executor
  • func (e *Executor) Dialect() string
  • func (e *Executor) InputReader(ctx context.Context, conn *sql.Conn) InputReader
  • func (e *Executor) InputWriter(ctx context.Context, conn *sql.Conn) InputWriter
  • func (e *Executor) LogWriter(ctx context.Context, conn *sql.Conn) LogWriter
  • func (e *Executor) SchemaEditor(ctx context.Context, conn *sql.Conn) SchemaEditor
  • func (e *Executor) SchemaReader(ctx context.Context, conn *sql.Conn) SchemaReader
  • func (e *Executor) TemplateEditor(ctx context.Context, conn *sql.Conn) TemplateEditor
  • func (e *Executor) TemplateReader(ctx context.Context, conn *sql.Conn) TemplateReader
  • func (e *Executor) UserManager(ctx context.Context, conn *sql.Conn) UserManager
• type InputReader
• type InputWriter
• type LogWriter
• type SchemaEditor
• type SchemaReader
• type TemplateEditor
• type TemplateReader
• type UserManager

Types

type Executor

type Executor struct {
	// contains filtered or unexported fields
}

Executor TODO issue#173

func New

func New(dialect string) *Executor

New TODO issue#173

func (*Executor) Dialect

func (e *Executor) Dialect() string

Dialect TODO issue#173

func (*Executor) InputReader

func (e *Executor) InputReader(ctx context.Context, conn *sql.Conn) InputReader

InputReader TODO issue#173

func (*Executor) InputWriter

func (e *Executor) InputWriter(ctx context.Context, conn *sql.Conn) InputWriter

InputWriter TODO issue#173

func (*Executor) LogWriter

func (e *Executor) LogWriter(ctx context.Context, conn *sql.Conn) LogWriter

LogWriter TODO issue#173

func (*Executor) SchemaEditor

func (e *Executor) SchemaEditor(ctx context.Context, conn *sql.Conn) SchemaEditor

SchemaEditor TODO issue#173

func (*Executor) SchemaReader

func (e *Executor) SchemaReader(ctx context.Context, conn *sql.Conn) SchemaReader

SchemaReader TODO issue#173 Deprecated: TODO issue#version3.0 use SchemaEditor and gRPC gateway instead

func (*Executor) TemplateEditor

func (e *Executor) TemplateEditor(ctx context.Context, conn *sql.Conn) TemplateEditor

TemplateEditor TODO issue#173

func (*Executor) TemplateReader

func (e *Executor) TemplateReader(ctx context.Context, conn *sql.Conn) TemplateReader

TemplateReader TODO issue#173 Deprecated: TODO issue#version3.0 use TemplateEditor and gRPC gateway instead

func (*Executor) UserManager

func (e *Executor) UserManager(ctx context.Context, conn *sql.Conn) UserManager

UserManager TODO issue#173

type InputReader

type InputReader interface {
	ReadByID(*types.Token, domain.ID) (types.Input, error)
	ReadByFilter(*types.Token, query.InputFilter) ([]types.Input, error)
}

InputReader TODO issue#173

type InputWriter

type InputWriter interface {
	Write(query.WriteInput) (types.Input, error)
}

InputWriter TODO issue#173

type LogWriter

type LogWriter interface {
	Write(query.WriteLog) (types.Event, error)
}

LogWriter TODO issue#173

type SchemaEditor

type SchemaEditor interface {
	Create(*types.Token, query.CreateSchema) (types.Schema, error)
	Read(*types.Token, query.ReadSchema) (types.Schema, error)
	Update(*types.Token, query.UpdateSchema) (types.Schema, error)
	Delete(*types.Token, query.DeleteSchema) (types.Schema, error)
}

SchemaEditor TODO issue#173

type SchemaReader

type SchemaReader interface {
	ReadByID(domain.ID) (types.Schema, error)
}

SchemaReader TODO issue#173 Deprecated: TODO issue#version3.0 use TemplateEditor and gRPC gateway instead

type TemplateEditor

type TemplateEditor interface {
	Create(*types.Token, query.CreateTemplate) (types.Template, error)
	Read(*types.Token, query.ReadTemplate) (types.Template, error)
	Update(*types.Token, query.UpdateTemplate) (types.Template, error)
	Delete(*types.Token, query.DeleteTemplate) (types.Template, error)
}

TemplateEditor TODO issue#173

type TemplateReader

type TemplateReader interface {
	ReadByID(domain.ID) (types.Template, error)
}

TemplateReader TODO issue#173 Deprecated: TODO issue#version3.0 use TemplateEditor and gRPC gateway instead

type UserManager

type UserManager interface {
	Token(domain.ID) (*types.Token, error)
}

UserManager TODO issue#173