server

May 5, 2026

Changes in this version

type Feed

+ func (f *Feed) MergeProfilePics(pics map[string][]byte) int

+ func (f *Feed) ProfilePicsBundle() protocol.ProfilePicsBundle

+ func (f *Feed) SetProfilePics(pics map[string][]byte) int

type MediaCache

+ func (c *MediaCache) StoreWithOptions(cacheKey, tag string, content []byte, mimeType, filename string, ...) (protocol.MediaMeta, error)

+ type MediaCacheStoreOptions struct

+ SkipGitHub bool

Apr 30, 2026

Changes in this version

+ var ErrCacheFull = errors.New("no free media channel slot")

+ var ErrTooLarge = errors.New("media file exceeds configured max-size")

+ func DecompressMediaBytes(r io.Reader, compression protocol.MediaCompression) (io.ReadCloser, error)

+ func SetMediaDebugLogs(enabled bool)

type Config

+ DNSMediaCacheTTL int

+ DNSMediaCompression string

+ DNSMediaEnabled bool

+ DNSMediaMaxSize int64

+ FetchInterval time.Duration

+ GitHubRelay GitHubRelayConfig

type Feed

+ func (f *Feed) AfterFetchCycle(ctx context.Context)

+ func (f *Feed) GitHubRelay() *GitHubRelay

+ func (f *Feed) MediaCache() *MediaCache

+ func (f *Feed) SetGitHubRelay(r *GitHubRelay)

+ func (f *Feed) SetMediaCache(c *MediaCache)

+ type GitHubRelay struct

+ func NewGitHubRelay(cfg GitHubRelayConfig, domain, passphrase string) *GitHubRelay

+ func (g *GitHubRelay) Domain() string

+ func (g *GitHubRelay) Flush(ctx context.Context) error

+ func (g *GitHubRelay) Has(size int64, crc uint32) bool

+ func (g *GitHubRelay) MaxBytes() int64

+ func (g *GitHubRelay) PruneStale(ctx context.Context, cutoff time.Time) (int, error)

+ func (g *GitHubRelay) Repo() string

+ func (g *GitHubRelay) Run(ctx context.Context)

+ func (g *GitHubRelay) TTL() time.Duration

+ func (g *GitHubRelay) Touch(size int64, crc uint32)

+ func (g *GitHubRelay) Upload(ctx context.Context, body []byte) error

+ type GitHubRelayConfig struct

+ Branch string

+ Enabled bool

+ MaxBytes int64

+ Repo string

+ StatePath string

+ TTLMinutes int

+ Token string

+ func (g GitHubRelayConfig) Active() bool

+ type MediaCache struct

+ func NewMediaCache(cfg MediaCacheConfig) *MediaCache

+ func (c *MediaCache) GetBlock(channel, block uint16) ([]byte, error)

+ func (c *MediaCache) Lookup(cacheKey string) (protocol.MediaMeta, bool)

+ func (c *MediaCache) LookupByChannel(channel uint16) (mime, filename string, ok bool)

+ func (c *MediaCache) MaxAcceptableBytes() int64

+ func (c *MediaCache) SetGitHubRelay(g *GitHubRelay)

+ func (c *MediaCache) Stats() MediaCacheStats

+ func (c *MediaCache) Store(cacheKey, tag string, content []byte, mimeType, filename string) (protocol.MediaMeta, error)

+ func (c *MediaCache) Sweep() int

+ func (c *MediaCache) TouchRelayEntries()

+ type MediaCacheConfig struct

+ Compression protocol.MediaCompression

+ DNSRelayEnabled bool

+ Logf func(format string, args ...interface{})

+ MaxFileBytes int64

+ TTL time.Duration

+ type MediaCacheStats struct

+ Bytes int64

+ Entries int64

+ Evictions uint64

+ MaxFileBytes int64

+ Queries uint64

+ StoreHits uint64

+ StoreMisses uint64

+ StoreRejected uint64

+ TTLSeconds int64

type PublicReader

+ func (pr *PublicReader) SetFetchInterval(d time.Duration)

type TelegramReader

+ func (tr *TelegramReader) SetFetchInterval(d time.Duration)

type XPublicReader

+ func (xr *XPublicReader) SetFetchInterval(d time.Duration)

Apr 22, 2026

Changes in this version

type Feed

+ func (f *Feed) SetChannelDisplayName(channelNum int, displayName string)

Apr 13, 2026

Changes in this version

type DNSServer

+ func (s *DNSServer) SetXReader(xr *XPublicReader)

type XPublicReader

+ func (xr *XPublicReader) SetBaseCh(baseCh int)

Apr 12, 2026

Changes in this version

type Config

+ Debug bool

+ XAccountsFile string

+ XRSSInstances string

type DNSServer

+ func (s *DNSServer) AddRefresher(channelCtl channelRefresher)

+ func (s *DNSServer) SetChannelRefresher(channelCtl channelRefresher)

type Feed

+ func (f *Feed) SetLatestVersion(v string)

type PublicReader

+ func (pr *PublicReader) RequestRefresh()

+ func (pr *PublicReader) UpdateChannels(channels []string)

+ type XPublicReader struct

+ func NewXPublicReader(accounts []string, feed *Feed, msgLimit int, baseCh int, instancesCSV string) *XPublicReader

+ func (xr *XPublicReader) RequestRefresh()

+ func (xr *XPublicReader) Run(ctx context.Context) error

+ func (xr *XPublicReader) UpdateChannels(_ []string)

Mar 30, 2026

Changes in this version

+ type Config struct

+ AllowManage bool

+ ChannelsFile string

+ Domain string

+ ListenAddr string

+ MaxPadding int

+ MsgLimit int

+ NoTelegram bool

+ Passphrase string

+ Telegram TelegramConfig

+ type DNSServer struct

+ func NewDNSServer(listenAddr, domain string, feed *Feed, ...) *DNSServer

+ func (s *DNSServer) ListenAndServe(ctx context.Context) error

+ type Feed struct

+ func NewFeed(channels []string) *Feed

+ func (f *Feed) ChannelNames() []string

+ func (f *Feed) GetBlock(channel, block int) ([]byte, error)

+ func (f *Feed) IsPrivateChannel(channelNum int) bool

+ func (f *Feed) SetChannels(channels []string)

+ func (f *Feed) SetChatInfo(channelNum int, chatType protocol.ChatType, canSend bool)

+ func (f *Feed) SetNextFetch(ts uint32)

+ func (f *Feed) SetTelegramLoggedIn(loggedIn bool)

+ func (f *Feed) UpdateChannel(channelNum int, msgs []protocol.Message)

+ type PublicReader struct

+ func NewPublicReader(channelUsernames []string, feed *Feed, msgLimit int) *PublicReader

+ func (pr *PublicReader) Run(ctx context.Context) error

+ type Server struct

+ func New(cfg Config) (*Server, error)

+ func (s *Server) Run(ctx context.Context) error

+ type TelegramConfig struct

+ APIHash string

+ APIID int

+ CodePrompt func(ctx context.Context) (string, error)

+ LoginOnly bool

+ Password string

+ Phone string

+ SessionPath string

+ type TelegramReader struct

+ func NewTelegramReader(cfg TelegramConfig, channelUsernames []string, feed *Feed, msgLimit int) *TelegramReader

+ func (tr *TelegramReader) RequestRefresh()

+ func (tr *TelegramReader) Run(ctx context.Context) error

+ func (tr *TelegramReader) SendMessage(ctx context.Context, channelNum int, text string) error

+ func (tr *TelegramReader) UpdateChannels(channels []string)