apt

Documentation

Index

• type Message
  • func (m *Message) Get(key string) string
  • func (m *Message) String() string
• type MessageReader
  • func NewAptMessageReader(r *bufio.Reader) *MessageReader
  • func (r *MessageReader) ReadMessage(ctx context.Context) (*Message, error)
• type MessageWriter
  • func NewAptMessageWriter(w io.Writer) *MessageWriter
  • func (w *MessageWriter) Fail(msg string) error
  • func (w *MessageWriter) FailURI(uri, msg string) error
  • func (w *MessageWriter) Log(msg string) error
  • func (w *MessageWriter) SendCapabilities() error
  • func (w *MessageWriter) URIDone(uri, size, lastModified, md5Hash, filename string, ims bool) error
  • func (w *MessageWriter) URIStart(uri, size, lastModified string) error
  • func (w *MessageWriter) WriteMessage(m Message) error
• type Method
  • func NewAptMethod(input *bufio.Reader, output io.Writer) *Method
  • func (m *Method) Run(ctx context.Context)

Types

type Message

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

Message represents a single RFC822 Apt message.

func (*Message) Get

func (m *Message) Get(key string) string

Get returns the first AptMessage Field for `key`, or "".

func (*Message) String

func (m *Message) String() string

type MessageReader

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

MessageReader supports reading Apt messages.

func NewAptMessageReader

func NewAptMessageReader(r *bufio.Reader) *MessageReader

NewAptMessageReader returns an AptMessageReader.

func (*MessageReader) ReadMessage

func (r *MessageReader) ReadMessage(ctx context.Context) (*Message, error)

ReadMessage reads lines from `reader` until a complete message is received.

type MessageWriter

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

MessageWriter supports writing Apt messages.

func NewAptMessageWriter

func NewAptMessageWriter(w io.Writer) *MessageWriter

NewAptMessageWriter returns an AptMessageWriter.

func (*MessageWriter) Fail

func (w *MessageWriter) Fail(msg string) error

Fail writes a 401 General Failure message.

func (*MessageWriter) FailURI

func (w *MessageWriter) FailURI(uri, msg string) error

FailURI writes a 400 URI Failure message.

func (*MessageWriter) Log

func (w *MessageWriter) Log(msg string) error

Log writes a 101 Log message.

func (*MessageWriter) SendCapabilities

func (w *MessageWriter) SendCapabilities() error

SendCapabilities writes a 100 Capabilities message.

func (*MessageWriter) URIDone

func (w *MessageWriter) URIDone(uri, size, lastModified, md5Hash, filename string, ims bool) error

URIDone writes a 201 URI Done message.

func (*MessageWriter) URIStart

func (w *MessageWriter) URIStart(uri, size, lastModified string) error

URIStart writes a 200 URI Start message.

func (*MessageWriter) WriteMessage

func (w *MessageWriter) WriteMessage(m Message) error

WriteMessage writes an AptMessage.

type Method

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

Method represents the method handler.

func NewAptMethod

func NewAptMethod(input *bufio.Reader, output io.Writer) *Method

NewAptMethod returns an AptMethod.

func (*Method) Run

func (m *Method) Run(ctx context.Context)

Run runs the method.