task

package
v0.0.0-...-7601700 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 25, 2024 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func WithDelay

func WithDelay(delay time.Duration) func(*taskspb.Task) error

Types

type AddEmailToMailingListMessage

type AddEmailToMailingListMessage struct {
	UserID persist.DBID `json:"user_id" binding:"required"`
}

type AutosocialPollFarcasterMessage

type AutosocialPollFarcasterMessage struct {
	SignerUUID string       `form:"signer_uuid" binding:"required"`
	UserID     persist.DBID `form:"user_id" binding:"required"`
}

type AutosocialProcessUsersMessage

type AutosocialProcessUsersMessage struct {
	Users               map[persist.DBID]map[persist.SocialProvider][]persist.ChainAddress `json:"users" binding:"required"`
	ImportSocialWallets map[persist.DBID]map[persist.SocialProvider]bool                   `json:"import_social_wallets"`
}

type Client

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

func NewClient

func NewClient(ctx context.Context) *Client

NewClient returns a new task client with tracing enabled.

func (*Client) CreateTaskForAddingEmailToMailingList

func (c *Client) CreateTaskForAddingEmailToMailingList(ctx context.Context, message AddEmailToMailingListMessage) error

func (*Client) CreateTaskForAutosocialPollFarcaster

func (c *Client) CreateTaskForAutosocialPollFarcaster(ctx context.Context, message AutosocialPollFarcasterMessage) error

func (*Client) CreateTaskForAutosocialProcessUsers

func (c *Client) CreateTaskForAutosocialProcessUsers(ctx context.Context, message AutosocialProcessUsersMessage) error

func (*Client) CreateTaskForFeed

func (c *Client) CreateTaskForFeed(ctx context.Context, message FeedMessage) error

func (*Client) CreateTaskForFeedbot

func (c *Client) CreateTaskForFeedbot(ctx context.Context, message FeedbotMessage) error

func (*Client) CreateTaskForHighlightMintClaim

func (c *Client) CreateTaskForHighlightMintClaim(ctx context.Context, message HighlightMintClaimMessage, opts ...func(*taskspb.Task) error) error

func (*Client) CreateTaskForPostPreflight

func (c *Client) CreateTaskForPostPreflight(ctx context.Context, message PostPreflightMessage) error

func (*Client) CreateTaskForPushNotification

func (c *Client) CreateTaskForPushNotification(ctx context.Context, message PushNotificationMessage) error

func (*Client) CreateTaskForSlackPostFeedBot

func (c *Client) CreateTaskForSlackPostFeedBot(ctx context.Context, message FeedbotSlackPostMessage) error

func (*Client) CreateTaskForWalletRemoval

func (c *Client) CreateTaskForWalletRemoval(ctx context.Context, message TokenProcessingWalletRemovalMessage) error

func (*Client) CreateTaskTokenProcessingForOpenseaStreamer

func (c *Client) CreateTaskTokenProcessingForOpenseaStreamer(ctx context.Context, message persist.OpenSeaWebhookInput) error

func (*Client) CreateTaskTokenProcessingRetryToken

func (c *Client) CreateTaskTokenProcessingRetryToken(ctx context.Context, message TokenProcessingTokenMessage, delayFor time.Duration) error

func (*Client) CreateTaskTokenProcessingSyncBatch

func (c *Client) CreateTaskTokenProcessingSyncBatch(ctx context.Context, message TokenProcessingBatchMessage) error

type FeedMessage

type FeedMessage struct {
	ID persist.DBID `json:"id" binding:"required"`
}

FeedMessage is the input message to the feed service

type FeedbotMessage

type FeedbotMessage struct {
	FeedEventID persist.DBID   `json:"id" binding:"required"`
	Action      persist.Action `json:"action" binding:"required"`
}

FeedbotMessage is the input message to the feedbot service

type FeedbotSlackPostMessage

type FeedbotSlackPostMessage struct {
	PostID persist.DBID `json:"post_id" binding:"required"`
}

type HighlightMintClaimMessage

type HighlightMintClaimMessage struct {
	ClaimID  persist.DBID `json:"claim_id" binding:"required"`
	Attempts int          `json:"attempts"`
}

type PostPreflightMessage

type PostPreflightMessage struct {
	Token  persist.TokenIdentifiers `json:"token" binding:"required"`
	UserID persist.DBID             `json:"user_id"`
}

type PushNotificationMessage

type PushNotificationMessage struct {
	PushTokenID persist.DBID   `json:"pushTokenID"`
	Title       string         `json:"title"`
	Subtitle    string         `json:"subtitle"`
	Body        string         `json:"body"`
	Data        map[string]any `json:"data"`
	Sound       bool           `json:"sound"`
	Badge       int            `json:"badge"`
}

type TokenIdentifiersQuantities

type TokenIdentifiersQuantities map[persist.TokenUniqueIdentifiers]persist.HexString

func (TokenIdentifiersQuantities) MarshalJSON

func (t TokenIdentifiersQuantities) MarshalJSON() ([]byte, error)

func (*TokenIdentifiersQuantities) UnmarshalJSON

func (t *TokenIdentifiersQuantities) UnmarshalJSON(b []byte) error

type TokenProcessingBatchMessage

type TokenProcessingBatchMessage struct {
	BatchID            persist.DBID   `json:"batch_id" binding:"required"`
	TokenDefinitionIDs []persist.DBID `json:"token_definition_ids" binding:"required"`
}

type TokenProcessingContractTokensMessage

type TokenProcessingContractTokensMessage struct {
	ContractID   persist.DBID `json:"contract_id" binding:"required"`
	ForceRefresh bool         `json:"force_refresh"`
}

type TokenProcessingTokenMessage

type TokenProcessingTokenMessage struct {
	TokenDefinitionID persist.DBID `json:"token_definition_id" binding:"required"`
	Attempts          int          `json:"attempts" binding:"required"`
}

type TokenProcessingUserTokensMessage

type TokenProcessingUserTokensMessage struct {
	UserID           persist.DBID               `json:"user_id" binding:"required"`
	TokenIdentifiers TokenIdentifiersQuantities `json:"token_identifiers" binding:"required"`
}

type TokenProcessingWalletRemovalMessage

type TokenProcessingWalletRemovalMessage struct {
	UserID    persist.DBID   `json:"user_id" binding:"required"`
	WalletIDs []persist.DBID `json:"wallet_ids" binding:"required"`
}

type ValidateNFTsMessage

type ValidateNFTsMessage struct {
	OwnerAddress persist.EthereumAddress `json:"wallet"`
}

Jump to

Keyboard shortcuts

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