tasks

Documentation

Index

• Constants
• Variables
• func CollectChannel(taskCtx plugin.SubTaskContext) errors.Error
• func CollectChannelMessage(taskCtx plugin.SubTaskContext) errors.Error
• func CollectThread(taskCtx plugin.SubTaskContext) errors.Error
• func ExtractChannel(taskCtx plugin.SubTaskContext) errors.Error
• func ExtractChannelMessage(taskCtx plugin.SubTaskContext) errors.Error
• func ExtractThread(taskCtx plugin.SubTaskContext) errors.Error
• func NewSlackApiClient(taskCtx plugin.TaskContext, connection *models.SlackConnection) (*api.ApiAsyncClient, errors.Error)
• type ChannelInput
• type SlackApiParams
• type SlackOptions
• type SlackTaskData
• type ThreadInput

Constants

const RAW_CHANNEL_MESSAGE_TABLE = "slack_channel_message"

const RAW_CHANNEL_TABLE = "slack_channel"

const RAW_THREAD_TABLE = "slack_thread"

Variables

var CollectChannelMessageMeta = plugin.SubTaskMeta{
	Name:             "collectChannelMessage",
	EntryPoint:       CollectChannelMessage,
	EnabledByDefault: true,
	Description:      "Collect channel message from Slack api",
}

var CollectChannelMeta = plugin.SubTaskMeta{
	Name:             "collectChannel",
	EntryPoint:       CollectChannel,
	EnabledByDefault: true,
	Description:      "Collect channels from Slack api",
}

var CollectThreadMeta = plugin.SubTaskMeta{
	Name:             "collectThread",
	EntryPoint:       CollectThread,
	EnabledByDefault: true,
	Description:      "Collect thread from Slack api",
}

var ExtractChannelMessageMeta = plugin.SubTaskMeta{
	Name:             "extractChannelMessage",
	EntryPoint:       ExtractChannelMessage,
	EnabledByDefault: true,
	Description:      "Extract raw channel messages data into tool layer table",
}

var ExtractChannelMeta = plugin.SubTaskMeta{
	Name:             "extractChannel",
	EntryPoint:       ExtractChannel,
	EnabledByDefault: true,
	Description:      "Extract raw channel data into tool layer table",
}

var ExtractThreadMeta = plugin.SubTaskMeta{
	Name:             "extractThread",
	EntryPoint:       ExtractThread,
	EnabledByDefault: true,
	Description:      "Extract raw thread messages data into tool layer table",
}

Functions

func CollectChannel

func CollectChannel(taskCtx plugin.SubTaskContext) errors.Error

CollectChannel collect all channels that bot is in

func CollectChannelMessage

func CollectChannelMessage(taskCtx plugin.SubTaskContext) errors.Error

func CollectThread

func CollectThread(taskCtx plugin.SubTaskContext) errors.Error

func ExtractChannel

func ExtractChannel(taskCtx plugin.SubTaskContext) errors.Error

func ExtractChannelMessage

func ExtractChannelMessage(taskCtx plugin.SubTaskContext) errors.Error

func ExtractThread

func ExtractThread(taskCtx plugin.SubTaskContext) errors.Error

func NewSlackApiClient

func NewSlackApiClient(taskCtx plugin.TaskContext, connection *models.SlackConnection) (*api.ApiAsyncClient, errors.Error)

Types

type ChannelInput

type ChannelInput struct {
	ChannelId string `json:"channel_id"`
}

type SlackApiParams

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

type SlackOptions

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

type SlackTaskData

type SlackTaskData struct {
	Options   *SlackOptions
	ApiClient *helper.ApiAsyncClient
}

type ThreadInput

type ThreadInput struct {
	ChannelId string `json:"channel_id"`
	ThreadTs  string `json:"thread_ts"`
}