tasks

Documentation

Index

• Constants
• Variables
• func CollectMeetingTopUserItem(taskCtx core.SubTaskContext) error
• func ExtractMeetingTopUserItem(taskCtx core.SubTaskContext) error
• func NewFeishuApiClient(taskCtx core.TaskContext, connection *models.FeishuConnection) (*helper.ApiAsyncClient, error)
• type FeishuApiParams
• type FeishuOptions
• type FeishuTaskData

Constants

const AUTH_ENDPOINT = "https://open.feishu.cn"

const ENDPOINT = "https://open.feishu.cn/open-apis/vc/v1"

const RAW_MEETING_TOP_USER_ITEM_TABLE = "feishu_meeting_top_user_item"

Variables

var CollectMeetingTopUserItemMeta = core.SubTaskMeta{
	Name:             "collectMeetingTopUserItem",
	EntryPoint:       CollectMeetingTopUserItem,
	EnabledByDefault: true,
	Description:      "Collect top user meeting data from Feishu api",
}

var ExtractMeetingTopUserItemMeta = core.SubTaskMeta{
	Name:             "extractMeetingTopUserItem",
	EntryPoint:       ExtractMeetingTopUserItem,
	EnabledByDefault: true,
	Description:      "Extract raw top user meeting data into tool layer table feishu_meeting_top_user_item",
}

Functions

func CollectMeetingTopUserItem

func CollectMeetingTopUserItem(taskCtx core.SubTaskContext) error

func ExtractMeetingTopUserItem

func ExtractMeetingTopUserItem(taskCtx core.SubTaskContext) error

func NewFeishuApiClient

func NewFeishuApiClient(taskCtx core.TaskContext, connection *models.FeishuConnection) (*helper.ApiAsyncClient, error)

Types

type FeishuApiParams

type FeishuApiParams struct {
	ConnectionId uint64 `json:"connectionId"`
}

type FeishuOptions

type FeishuOptions struct {
	ConnectionId       uint64  `json:"connectionId"`
	NumOfDaysToCollect float64 `json:"numOfDaysToCollect"`
}

type FeishuTaskData

type FeishuTaskData struct {
	Options                  *FeishuOptions
	ApiClient                *helper.ApiAsyncClient
	FeishuMeetingTopUserItem *models.FeishuMeetingTopUserItem
}