subscribed

Documentation

Index

• Constants
• type Plugin
  • func (p *Plugin) Init(log *zap.Logger, feedStorage storage.FeedStorage, ...) error
  • func (p *Plugin) Name() string
  • func (p *Plugin) ProcessTask(ctx context.Context, task *asynq.Task) error

Constants

const PluginName = consts.TaskSubscribed

Types

type Plugin

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

func (*Plugin) Init

func (p *Plugin) Init(
	log *zap.Logger,
	feedStorage storage.FeedStorage,
	roomStorage storage.RoomStorage,
	sender tgbotsender.TelegramSender,
) 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