pathway

README

pathway

Documentation

Index

• func BroadcastWriter(writers ...io.Writer) io.WriteCloser
• func PathHandler(w http.ResponseWriter, r *http.Request)
• type Queue
• type Transfer
  • func NewTransfer(contentlength string) (transfer Transfer, writer io.WriteCloser)

Functions

func BroadcastWriter

func BroadcastWriter(writers ...io.Writer) io.WriteCloser

BroadcastWriter creates a writer that duplicates its writes to all the provided writers, similar to the Unix tee(1) command.

Each write is written to each listed writer, one at a time. If a listed writer returns an error, that overall write operation continues and the offending writer is dropped from the list.

Only if all writers are dropped, the last error is returned at the end.

func PathHandler

func PathHandler(w http.ResponseWriter, r *http.Request)

Types

type Queue

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

Queue is where posts and gets can exchange transfers

type Transfer

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

Transfer holds a single tranferable connection to be read

func NewTransfer

func NewTransfer(contentlength string) (transfer Transfer, writer io.WriteCloser)

NewTransfer returns a ready to use Transfer and it's writer