extensions

Documentation

Index

• func Caller() string
• type ExecutorEx
  • func NewExecutorEx(exec executor.Executor) *ExecutorEx
  • func (s *ExecutorEx) Begin(ctx context.Context) (e error)
  • func (s *ExecutorEx) Close(ctx context.Context, rollback bool) (e error)
  • func (s *ExecutorEx) Commit(ctx context.Context, require bool) (e error)
  • func (s *ExecutorEx) Execute(ctx context.Context, stmt string, params ...interface{}) (ret resultset.Result, e error)
  • func (s *ExecutorEx) Extend(cut aop.PointCut, advice aop.Advice) Extension
  • func (s *ExecutorEx) Ping(ctx context.Context) (ret bool)
  • func (s *ExecutorEx) Query(ctx context.Context, stmt string, params ...interface{}) (ret resultset.Result, e error)
  • func (s *ExecutorEx) Rollback(ctx context.Context, require bool) (e error)
• type Extension
• type SessionEx
  • func NewSessionEx(sess session.Session) *SessionEx
  • func (s *SessionEx) Begin(ctx context.Context) (e error)
  • func (s *SessionEx) Close() (e error)
  • func (s *SessionEx) Commit(ctx context.Context) (e error)
  • func (s *SessionEx) Execute(ctx context.Context, stmt string, params ...interface{}) (ret resultset.Result, e error)
  • func (s *SessionEx) Extend(cut aop.PointCut, advice aop.Advice) Extension
  • func (s *SessionEx) Ping(ctx context.Context) (ret bool)
  • func (s *SessionEx) Query(ctx context.Context, stmt string, params ...interface{}) (ret resultset.Result, e error)
  • func (s *SessionEx) Rollback(ctx context.Context) (e error)

Functions

func Caller

func Caller() string

Types

type ExecutorEx

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

func NewExecutorEx

func NewExecutorEx(exec executor.Executor) *ExecutorEx

func (*ExecutorEx) Begin

func (s *ExecutorEx) Begin(ctx context.Context) (e error)

func (*ExecutorEx) Close

func (s *ExecutorEx) Close(ctx context.Context, rollback bool) (e error)

func (*ExecutorEx) Commit

func (s *ExecutorEx) Commit(ctx context.Context, require bool) (e error)

func (*ExecutorEx) Execute

func (s *ExecutorEx) Execute(ctx context.Context, stmt string, params ...interface{}) (ret resultset.Result, e error)

func (*ExecutorEx) Extend

func (s *ExecutorEx) Extend(cut aop.PointCut, advice aop.Advice) Extension

func (*ExecutorEx) Ping

func (s *ExecutorEx) Ping(ctx context.Context) (ret bool)

func (*ExecutorEx) Query

func (s *ExecutorEx) Query(ctx context.Context, stmt string, params ...interface{}) (ret resultset.Result, e error)

func (*ExecutorEx) Rollback

func (s *ExecutorEx) Rollback(ctx context.Context, require bool) (e error)

type Extension

type Extension interface {
	Extend(cut aop.PointCut, advice aop.Advice) Extension
}

type SessionEx

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

func NewSessionEx

func NewSessionEx(sess session.Session) *SessionEx

func (*SessionEx) Begin

func (s *SessionEx) Begin(ctx context.Context) (e error)

func (*SessionEx) Close

func (s *SessionEx) Close() (e error)

func (*SessionEx) Commit

func (s *SessionEx) Commit(ctx context.Context) (e error)

func (*SessionEx) Execute

func (s *SessionEx) Execute(ctx context.Context, stmt string, params ...interface{}) (ret resultset.Result, e error)

func (*SessionEx) Extend

func (s *SessionEx) Extend(cut aop.PointCut, advice aop.Advice) Extension

func (*SessionEx) Ping

func (s *SessionEx) Ping(ctx context.Context) (ret bool)

func (*SessionEx) Query

func (s *SessionEx) Query(ctx context.Context, stmt string, params ...interface{}) (ret resultset.Result, e error)

func (*SessionEx) Rollback

func (s *SessionEx) Rollback(ctx context.Context) (e error)