reclient

Documentation

Index

• type Handler
• type Jobctx
  • func (j *Jobctx) Data() []byte
  • func (j *Jobctx) GetBindings() any
  • func (j *Jobctx) RootBindings() any
• type Options
• type ReBindx
  • func NewReBindx(port string, btype string) *ReBindx
  • func (r *ReBindx) InLinks() ([]bindx.Link, error)
  • func (r *ReBindx) Log(msg string)
  • func (r *ReBindx) OutLinks() ([]bindx.Link, error)
• type ReRouter
  • func New(opts Options) *ReRouter
  • func (r *ReRouter) Close() error
  • func (r *ReRouter) Init() error
  • func (r *ReRouter) Register(name string, handler Handler)

Types

type Handler

type Handler func(ctx Jobctx) (any, error)

type Jobctx

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

func (*Jobctx) Data

func (j *Jobctx) Data() []byte

func (*Jobctx) GetBindings

func (j *Jobctx) GetBindings() any

func (*Jobctx) RootBindings

func (j *Jobctx) RootBindings() any

type Options

type Options struct {
	Port     string
	Token    string
	AgentId  string
	PlugId   string
	TenantId string
}

type ReBindx

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

func NewReBindx

func NewReBindx(port string, btype string) *ReBindx

func (*ReBindx) InLinks

func (r *ReBindx) InLinks() ([]bindx.Link, error)

func (*ReBindx) Log

func (r *ReBindx) Log(msg string)

func (*ReBindx) OutLinks

func (r *ReBindx) OutLinks() ([]bindx.Link, error)

type ReRouter

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

func New

func New(opts Options) *ReRouter

func (*ReRouter) Close

func (r *ReRouter) Close() error

func (*ReRouter) Init

func (r *ReRouter) Init() error

func (*ReRouter) Register

func (r *ReRouter) Register(name string, handler Handler)