internal

type CredentialGetter func(host string) (string, string, error)

type Executor func(ctx context.Context, name string, args ...string) error

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

type FTPFetcher struct{}

type Fetcher interface {
	// Fetch the file at url to dest. They file will exist at dest unless err is non-nil.
	Fetch(url string, dst io.Writer) error
	// FetchContext is the same as Fetch but takes a context to potentially cancel the fetch.
	FetchContext(ctx context.Context, url string, dst io.Writer) error
}

type FetcherFactory func(url string) Fetcher

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

type Integrity struct {
	Method string `json:"method"`
	Value  string `json:"value"`
}

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

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

type MQTTReceiverOpt func(*MQTTReceiver)

type Message struct {
	Topic    string
	Received time.Time
	Source   string
	Payload  WISMessage
}

type ReceiveError struct {
	Topic string
	Body  []byte
	Err   error
}

type Receiver interface {
	Err() error
	Next() bool
	Message() *Message
}

type Repo interface {
	Store(topic, src string) (string, error)
	Get(topic, name string) (*os.File, error)
	Exists(topic, name string) (bool, error)
}

type TopicsError struct {
	Failed []string
}

type WISMessage struct {
	PubTime   *time.Time `json:"pubTime"`
	BaseURL   string     `json:"baseUrl"`
	RelPath   string     `json:"relPath"`
	Integrity Integrity  `json:"integrity"`
	Size      int64      `json:"size"`
	RetPath   string     `json:"retPath"`
}