Versions in this module Expand all Collapse all v0 v0.16.0 May 17, 2026 Changes in this version + type BytesSource struct + func NewBytes(name, contentType string, data []byte) *BytesSource + func (b *BytesSource) Name() string + func (b *BytesSource) Priority() int + func (b *BytesSource) Read(_ context.Context) ([]byte, string, string, error) + func (b *BytesSource) Watch(_ context.Context) (<-chan contracts.Event, error) + func (b *BytesSource) WithPriority(p int) *BytesSource + type FileSource struct + func NewFile(path string) *FileSource + func (f *FileSource) Name() string + func (f *FileSource) Priority() int + func (f *FileSource) Read(_ context.Context) ([]byte, string, string, error) + func (f *FileSource) Watch(_ context.Context) (<-chan contracts.Event, error) + func (f *FileSource) WithPriority(p int) *FileSource + type HTTPSource struct + func NewHTTP(url string) *HTTPSource + func (h *HTTPSource) Name() string + func (h *HTTPSource) Priority() int + func (h *HTTPSource) Read(ctx context.Context) ([]byte, string, string, error) + func (h *HTTPSource) Watch(_ context.Context) (<-chan contracts.Event, error) + func (h *HTTPSource) WithClient(c *http.Client) *HTTPSource + func (h *HTTPSource) WithPriority(p int) *HTTPSource
Go to main page