stream

Documentation

Index

• Constants
• type CommandFrame
• type CommandID
  • func (self CommandID) String() string
• type DataFrame
• type Frame
  • func (self Frame) IsCommandFrame() bool
  • func (self Frame) IsDataFrame() bool
• type MailerFrameLayer
  • func NewFrameLayer() *MailerFrameLayer
• type MailerStream
  • func NewMailerStream() *MailerStream
  • func (self *MailerStream) CloseSession() error
  • func (self *MailerStream) OpenSession(remoteSystem string) error
  • func (self *MailerStream) WriteAddress(addr string) error
  • func (self *MailerStream) WriteCommandPacket(commandID CommandID, msgBody []byte) error
  • func (self *MailerStream) WriteComment(comment string) error
  • func (self *MailerStream) WriteData(chunk []byte) error
  • func (self *MailerStream) WriteHeader(stat string) error
  • func (self *MailerStream) WriteInfo(name string, value string) error
  • func (self *MailerStream) WritePassword(password string) error

Constants

const (
	FrameCommandMask uint16 = 0x08000
	FrameSizeMask    uint16 = 0x07FFF
)

Types

type CommandFrame

type CommandFrame struct {
	CommandID CommandID /* Command ID  */
	Body      []byte
}

type CommandID

type CommandID byte

const (
	M_NUL  CommandID = 0
	M_ADR  CommandID = 1
	M_PWD  CommandID = 2
	M_FILE CommandID = 3
	M_OK   CommandID = 4
	M_EOB  CommandID = 5
	M_GOT  CommandID = 6
	M_ERR  CommandID = 7
	M_BSY  CommandID = 8
	M_GET  CommandID = 9
	M_SKIP CommandID = 10
)

func (CommandID) String

func (self CommandID) String() string

type DataFrame

type DataFrame struct {
	Body []byte
}

type Frame

type Frame struct {
	Command bool
	DataFrame
	CommandFrame
}

func (Frame) IsCommandFrame

func (self Frame) IsCommandFrame() bool

func (Frame) IsDataFrame

func (self Frame) IsDataFrame() bool

type MailerFrameLayer

type MailerFrameLayer struct {
}

func NewFrameLayer

func NewFrameLayer() *MailerFrameLayer

type MailerStream

type MailerStream struct {
	InFrameReady  chan interface{}
	OutFrameReady chan interface{}

	InFrame  chan Frame
	OutFrame chan Frame
	// contains filtered or unexported fields
}

func NewMailerStream

func NewMailerStream() *MailerStream

func (*MailerStream) CloseSession

func (self *MailerStream) CloseSession() error

func (*MailerStream) OpenSession

func (self *MailerStream) OpenSession(remoteSystem string) error

func (*MailerStream) WriteAddress

func (self *MailerStream) WriteAddress(addr string) error

func (*MailerStream) WriteCommandPacket

func (self *MailerStream) WriteCommandPacket(commandID CommandID, msgBody []byte) error

func (*MailerStream) WriteComment

func (self *MailerStream) WriteComment(comment string) error

func (*MailerStream) WriteData

func (self *MailerStream) WriteData(chunk []byte) error

func (*MailerStream) WriteHeader

func (self *MailerStream) WriteHeader(stat string) error

func (*MailerStream) WriteInfo

func (self *MailerStream) WriteInfo(name string, value string) error

func (*MailerStream) WritePassword

func (self *MailerStream) WritePassword(password string) error