Versions in this module Expand all Collapse all v0 v0.1.1 Aug 14, 2026 Changes in this version + var ErrInvalidTargetName = errors.New("invalid target name") + var ErrNoWaaTargetConfigured = errors.New("no WAA target configured") + var ErrShouldBeDispatchedElsewhere = errors.New("should be dispatched elsewhere") + var ErrTargetIndexOutOfRange = errors.New("target index out of range") + var ErrTargetNameAlreadyExists = errors.New("target name already exists") + var ErrTargetNameNotFound = errors.New("target name not found") + func Call(w WaaTargetParam, ctx WaaCtx) (error, bool) + type WaaRouter struct + func (r *WaaRouter) AddTarget(name string, host string, port int, timeouts ...int) (error, *WaaTarget) + func (r *WaaRouter) GetTargetIndexByName(name string) int + func (r *WaaRouter) MapPackageToTarget(pkgName string, targetName string) error + func (r *WaaRouter) SetDefaultTarget(name string) error + func (r *WaaRouter) SetPackageVarName(name string) + func (w *WaaRouter) GetWaaTargetParam(ctx WaaCtx) (error, *WaaTarget) + type WaaTarget struct + ConnTimeout int + Host string + Name string + Port int + ReadTimeout int + WriteTimeout int + func (t *WaaTarget) Init(host string, port int, timeouts ...int) + func (w *WaaTarget) GetWaaTargetParam(ctx WaaCtx) (error, *WaaTarget) + type WaaTargetParam interface + GetWaaTargetParam func(ctx WaaCtx) (error, *WaaTarget) v0.1.0 Aug 12, 2026retracted Changes in this version + const CmdAck + const CmdCloseFile + const CmdConnect + const CmdDisconnect + const CmdEmail + const CmdGetAllVars + const CmdGetDocRoot + const CmdGetEnv + const CmdGetScriptName + const CmdGetVar + const CmdNak + const CmdOpenFile + const CmdPut + const CmdPutAllVars + const CmdPutEnv + const CmdPutFileData + const CmdPutVar + const CmdReady + const EolCr + const EolCrLf + const EolLf + func PutMessage(conn io.Writer, cmd int32, data []byte) error + func PutMessageString(conn io.Writer, cmd int32, data string) error + type DirectWaaCtx struct + Body []byte + Emails [][]byte + Env map[string]string + Files map[string]*bytes.Buffer + Header []string + func NewDirectWaaCtx(env map[string]string) *DirectWaaCtx + func (c *DirectWaaCtx) AddValue(name, value string) + func (c *DirectWaaCtx) OnEmail(rfc822data []byte) error + func (c *DirectWaaCtx) OnGetAllVars() []KvEntry + func (c *DirectWaaCtx) OnGetEnv(name string) string + func (c *DirectWaaCtx) OnGetVar(name string) ([]string, bool) + func (c *DirectWaaCtx) OnHeaderLine(line string, lineTerminator int) error + func (c *DirectWaaCtx) OnOpenFile(filename string) (io.WriteCloser, error) + func (c *DirectWaaCtx) OnPutData(data []byte) error + func (c *DirectWaaCtx) SetMethod(method string) + func (c *DirectWaaCtx) SetValue(name, value string) + func (c *DirectWaaCtx) SetValues(name string, values []string) + type KvEntry struct + Key string + Values []string + type Message struct + Cmd int32 + Data []byte + func GetMessage(conn io.Reader) (*Message, error) + func (m *Message) DataString() string + type NullWaaCtx struct + func (NullWaaCtx) OnEmail(rfc822data []byte) error + func (NullWaaCtx) OnEndHeader(lineTerminator int) error + func (NullWaaCtx) OnGetAllVars() []KvEntry + func (NullWaaCtx) OnGetDocRoot() string + func (NullWaaCtx) OnGetEnv(name string) string + func (NullWaaCtx) OnGetScriptName() string + func (NullWaaCtx) OnGetVar(name string) ([]string, bool) + func (NullWaaCtx) OnHeaderLine(line string, lineTerminator int) error + func (NullWaaCtx) OnOpenFile(filename string) (io.WriteCloser, error) + func (NullWaaCtx) OnPutData(data []byte) error + type WaaClient struct + ConnTimeout int + Host string + Port int + ReadTimeout int + WriteTimeout int + func (w *WaaClient) Call(ctx WaaCtx) error + type WaaCtx interface + OnEmail func(rfc822data []byte) error + OnEndHeader func(lineTerminator int) error + OnGetAllVars func() []KvEntry + OnGetDocRoot func() string + OnGetEnv func(name string) string + OnGetScriptName func() string + OnGetVar func(name string) ([]string, bool) + OnHeaderLine func(line string, lineTerminator int) error + OnOpenFile func(filename string) (io.WriteCloser, error) + OnPutData func(data []byte) error