resource

Documentation

Index

• Constants
• func ETag() bool
• func SetETag(b bool)
• type Fetcher
  • func NewFetcher[V any](name string, interval time.Duration, vehicle types.Vehicle, parser Parser[V], ...) *Fetcher[V]
  • func (f *Fetcher[V]) Close() error
  • func (f *Fetcher[V]) Initial() (V, error)
  • func (f *Fetcher[V]) Name() string
  • func (f *Fetcher[V]) SideUpdate(buf []byte) (V, bool, error)
  • func (f *Fetcher[V]) Update() (V, bool, error)
  • func (f *Fetcher[V]) UpdatedAt() time.Time
  • func (f *Fetcher[V]) Vehicle() types.Vehicle
  • func (f *Fetcher[V]) VehicleType() types.VehicleType
• type FileVehicle
  • func NewFileVehicle(path string) *FileVehicle
  • func (f *FileVehicle) Path() string
  • func (f *FileVehicle) Proxy() string
  • func (f *FileVehicle) Read(ctx context.Context, oldHash utils.HashType) (buf []byte, hash utils.HashType, err error)
  • func (f *FileVehicle) Type() types.VehicleType
  • func (f *FileVehicle) Url() string
  • func (f *FileVehicle) Write(buf []byte) error
• type HTTPVehicle
  • func NewHTTPVehicle(url string, path string, proxy string, header http.Header, ...) *HTTPVehicle
  • func (h *HTTPVehicle) Path() string
  • func (h *HTTPVehicle) Proxy() string
  • func (h *HTTPVehicle) Read(ctx context.Context, oldHash utils.HashType) (buf []byte, hash utils.HashType, err error)
  • func (h *HTTPVehicle) SetProvider(provider types.ProxyProvider)
  • func (h *HTTPVehicle) Type() types.VehicleType
  • func (h *HTTPVehicle) Url() string
  • func (h *HTTPVehicle) Write(buf []byte) error
• type Parser

Constants

const (
	DefaultHttpTimeout = time.Second * 20
)

Functions

func ETag

func ETag() bool

func SetETag

func SetETag(b bool)

Types

type Fetcher

type Fetcher[V any] struct {
	// contains filtered or unexported fields
}

func NewFetcher

func NewFetcher[V any](name string, interval time.Duration, vehicle types.Vehicle, parser Parser[V], onUpdate func(V)) *Fetcher[V]

func (*Fetcher[V]) Close

func (f *Fetcher[V]) Close() error

func (*Fetcher[V]) Initial

func (f *Fetcher[V]) Initial() (V, error)

func (*Fetcher[V]) Name

func (f *Fetcher[V]) Name() string

func (*Fetcher[V]) SideUpdate

func (f *Fetcher[V]) SideUpdate(buf []byte) (V, bool, error)

func (*Fetcher[V]) Update

func (f *Fetcher[V]) Update() (V, bool, error)

func (*Fetcher[V]) UpdatedAt

func (f *Fetcher[V]) UpdatedAt() time.Time

func (*Fetcher[V]) Vehicle

func (f *Fetcher[V]) Vehicle() types.Vehicle

func (*Fetcher[V]) VehicleType

func (f *Fetcher[V]) VehicleType() types.VehicleType

type FileVehicle

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

func NewFileVehicle

func NewFileVehicle(path string) *FileVehicle

func (*FileVehicle) Path

func (f *FileVehicle) Path() string

func (*FileVehicle) Proxy

func (f *FileVehicle) Proxy() string

func (*FileVehicle) Read

func (f *FileVehicle) Read(ctx context.Context, oldHash utils.HashType) (buf []byte, hash utils.HashType, err error)

func (*FileVehicle) Type

func (f *FileVehicle) Type() types.VehicleType

func (*FileVehicle) Url

func (f *FileVehicle) Url() string

func (*FileVehicle) Write

func (f *FileVehicle) Write(buf []byte) error

type HTTPVehicle

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

func NewHTTPVehicle

func NewHTTPVehicle(url string, path string, proxy string, header http.Header, timeout time.Duration, sizeLimit int64) *HTTPVehicle

func (*HTTPVehicle) Path

func (h *HTTPVehicle) Path() string

func (*HTTPVehicle) Proxy

func (h *HTTPVehicle) Proxy() string

func (*HTTPVehicle) Read

func (h *HTTPVehicle) Read(ctx context.Context, oldHash utils.HashType) (buf []byte, hash utils.HashType, err error)

func (*HTTPVehicle) SetProvider

func (h *HTTPVehicle) SetProvider(provider types.ProxyProvider)

func (*HTTPVehicle) Type

func (h *HTTPVehicle) Type() types.VehicleType

func (*HTTPVehicle) Url

func (h *HTTPVehicle) Url() string

func (*HTTPVehicle) Write

func (h *HTTPVehicle) Write(buf []byte) error

type Parser

type Parser[V any] func([]byte) (V, error)