valve

Documentation

Index

• Constants
• type Stat
  • func (s *Stat) String() string
• type Valve
  • func MakeValve(n int) Valve
• type XValve
  • func (x XValve) Cap() int
  • func (x XValve) Close() error
  • func (x XValve) IsDone() bool
  • func (x XValve) Recv() (circuit.X, error)
  • func (x XValve) Scrub()
  • func (x XValve) Send() (circuit.X, error)
  • func (x XValve) Stat() Stat
• type YValve
  • func (y YValve) Cap() int
  • func (y YValve) Close() error
  • func (y YValve) IsDone() bool
  • func (y YValve) Recv() (_ io.ReadCloser, err error)
  • func (y YValve) Scrub()
  • func (y YValve) Send() (_ io.WriteCloser, err error)
  • func (y YValve) Stat() Stat

Constants

const MessageCap = 32e3 // 32K

Sender-receiver pipe capacity (once matched)

Types

type Stat

type Stat struct {
	Cap     int  `json:"cap"`
	Opened  bool `json:"opened"`
	Closed  bool `json:"closed"`
	Aborted bool `json:"aborted"`
	NumSend int  `json:"numsend"`
	NumRecv int  `json:"numrecv"`
}

func (*Stat) String

func (s *Stat) String() string

type Valve

type Valve interface {
	Send() (io.WriteCloser, error)
	IsDone() bool
	Scrub()
	Close() error
	Recv() (io.ReadCloser, error)
	Cap() int
	Stat() Stat
	X() circuit.X
}

func MakeValve

func MakeValve(n int) Valve

type XValve

type XValve struct {
	Valve Valve
}

func (XValve) Cap

func (x XValve) Cap() int

func (XValve) Close

func (x XValve) Close() error

func (XValve) IsDone

func (x XValve) IsDone() bool

func (XValve) Recv

func (x XValve) Recv() (circuit.X, error)

func (XValve) Scrub

func (x XValve) Scrub()

func (XValve) Send

func (x XValve) Send() (circuit.X, error)

func (XValve) Stat

func (x XValve) Stat() Stat

type YValve

type YValve struct {
	X circuit.X
}

func (YValve) Cap

func (y YValve) Cap() int

func (YValve) Close

func (y YValve) Close() error

func (YValve) IsDone

func (y YValve) IsDone() bool

func (YValve) Recv

func (y YValve) Recv() (_ io.ReadCloser, err error)

func (YValve) Scrub

func (y YValve) Scrub()

func (YValve) Send

func (y YValve) Send() (_ io.WriteCloser, err error)

func (YValve) Stat

func (y YValve) Stat() Stat