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 + var ErrNotAuthorized = errors.New("not authorized") + type ClientInfo struct + Blacklisted bool + Cached bool + ID common.ClientID + Key crypto.PublicKey + Labels []*fspb.Label + type Communicator interface + Setup func(Context) error + Start func() error + Stop func() + type ConnectionInfo struct + Addr net.Addr + AuthClientInfo authorizer.ClientInfo + Client ClientInfo + ContactID db.ContactID + Fin func() + NonceReceived uint64 + NonceSent uint64 + Notices <-chan struct{} + func (i *ConnectionInfo) AddMessageTokens(delta map[string]uint64) + func (i *ConnectionInfo) MessageTokens() map[string]uint64 + func (i *ConnectionInfo) SubtractMessageTokens(delta map[string]uint64) + type Context interface + Authorizer func() authorizer.Authorizer + GetMessagesForClient func(ctx context.Context, info *ConnectionInfo) (data *fspb.ContactData, more bool, err error) + HandleMessagesFromClient func(ctx context.Context, info *ConnectionInfo, wcd *fspb.WrappedContactData) error + InitializeConnection func(ctx context.Context, addr net.Addr, key crypto.PublicKey, ...) (i *ConnectionInfo, d *fspb.ContactData, more bool, err error) + IsNotFound func(err error) bool + ReadFile func(ctx context.Context, service, name string) (data db.ReadSeekerCloser, modtime time.Time, err error) + StatsCollector func() stats.Collector + ValidateMessagesFromClient func(ctx context.Context, info *ConnectionInfo, wcd *fspb.WrappedContactData) (*fspb.ValidationInfo, error)