broker

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

type DeltaProvider func(ch channels.Name) bool

type Options struct {
	// HistorySize bounds how many publications are retained per channel for
	// late-subscriber replay. Default 100.
	HistorySize int
	// PublicHistoryTTL is how long public history is kept. Default 5m.
	PublicHistoryTTL time.Duration
	// PrivateHistoryTTL is the same for private channels. Default 5m.
	PrivateHistoryTTL time.Duration
	// LogHandler receives broker-level log events. Optional.
	LogHandler centrifuge.LogHandler
	// SubscribeAuthorizer is consulted on every subscribe attempt. Default
	// authorizer allows any well-formed public channel and rejects all
	// private channels (callers must provide their own authorizer for
	// private access).
	SubscribeAuthorizer SubscribeAuthorizer
	// DeltaProvider, when non-nil, lets the broker negotiate fossil-delta
	// encoding per channel at subscribe time. Returns true to enable
	// delta on that subscription.
	DeltaProvider DeltaProvider
	// RedisShards turn the broker into a Redis-backed broker shared with
	// any other Parsec node configured against the same shards. Empty
	// means in-memory single-node mode. Pre-built via centrifuge.NewRedisShard.
	RedisShards []*centrifuge.RedisShard
	// RedisBrokerPrefix overrides the default centrifuge key prefix
	// ("parsec"). Only used when RedisShards is non-empty.
	RedisBrokerPrefix string
	// OnSubscriberChange, when non-nil, is invoked once per subscribe
	// and once per unsubscribe with the channel's parsed name and the
	// signed delta (+1 / -1). Used by the metrics layer to keep a live
	// subscriber gauge by visibility without leaking channel names.
	OnSubscriberChange func(ch channels.Name, delta int)
}

type PublishResult struct {
	Offset uint64
	Epoch  string
}

type SubscribeAuthorizer func(ctx context.Context, userID string, ch channels.Name, event centrifuge.SubscribeEvent) error