Versions in this module Expand all Collapse all v1 v1.1.0 Apr 23, 2026 v1.0.0 Jan 20, 2026 Changes in this version + func NewPublish[T any](topic TopicKey[T]) func(ctx context.Context, payload T) + func Subscribe[T any](topic TopicKey[T], handler func(ctx context.Context, payload T)) error + type CacheCompleted interface + ChunkCount func() int + ChunkSize func() uint64 + ContentLength func() int64 + Kind func() Kind + LastModified func() string + ReportRatio func() int + StoreKey func() string + StorePath func() string + StoreUrl func() string + type Kind string + const CacheCompletedKey + type TopicKey interface + Name func() Kind + func NewTopicKey[T any](name Kind) TopicKey[T]
Go to main page