enqueuemanager

package

v0.0.0-...-e9c30ff Latest Latest Go to latest Published: Apr 20, 2024 License: Apache-2.0 Imports: 25 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/tnyim/jungletv

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type EnqueueTicket
type Manager
- func New(workerContext context.Context, log *log.Logger, statsClient *statsd.Client, ...) (*Manager, error)

Constants ¶

View Source

const TicketExpiration = 10 * time.Minute

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type EnqueueTicket ¶

type EnqueueTicket interface {
	media.EnqueueRequest
	ID() string
	CreatedAt() time.Time
	RequestedBy() auth.User
	PaymentAddress() string
	SerializeForAPI() *proto.EnqueueMediaTicket
	RequestPricing() pricer.EnqueuePricing
	SetPaid() error
	SetFailedDueToInsufficientPoints()
	Status() proto.EnqueueMediaTicketStatus
	StatusChanged() event.NoArgEvent
	ForceEnqueuing(proto.ForcedTicketEnqueueType)
	EnqueuingForced() (bool, proto.ForcedTicketEnqueueType)
}

EnqueueTicket is a request to enqueue media that is pending payment

type Manager ¶

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

Manager manages requests for enqueuing that are pending payment

func New ¶

func New(
	workerContext context.Context,
	log *log.Logger,
	statsClient *statsd.Client,
	mediaQueue *mediaqueue.MediaQueue,
	pricer *pricer.Pricer,
	paymentAccountPool *payment.PaymentAccountPool,
	rewardsHandler *rewards.Handler,
	pointsManager *pointsmanager.Manager,
	moderationStore moderation.Store,
	modLogWebhook api.WebhookClient) (*Manager, error)

New returns a new Manager

func (*Manager) GetTicket ¶

func (e *Manager) GetTicket(id string) EnqueueTicket

func (*Manager) NewEntriesAlwaysUnskippableForFree ¶

func (e *Manager) NewEntriesAlwaysUnskippableForFree() bool

func (*Manager) RegisterRequest ¶

func (e *Manager) RegisterRequest(ctx context.Context, request media.EnqueueRequest, forceAnonymous bool) (EnqueueTicket, error)

func (*Manager) SetNewQueueEntriesAlwaysUnskippableForFree ¶

func (e *Manager) SetNewQueueEntriesAlwaysUnskippableForFree(enabled bool)

func (*Manager) UserHasEnoughPointsToEnqueueConcealedEntry ¶

func (e *Manager) UserHasEnoughPointsToEnqueueConcealedEntry(ctxCtx context.Context, user auth.User) (bool, error)

Source Files ¶

View all Source files

manager.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL