mutual

Documentation

Index

• type DuplexChan
  • func NewDuplexChan(reqSize int, respSize int, reqType any, respType any) DuplexChan
  • func (c *DuplexChan) Clean()
  • func (c *DuplexChan) IsReqType(msg any) bool
  • func (c *DuplexChan) IsRespType(msg any) bool
  • func (c *DuplexChan) ReqReceive(duration time.Duration) (any, error)
  • func (c *DuplexChan) ReqSend(msg any, duration time.Duration) error
  • func (c *DuplexChan) RespReceive(duration time.Duration) (any, error)
  • func (c *DuplexChan) RespSend(msg any, duration time.Duration) error
• type KV

Types

type DuplexChan

type DuplexChan struct {
	Req  chan any
	Resp chan any
	// contains filtered or unexported fields
}

func NewDuplexChan

func NewDuplexChan(reqSize int, respSize int, reqType any, respType any) DuplexChan

func (*DuplexChan) Clean

func (c *DuplexChan) Clean()

func (*DuplexChan) IsReqType

func (c *DuplexChan) IsReqType(msg any) bool

func (*DuplexChan) IsRespType

func (c *DuplexChan) IsRespType(msg any) bool

func (*DuplexChan) ReqReceive

func (c *DuplexChan) ReqReceive(duration time.Duration) (any, error)

func (*DuplexChan) ReqSend

func (c *DuplexChan) ReqSend(msg any, duration time.Duration) error

func (*DuplexChan) RespReceive

func (c *DuplexChan) RespReceive(duration time.Duration) (any, error)

func (*DuplexChan) RespSend

func (c *DuplexChan) RespSend(msg any, duration time.Duration) error

type KV

type KV map[string]interface{}