controller

Documentation

Index

• func RunProc2(ctx *gin.Context, st StatementInterface, r interface{}, rsp interface{}, ...) error
• type AppParamInterface
• type BaseProc
  • func (b *BaseProc) Next(r *Context)
• type BaseStatement
  • func (b *BaseStatement) Error() error
  • func (b *BaseStatement) OrgRequest() interface{}
  • func (b *BaseStatement) OrgResponse() interface{}
  • func (b *BaseStatement) SetError(err error)
  • func (b *BaseStatement) SetOrgRequest(r interface{})
  • func (b *BaseStatement) SetOrgResponse(rsp interface{})
• type ClaimsImpl
  • func (c *ClaimsImpl) GetClaims(v interface{}) interface{}
  • func (c *ClaimsImpl) SetClaims(v interface{}, claims interface{}) error
• type ClaimsParamInterface
• type Context
  • func NewContext() *Context
  • func (*Context) Deadline() (deadline time.Time, ok bool)
  • func (*Context) Done() <-chan struct{}
  • func (*Context) Err() error
  • func (c *Context) String() string
  • func (*Context) Value(key interface{}) interface{}
• type JwtToken
  • func (c *JwtToken) Process()
• type StatementAppImpl
  • func (b *StatementAppImpl) GetApp(v interface{}) interface{}
  • func (b *StatementAppImpl) SetApp(v interface{}, app *ent.App) error
• type StatementInterface

Functions

func RunProc2

func RunProc2(ctx *gin.Context, st StatementInterface, r interface{}, rsp interface{}, f func() *goflow.Graph) error

Types

type AppParamInterface

type AppParamInterface interface {
	GetApp(v interface{}) interface{}
	SetApp(v interface{}, app *ent.App) error
}

type BaseProc

type BaseProc struct {
	In  <-chan *Context
	Out chan<- *Context
}

func (*BaseProc) Next

func (b *BaseProc) Next(r *Context)

type BaseStatement

type BaseStatement struct {
	Err error
	// contains filtered or unexported fields
}

func (*BaseStatement) Error

func (b *BaseStatement) Error() error

func (*BaseStatement) OrgRequest

func (b *BaseStatement) OrgRequest() interface{}

func (*BaseStatement) OrgResponse

func (b *BaseStatement) OrgResponse() interface{}

func (*BaseStatement) SetError

func (b *BaseStatement) SetError(err error)

func (*BaseStatement) SetOrgRequest

func (b *BaseStatement) SetOrgRequest(r interface{})

func (*BaseStatement) SetOrgResponse

func (b *BaseStatement) SetOrgResponse(rsp interface{})

type ClaimsImpl

type ClaimsImpl struct {
	BaseStatement
}

func (*ClaimsImpl) GetClaims

func (c *ClaimsImpl) GetClaims(v interface{}) interface{}

func (*ClaimsImpl) SetClaims

func (c *ClaimsImpl) SetClaims(v interface{}, claims interface{}) error

type ClaimsParamInterface

type ClaimsParamInterface interface {
	GetClaims(v interface{}) interface{}
	SetClaims(v interface{}, claims interface{}) error
}

type Context

type Context struct {
	AesKey string
	Unique string
	Req    interface{}
	GinCtx *gin.Context

	Headers    http.Header
	AuthedUser *ent.User
}

func NewContext

func NewContext() *Context

func (*Context) Deadline

func (*Context) Deadline() (deadline time.Time, ok bool)

func (*Context) Done

func (*Context) Done() <-chan struct{}

func (*Context) Err

func (*Context) Err() error

func (*Context) String

func (c *Context) String() string

func (*Context) Value

func (*Context) Value(key interface{}) interface{}

type JwtToken

type JwtToken struct {
	BaseProc
}

func (*JwtToken) Process

func (c *JwtToken) Process()

type StatementAppImpl

type StatementAppImpl struct {
	BaseStatement
}

func (*StatementAppImpl) GetApp

func (b *StatementAppImpl) GetApp(v interface{}) interface{}

func (*StatementAppImpl) SetApp

func (b *StatementAppImpl) SetApp(v interface{}, app *ent.App) error

type StatementInterface

type StatementInterface interface {
	Error() error
	SetError(err error)
	SetOrgRequest(r interface{})
	OrgRequest() interface{}
	SetOrgResponse(rsp interface{})
	OrgResponse() interface{}
}