Documentation ¶ Index ¶ Constants type Plugin func (p *Plugin) Init(log *zap.Logger, client *asynq.Client, roomStorage storage.RoomStorage) error func (p *Plugin) Name() string func (p *Plugin) ProcessTask(ctx context.Context, task *asynq.Task) error Constants ¶ View Source const PluginName = consts.TaskFeedItemGroup Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Plugin ¶ type Plugin struct { // contains filtered or unexported fields } func (*Plugin) Init ¶ func (p *Plugin) Init(log *zap.Logger, client *asynq.Client, roomStorage storage.RoomStorage) error func (*Plugin) Name ¶ func (p *Plugin) Name() string Name returns user-friendly plugin name func (*Plugin) ProcessTask ¶ func (p *Plugin) ProcessTask(ctx context.Context, task *asynq.Task) error Source Files ¶ View all Source files plugin.go Click to show internal directories. Click to hide internal directories.