dapr

Documentation

Index

• type Invoker
  • func NewInvoker(invokeAPI *invoke.API, prefix string) *Invoker
  • func (d *Invoker) AddHeader(k, v string) *Invoker
  • func (d *Invoker) BodyJSON(body any) *Invoker
  • func (d *Invoker) BodyRaw(body any) *Invoker
  • func (d *Invoker) Bytes(bs *[]byte) *Invoker
  • func (d *Invoker) Delete(methodName string, args ...any) *Invoker
  • func (d *Invoker) FormField(k, v string) *Invoker
  • func (d *Invoker) FormFile(k string, fhs ...*multipart.FileHeader) *Invoker
  • func (d *Invoker) Get(methodName string, args ...any) *Invoker
  • func (d *Invoker) OK() error
  • func (d *Invoker) Post(methodName string, args ...any) *Invoker
  • func (d *Invoker) Put(methodName string, args ...any) *Invoker
  • func (d *Invoker) Query(k, v string) *Invoker
  • func (d *Invoker) QueryBool(k string, b bool) *Invoker
  • func (d *Invoker) QueryFloat(k string, v float64) *Invoker
  • func (d *Invoker) QueryInt(k string, v int) *Invoker
  • func (d *Invoker) QueryObj(o any) *Invoker
  • func (d *Invoker) QueryPBool(k string, b *bool) *Invoker
  • func (d *Invoker) RespJSON(resp any) *Invoker
• type Pub
  • func NewPub(port int, timeoutSec int64, pubSub string, topic string) *Pub
  • func (pub *Pub) JSON(o interface{}) *Pub
  • func (pub *Pub) OK() error
  • func (pub *Pub) Pub() *Pub
  • func (pub *Pub) Query(k string, v string) *Pub
  • func (pub *Pub) Text(s string) *Pub

Types

type Invoker

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

func NewInvoker

func NewInvoker(invokeAPI *invoke.API, prefix string) *Invoker

func (*Invoker) AddHeader

func (d *Invoker) AddHeader(k, v string) *Invoker

func (*Invoker) BodyJSON

func (d *Invoker) BodyJSON(body any) *Invoker

func (*Invoker) BodyRaw

func (d *Invoker) BodyRaw(body any) *Invoker

func (*Invoker) Bytes

func (d *Invoker) Bytes(bs *[]byte) *Invoker

func (*Invoker) Delete

func (d *Invoker) Delete(methodName string, args ...any) *Invoker

func (*Invoker) FormField

func (d *Invoker) FormField(k, v string) *Invoker

func (*Invoker) FormFile

func (d *Invoker) FormFile(k string, fhs ...*multipart.FileHeader) *Invoker

func (*Invoker) Get

func (d *Invoker) Get(methodName string, args ...any) *Invoker

func (*Invoker) OK

func (d *Invoker) OK() error

OK 释放资源，获取错误

func (*Invoker) Post

func (d *Invoker) Post(methodName string, args ...any) *Invoker

func (*Invoker) Put

func (d *Invoker) Put(methodName string, args ...any) *Invoker

func (*Invoker) Query

func (d *Invoker) Query(k, v string) *Invoker

func (*Invoker) QueryBool

func (d *Invoker) QueryBool(k string, b bool) *Invoker

func (*Invoker) QueryFloat

func (d *Invoker) QueryFloat(k string, v float64) *Invoker

func (*Invoker) QueryInt

func (d *Invoker) QueryInt(k string, v int) *Invoker

func (*Invoker) QueryObj

func (d *Invoker) QueryObj(o any) *Invoker

func (*Invoker) QueryPBool

func (d *Invoker) QueryPBool(k string, b *bool) *Invoker

func (*Invoker) RespJSON

func (d *Invoker) RespJSON(resp any) *Invoker

type Pub

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

func NewPub

func NewPub(port int, timeoutSec int64, pubSub string, topic string) *Pub

func (*Pub) JSON

func (pub *Pub) JSON(o interface{}) *Pub

func (*Pub) OK

func (pub *Pub) OK() error

func (*Pub) Pub

func (pub *Pub) Pub() *Pub

func (*Pub) Query

func (pub *Pub) Query(k string, v string) *Pub

func (*Pub) Text

func (pub *Pub) Text(s string) *Pub