Versions in this module Expand all Collapse all v0 v0.1.14 Apr 23, 2024 v0.1.13 Mar 5, 2024 Changes in this version + type Communicator struct + DialContext func(ctx context.Context, network, addr string) (net.Conn, error) + func (c *Communicator) GetFileIfModified(ctx context.Context, service, name string, modSince time.Time) (io.ReadCloser, time.Time, error) + func (c *Communicator) Setup(cl comms.Context) error + func (c *Communicator) Start() error + func (c *Communicator) Stop() + type StreamingCommunicator struct + DialContext func(ctx context.Context, network, addr string) (net.Conn, error) + func (c *StreamingCommunicator) GetFileIfModified(ctx context.Context, service, name string, modSince time.Time) (io.ReadCloser, time.Time, error) + func (c *StreamingCommunicator) Setup(cl comms.Context) error + func (c *StreamingCommunicator) Start() error + func (c *StreamingCommunicator) Stop()