fetcher

Documentation

Index

• type HTTP
  • func (h *HTTP) Fetch() (io.Reader, error)
  • func (h *HTTP) Init() error
• type Interface
  • func Func(fn func() (io.Reader, error)) Interface
• type S3
  • func (s *S3) Fetch() (io.Reader, error)
  • func (s *S3) Init() error

Types

type HTTP

type HTTP struct {
	//URL to poll for new binaries
	URL          string
	Interval     time.Duration
	CheckHeaders []string
	// contains filtered or unexported fields
}

HTTPFetcher uses HEAD requests to poll the status of a given file. If it detects this file has been updated, it will fetch and return its io.Reader stream.

func (*HTTP) Fetch

func (h *HTTP) Fetch() (io.Reader, error)

func (*HTTP) Init

func (h *HTTP) Init() error

type Interface

type Interface interface {
	//Init should perform validation on fields. For
	//example, ensure the appropriate URLs or keys
	//are defined or ensure there is connectivity
	//to the appropriate web service.
	Init() error
	//Fetch should check if there is an updated
	//binary to fetch, and then stream it back the
	//form of an io.Reader. If io.Reader is nil,
	//then it is assumed there are no updates. Fetch
	//will be run repeatly and forever. It is up the
	//implementation to throttle the fetch frequency.
	Fetch() (io.Reader, error)
}

func Func

func Func(fn func() (io.Reader, error)) Interface

Converts a fetch function into interface

type S3

type S3 struct {
	Access string
	Secret string
	Region string
	Bucket string
	Key    string
	//interal state
	Interval time.Duration
	// contains filtered or unexported fields
}

S3 uses authenticated HEAD requests to poll the status of a given object. If it detects this file has been updated, it will perform an object GET and return its io.Reader stream.

func (*S3) Fetch

func (s *S3) Fetch() (io.Reader, error)

func (*S3) Init

func (s *S3) Init() error