Help us shape the future of Go! Take the 2026 Go Developer Survey

Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

tp

package module

Go to main page

Versions in this module

v0

v0.4.2

Oct 29, 2026

Changes in this version

type QueuedClient

+ QueueStat func(ctx context.Context, queueID uint16) ([]queuedproto.RespQueueStat, error)

v0.4.1

Sep 28, 2026

Changes in this version

+ const DefaultProducerInstance

+ const MaxVersion

+ const SignalReload

+ var ErrEventTypesDiffer = errors.New("tp.Next: event types differ")

+ var ErrExportedRequired = errors.New("exported (public) field is required for autofill feature")

+ var ErrFieldNotFound = errors.New("no field found")

+ var ErrHardMemoryLimit = errors.New("memory usage is over the hard limit, stopping processing")

+ var ErrInternalHandler = errors.New("internal error: handlerInfo.dataType is not Handler")

+ var ErrMisconstructedEvent = errors.New("tp.Next: misconstructed event")

+ var ErrPointerRequired = errors.New("tp.Next: pointer to Handle method's receiver is required")

+ var ErrStructRequired = errors.New("struct type is required for autofill feature")

+ var ErrUnknownQueue = errors.New("unregistered queue")

+ var ErrUnknownType = errors.New("unregistered type")

+ var ErrUnknownVersion = errors.New("unregistered version")

+ var ErrVersionTooBig = errors.New("version number exceeds MaxVersion")

+ var SignalsExit = [...]os.Signal

+ func CalcShard(eventID uint64, shardNum uint) uint

+ func EncodeEvent(event Event) (eventData []byte, err error)

+ func Register[EvType Event, EvSlice ~[]EvType](q Queue, handler func(context.Context, EvSlice) error) error

+ type BaseEvent struct

+ func NewBaseEvent() BaseEvent

+ func (BaseEvent) AddonID(incompatible)

+ func (BaseEvent) MarshalAddon(incompatible)

+ func (BaseEvent) MarshalIProto(incompatible)

+ func (BaseEvent) MarshalerDisabled(incompatible)

+ func (BaseEvent) UnmarshalAddon(incompatible)

+ func (BaseEvent) UnmarshalIProto(incompatible)

+ func (bev BaseEvent) Defer(ctx context.Context, delay time.Duration) error

+ func (bev BaseEvent) Done()

+ func (bev BaseEvent) GetEventID() queuedproto.EventID

+ func (bev BaseEvent) HasCustomDefer() bool

+ func (bev BaseEvent) IsDone() bool

+ func (bev BaseEvent) Queue() Queue

+ func (bev BaseEvent) Shard(shardNum uint) uint

+ type Builder interface

+ Build func() error

+ type DisableMarshaler struct

+ func (DisableMarshaler) MarshalIProto(buf []byte) ([]byte, error)

+ func (DisableMarshaler) MarshalerDisabled()

+ func (DisableMarshaler) UnmarshalIProto(buf []byte) ([]byte, error)

+ type Event interface

+ Defer func(context.Context, time.Duration) error

+ Done func()

+ GetEventID func() queuedproto.EventID

+ HasCustomDefer func() bool

+ IsDone func() bool

+ Queue func() Queue

+ QueueID func() QueueIDType

+ Shard func(shardNum uint) uint

+ Version func() VersionType

+ type EventIDBuilder interface

+ BuildEventID func() uint64

+ type EventWithCreationTime interface

+ GetCreationTime func() addons.CreationTime

+ type Handler func(context.Context, EvSlice) error

+ func WithMaxAge[EvType EventWithCreationTime, EvSlice ~[]EvType](handler Handler[EvType, EvSlice]) Handler[EvType, EvSlice]

+ func WithRetry2[EvType RetryableEvent2, EvSlice ~[]EvType](handler Handler[EvType, EvSlice], opts ...Retry2Option) Handler[EvType, EvSlice]

+ func WithRetry[EvType RetryableEvent, EvSlice ~[]EvType](handler Handler[EvType, EvSlice], opts ...RetryOption) Handler[EvType, EvSlice]

+ type IgnoreDuplicateItems interface

+ IgnoreDuplicateItems func() bool

+ type InitOption func(*InitOptions)

+ func WithInstanceName(instanceName string) InitOption

+ func WithLogLevelConfig(lc advslog.LevelConfig) InitOption

+ func WithLogger(logger *slog.Logger) InitOption

+ func WithMetrics(ms advmetricsset.Set) InitOption

+ type InitOptions struct

+ type MarshalerDisabled interface

+ MarshalerDisabled func()

+ type Middleware func(Handler[EvType, EvSlice]) Handler[EvType, EvSlice]

+ type Queue interface

+ Client func() QueuedClient

+ Config func() *queueconfig.Config

+ IsRegistered func(queueID uint16) bool

+ MetricsSet func() advmetricsset.Set

+ NewPoller func(logger *slog.Logger) workerpool.Poller

+ Publish func(ctx context.Context, event Event, opts ...queuedclient.PublishOption) (queuedproto.EventID, error)

+ Replace func(ctx context.Context, event Event, opts ...queuedclient.PublishOption) error

+ SetMetricsSet func(advmetricsset.Set)

+ func InitProducer[T queueconfig.OnlineConf](conf queueconfig.OnlineConfWithSubtree[T], opts ...InitOption) Queue

+ func NewQueue(ctx context.Context, conf *queueconfig.Config, opts ...queuedclient.DialOption) (Queue, error)

+ type QueueIDType = uint16

+ type QueuedClient interface

+ Defer func(ctx context.Context, queueID uint16, delay time.Duration, ...) error

+ Delete func(ctx context.Context, queueID uint16, eventIDs []queuedproto.EventID) error

+ GetActive func(ctx context.Context, queueID uint16, count int) (queuedproto.ItemList, error)

+ GetByIDs func(ctx context.Context, queueID uint16, eventIDs []queuedproto.EventID) (queuedproto.ItemList, error)

+ GetByIDsBroadcast func(ctx context.Context, queueID uint16, eventIDs []uint64) (queuedproto.ItemList, error)

+ IsHealthy func() bool

+ IsOnline func() bool

+ MakeBroadcastRequest func(ctx context.Context, req queuedproto.Request, resFunc queuedclient.ResultFunc) error

+ MakeMulticastRequest func(ctx context.Context, batchSize int, eventIDs []queuedproto.EventID, ...) error

+ MakeUnicastRequest func(ctx context.Context, shard uint, req queuedproto.Request) (usedShard uint, respBytes []byte, err error)

+ MetricsSet func() advmetricsset.Set

+ Publish func(ctx context.Context, queueID uint16, eventID queuedproto.EventID, flags uint32, ...) (queuedproto.EventID, error)

+ Replace func(ctx context.Context, queueID uint16, eventID queuedproto.EventID, ...) (bool, error)

+ SetActivationTime func(ctx context.Context, queueID uint16, atime time.Time, ...) error

+ SetMetricsSet func(advmetricsset.Set)

+ ShardNum func() uint

+ type Retry2Option func(*retry2Opt)

+ func OnRetry2Exhausted[T RetryableEvent2](f func(T, string)) Retry2Option

+ func OnRetry2[T RetryableEvent2](f func(T)) Retry2Option

+ func Retry2CounterNames(retry1, retry2 string) Retry2Option

+ type RetryOption func(*retryOpt)

+ func OnRetryExhausted[T RetryableEvent](f func(T)) RetryOption

+ func OnRetry[T RetryableEvent](f func(T)) RetryOption

+ type RetryableEvent interface

+ GetRetryCount func() uint32

+ IncRetryCount func()

+ NeedRetry func() bool

+ Retry func()

+ type RetryableEvent2 interface

+ GetRetry1Count func() uint32

+ GetRetry2Count func() uint32

+ IncRetry1Count func()

+ IncRetry2Count func()

+ NeedRetry1 func() bool

+ NeedRetry2 func() bool

+ Retry1 func()

+ Retry2 func()

+ type StandaloneMaster struct

+ func InitProcessor[T queueconfig.OnlineConf](conf queueconfig.OnlineConfWithSubtree[T], opts ...InitOption) *StandaloneMaster

+ func NewStandaloneManager(queue Queue, pool *workerpool.WorkerPool, logger *slog.Logger) *StandaloneMaster

+ func (qm *StandaloneMaster) Run()

+ func (qm *StandaloneMaster) Stop()

+ type Stat struct

+ func (s *Stat) Errors() uint32

+ func (s *Stat) Processed() uint32

+ type Unpacker interface

+ Unpack func() error

+ type VersionType = uint8

v0.4.0

Sep 25, 2026