resource

Documentation

Index

• 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) ([]byte, error)
  • func (f *FileVehicle) Type() types.VehicleType
• 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) ([]byte, error)
  • func (h *HTTPVehicle) Type() types.VehicleType
  • func (h *HTTPVehicle) Url() string
• type Parser

Types

type Fetcher

type Fetcher[V any] struct {
	OnUpdate func(V)
	// 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) ([]byte, error)

func (*FileVehicle) Type

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

type HTTPVehicle

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

func NewHTTPVehicle

func NewHTTPVehicle(url string, path string, proxy string, header http.Header) *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) ([]byte, error)

func (*HTTPVehicle) Type

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

func (*HTTPVehicle) Url

func (h *HTTPVehicle) Url() string

type Parser

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