autonats

Nov 5, 2020

Changes in this version

type Method

+ Timeout int

type ParserConfig

+ DefaultConcurrency int

+ Tracing bool

Oct 11, 2020

Changes in this version

+ func PutReply(reply *Reply)

+ type Method struct

+ HandlerConcurrency int

+ Name string

+ Params []*Param

+ Results []*Param

+ func MethodFromField(field *ast.Field) *Method

type RenderData

+ JsonLib string

+ Tracing bool

type Reply

+ func GetReply() *Reply

+ func (r *Reply) GetDataAsString() string

+ func (r *Reply) GetError() error

+ func (r *Reply) MarshalAndSetData(data interface{}) error

+ func (r *Reply) MarshalBinary() ([]byte, error)

+ func (r *Reply) Reset()

+ func (r *Reply) SetData(data []byte)

+ func (r *Reply) UnmarshalBinary(data []byte) error

+ func (r *Reply) UnmarshalData(vPtr interface{}) error

+ func (r *Reply) WriteString(data string)

Oct 2, 2020

Changes in this version

+ const DocPrefix

+ const ENCODER

+ func ParseDir(path string) (map[string]*ast.Package, error)

+ func Render(data *RenderData)

+ func SendRequest(ctx context.Context, nc *nats.EncodedConn, subject string, in, out interface{}) error

+ type Encoder struct

+ func (enc *Encoder) Decode(subject string, data []byte, vPtr interface{}) error

+ func (enc *Encoder) Encode(subject string, v interface{}) ([]byte, error)

+ type Function struct

+ HandlerConcurrency int

+ Name string

+ Params []*Param

+ Results []*Param

+ func FuncFromType(fxField *ast.Field) *Function

+ type Handler interface

+ Run func(ctx context.Context) error

+ Shutdown func()

+ type Package struct

+ BaseDir string

+ FileName string

+ Imports map[string]string

+ Name string

+ OriginFileName string

+ Services []*Service

+ func PackageFromService(svc *Service) *Package

+ func (pkg *Package) AddService(service *Service)

+ type Param struct

+ Array bool

+ Name string

+ Pointer bool

+ RequiredImports map[string]bool

+ Type string

+ TypePackage string

+ func ParseParam(f *ast.Field) *Param

type Parser

+ func (par *Parser) AddRawPackages(packages map[string]*ast.Package)

+ func (par *Parser) ParseDir(path string) error

+ func (par *Parser) Render(outfile string, timeout int)

type ParserConfig

+ DefaultTimeout int

+ OutputFileName string

+ type RenderData struct

+ FileName string

+ Imports []string

+ PackageName string

+ Path string

+ Services []*Service

+ Timeout int

+ type Reply struct

+ Data []byte

+ Error []byte

+ type Runner struct

+ func StartRunner(ctx context.Context, nc *nats.Conn, subj, group string, concurrency int, ...) (*Runner, error)

+ func (r *Runner) Shutdown() error

+ type Service struct

+ Basedir string

+ FileName string

+ Imports map[string]string

+ InterfaceID string

+ Methods []*Function

+ Name string

+ PackageName string

+ func ServicesFromFile(pkgName, fileName string, file *ast.File) []*Service

+ func ServicesFromPkg(v *ast.Package) []*Service

+ type ServiceConfig struct

+ Name string

+ Timeout time.Duration

+ func ServiceConfigFromDoc(doc *ast.CommentGroup) ServiceConfig

Nov 14, 2019

Changes in this version

+ type Logger interface

+ Printf func(format string, v ...interface{})

+ type Parser struct

+ func NewParser(config *ParserConfig) (p *Parser, err error)

+ func (p *Parser) Run()

+ type ParserConfig struct

+ BaseDir string

+ NatsTimeout int

+ OutFileName string

+ type Request struct

+ Data []byte

+ Error error

+ Subject string