data_types

Documentation

Index

• func WorkerTypeToCategory(wt WorkerType) pubsub.WorkerCategory
• func WorkerTypeToDataSource(wt WorkerType) string
• type WorkRequest
• type WorkResponse
• type Worker
  • func NewWorker(isLocal bool, nd *pubsub.NodeData) *Worker
• type WorkerType

Functions

func WorkerTypeToCategory

func WorkerTypeToCategory(wt WorkerType) pubsub.WorkerCategory

WorkerTypeToCategory maps WorkerType to WorkerCategory

func WorkerTypeToDataSource

func WorkerTypeToDataSource(wt WorkerType) string

WorkerTypeToDataSource maps WorkerType to WorkerCategory

Types

type WorkRequest

type WorkRequest struct {
	WorkType  WorkerType `json:"workType,omitempty"`
	RequestId string     `json:"requestId,omitempty"`
	Data      []byte     `json:"data,omitempty"`
}

type WorkResponse

type WorkResponse struct {
	WorkRequest  *WorkRequest `json:"workRequest,omitempty"`
	Data         interface{}  `json:"data,omitempty"`
	Error        string       `json:"error,omitempty"`
	WorkerPeerId string       `json:"workerPeerId,omitempty"`
	RecordCount  int          `json:"recordCount,omitempty"`
}

type Worker

type Worker struct {
	IsLocal  bool
	IPAddr   string
	AddrInfo *peer.AddrInfo
	NodeData pubsub.NodeData
	Node     *masa.OracleNode
}

func NewWorker

func NewWorker(isLocal bool, nd *pubsub.NodeData) *Worker

type WorkerType

type WorkerType string

const (
	Discord                 WorkerType = "discord"
	DiscordProfile          WorkerType = "discord-profile"
	DiscordChannelMessages  WorkerType = "discord-channel-messages"
	DiscordSentiment        WorkerType = "discord-sentiment"
	TelegramSentiment       WorkerType = "telegram-sentiment"
	TelegramChannelMessages WorkerType = "telegram-channel-messages"
	DiscordGuildChannels    WorkerType = "discord-guild-channels"
	DiscordUserGuilds       WorkerType = "discord-user-guilds"
	LLMChat                 WorkerType = "llm-chat"
	Twitter                 WorkerType = "twitter"
	TwitterFollowers        WorkerType = "twitter-followers"
	TwitterProfile          WorkerType = "twitter-profile"
	TwitterSentiment        WorkerType = "twitter-sentiment"
	TwitterTrends           WorkerType = "twitter-trends"
	Web                     WorkerType = "web"
	WebSentiment            WorkerType = "web-sentiment"
	Test                    WorkerType = "test"

	DataSourceTwitter  = "twitter"
	DataSourceDiscord  = "discord"
	DataSourceWeb      = "web"
	DataSourceTelegram = "telegram"
)