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 ¶
View Source
const RAW_CHANNEL_MESSAGE_TABLE = "slack_channel_message"
View Source
const RAW_CHANNEL_TABLE = "slack_channel"
View Source
const RAW_THREAD_TABLE = "slack_thread"
Variables ¶
View Source
var CollectChannelMessageMeta = plugin.SubTaskMeta{ Name: "collectChannelMessage", EntryPoint: CollectChannelMessage, EnabledByDefault: true, Description: "Collect channel message from Slack api", }
View Source
var CollectChannelMeta = plugin.SubTaskMeta{ Name: "collectChannel", EntryPoint: CollectChannel, EnabledByDefault: true, Description: "Collect channels from Slack api", }
View Source
var CollectThreadMeta = plugin.SubTaskMeta{ Name: "collectThread", EntryPoint: CollectThread, EnabledByDefault: true, Description: "Collect thread from Slack api", }
View Source
var ExtractChannelMessageMeta = plugin.SubTaskMeta{ Name: "extractChannelMessage", EntryPoint: ExtractChannelMessage, EnabledByDefault: true, Description: "Extract raw channel messages data into tool layer table", }
View Source
var ExtractChannelMeta = plugin.SubTaskMeta{ Name: "extractChannel", EntryPoint: ExtractChannel, EnabledByDefault: true, Description: "Extract raw channel data into tool layer table", }
View Source
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"` helper.CollectorOptions `mapstructure:",squash"` }
type SlackTaskData ¶
type SlackTaskData struct { Options *SlackOptions ApiClient *helper.ApiAsyncClient }
type ThreadInput ¶
Click to show internal directories.
Click to hide internal directories.