client

Documentation

Index

• type CompositeField
• type Conn
  • func NewConn(cert tls.Certificate) *Conn
  • func (conn *Conn) AsProtoStream() *ProtoStream
  • func (self *Conn) Close() error
  • func (self *Conn) Connect(host string) error
  • func (self *Conn) Receive() (msg tldmsg.Message, err error)
  • func (self *Conn) SendMessage(msg tldmsg.Message) error
• type Post
• type ProtoStream
  • func (self *ProtoStream) Composite(group string, minTime, maxTime time.Time, limit uint64, out *[]CompositeField) *ProtoStream
  • func (self *ProtoStream) Execute() error
  • func (self *ProtoStream) Get(group, id string, out *Post) *ProtoStream
  • func (self *ProtoStream) Head(group, id string, out *map[string]string) *ProtoStream
  • func (self *ProtoStream) Post(headers map[string]string, post string) *ProtoStream
  • func (self *ProtoStream) Read(group string, out **[]string) *ProtoStream

Types

type CompositeField

type CompositeField struct {
	Id          string
	Group       string
	DatePosted  time.Time
	IdInReplyTo string
	ClientId    string
	From        string
	Subject     string
}

type Conn

type Conn struct {
	Conn *tls.Conn
	// contains filtered or unexported fields
}

func NewConn

func NewConn(cert tls.Certificate) *Conn

func (*Conn) AsProtoStream

func (conn *Conn) AsProtoStream() *ProtoStream

func (*Conn) Close

func (self *Conn) Close() error

func (*Conn) Connect

func (self *Conn) Connect(host string) error

func (*Conn) Receive

func (self *Conn) Receive() (msg tldmsg.Message, err error)

func (*Conn) SendMessage

func (self *Conn) SendMessage(msg tldmsg.Message) error

type Post

type Post struct {
	Headers  map[string]string
	Contents []byte
}

type ProtoStream

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

func (*ProtoStream) Composite

func (self *ProtoStream) Composite(group string, minTime, maxTime time.Time, limit uint64, out *[]CompositeField) *ProtoStream

func (*ProtoStream) Execute

func (self *ProtoStream) Execute() error

func (*ProtoStream) Get

func (self *ProtoStream) Get(group, id string, out *Post) *ProtoStream

func (*ProtoStream) Head

func (self *ProtoStream) Head(group, id string, out *map[string]string) *ProtoStream

func (*ProtoStream) Post

func (self *ProtoStream) Post(headers map[string]string, post string) *ProtoStream

func (*ProtoStream) Read

func (self *ProtoStream) Read(group string, out **[]string) *ProtoStream