task

Documentation

Index

• func WithDelay(delay time.Duration) func(*taskspb.Task) error
• type AddEmailToMailingListMessage
• type AutosocialPollFarcasterMessage
• type AutosocialProcessUsersMessage
• type Client
  • func NewClient(ctx context.Context) *Client
  • func (c *Client) CreateTaskForAddingEmailToMailingList(ctx context.Context, message AddEmailToMailingListMessage) error
  • func (c *Client) CreateTaskForAutosocialPollFarcaster(ctx context.Context, message AutosocialPollFarcasterMessage) error
  • func (c *Client) CreateTaskForAutosocialProcessUsers(ctx context.Context, message AutosocialProcessUsersMessage) error
  • func (c *Client) CreateTaskForFeed(ctx context.Context, message FeedMessage) error
  • func (c *Client) CreateTaskForFeedbot(ctx context.Context, message FeedbotMessage) error
  • func (c *Client) CreateTaskForHighlightMintClaim(ctx context.Context, message HighlightMintClaimMessage, ...) error
  • func (c *Client) CreateTaskForPostPreflight(ctx context.Context, message PostPreflightMessage) error
  • func (c *Client) CreateTaskForPushNotification(ctx context.Context, message PushNotificationMessage) error
  • func (c *Client) CreateTaskForSlackPostFeedBot(ctx context.Context, message FeedbotSlackPostMessage) error
  • func (c *Client) CreateTaskForWalletRemoval(ctx context.Context, message TokenProcessingWalletRemovalMessage) error
  • func (c *Client) CreateTaskTokenProcessingForOpenseaStreamer(ctx context.Context, message persist.OpenSeaWebhookInput) error
  • func (c *Client) CreateTaskTokenProcessingRetryToken(ctx context.Context, message TokenProcessingTokenMessage, ...) error
  • func (c *Client) CreateTaskTokenProcessingSyncBatch(ctx context.Context, message TokenProcessingBatchMessage) error
• type FeedMessage
• type FeedbotMessage
• type FeedbotSlackPostMessage
• type HighlightMintClaimMessage
• type PostPreflightMessage
• type PushNotificationMessage
• type TokenIdentifiersQuantities
  • func (t TokenIdentifiersQuantities) MarshalJSON() ([]byte, error)
  • func (t *TokenIdentifiersQuantities) UnmarshalJSON(b []byte) error
• type TokenProcessingBatchMessage
• type TokenProcessingContractTokensMessage
• type TokenProcessingTokenMessage
• type TokenProcessingUserTokensMessage
• type TokenProcessingWalletRemovalMessage
• type ValidateNFTsMessage

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"`
}