data

Documentation

Index

• type Message
  • func BinaryMessage(r channel.BinaryReader) (Message, error)
  • func JSONMessage(r io.Reader) (Message, io.Reader, error)
  • func (m Message) Binary(r channel.BinaryWriter) error
  • func (m Message) Equal(msg channel.Msg) bool
  • func (m Message) FromBinary(r channel.BinaryReader) (channel.Msg, error)
  • func (m Message) FromJSON(r io.Reader) (channel.Msg, io.Reader, error)
  • func (m Message) JSON(w io.Writer) error
• type ServerMessage
  • func BinaryServerMessage(r channel.BinaryReader) (ServerMessage, error)
  • func JSONServerMessage(r io.Reader) (ServerMessage, io.Reader, error)
  • func NewNoServerMessage() ServerMessage
  • func NewServerMessage(size int64, sig []byte, r io.Reader) ServerMessage
  • func (m ServerMessage) Binary(w channel.BinaryWriter) error
  • func (m ServerMessage) Close() error
  • func (m ServerMessage) FromBinary(r channel.BinaryReader) (channel.Msg, error)
  • func (m ServerMessage) FromJSON(r io.Reader) (channel.Msg, io.Reader, error)
  • func (m ServerMessage) JSON(w io.Writer) error
  • func (m ServerMessage) Upload() io.Reader

Types

type Message

type Message struct {
	GOOS   string
	GOARCH string

	channel.NoClose
}

func BinaryMessage

func BinaryMessage(r channel.BinaryReader) (Message, error)

func JSONMessage

func JSONMessage(r io.Reader) (Message, io.Reader, error)

func (Message) Binary

func (m Message) Binary(r channel.BinaryWriter) error

func (Message) Equal

func (m Message) Equal(msg channel.Msg) bool

func (Message) FromBinary

func (m Message) FromBinary(r channel.BinaryReader) (channel.Msg, error)

func (Message) FromJSON

func (m Message) FromJSON(r io.Reader) (channel.Msg, io.Reader, error)

func (Message) JSON

func (m Message) JSON(w io.Writer) error

type ServerMessage

type ServerMessage struct {
	Available bool
	Sig       []byte
	Size      int64

	channel.NeverEqual
	// contains filtered or unexported fields
}

func BinaryServerMessage

func BinaryServerMessage(r channel.BinaryReader) (ServerMessage, error)

func JSONServerMessage

func JSONServerMessage(r io.Reader) (ServerMessage, io.Reader, error)

func NewNoServerMessage

func NewNoServerMessage() ServerMessage

func NewServerMessage

func NewServerMessage(size int64, sig []byte, r io.Reader) ServerMessage

func (ServerMessage) Binary

func (m ServerMessage) Binary(w channel.BinaryWriter) error

func (ServerMessage) Close

func (m ServerMessage) Close() error

func (ServerMessage) FromBinary

func (m ServerMessage) FromBinary(r channel.BinaryReader) (channel.Msg, error)

func (ServerMessage) FromJSON

func (m ServerMessage) FromJSON(r io.Reader) (channel.Msg, io.Reader, error)

func (ServerMessage) JSON

func (m ServerMessage) JSON(w io.Writer) error

func (ServerMessage) Upload

func (m ServerMessage) Upload() io.Reader