control

type Controller struct {
	// contains filtered or unexported fields
}

type EncodeReferenceCloser interface {
	chunk.Encoder
	ReferenceChecker
	io.Closer
}

type Error struct {
	// Subroutine is the name of the subroutine that failed.
	Subroutine string
	// Stage is the stage of the subroutine that failed.
	Stage Stage
	// Err is the error that caused the failure.
	Err error
}

type ExportTransformer interface {
	chunk.Transformer
	TransformStarter
}

type Flags struct {
	// MemberOnly is the flag to fetch only those channels where the user is a
	// member.
	MemberOnly bool
	// RecordFiles instructs directory processor to record the files as chunks.
	RecordFiles bool
	// Refresh is to fetch additional channels from the API in addition to
	// those provided in the list.  It's useful when the list is
	// incomplete or outdated.
	Refresh bool
	// ChannelUsers is the flag to fetch only users involved in the channel,
	// and skip fetching of all users.
	ChannelUsers bool
	// ChannelTypes is the list of channel types to fetch.  If empty, all
	// channel types are fetched.
	ChannelTypes []string
	// IncludeLabels requests API to include the labels for the custom fields.
	// works only with ChannelUsers. Server may throttle requests hard.
	IncludeLabels bool
}

type Option func(*options)

type ReferenceChecker interface {
	// IsComplete should return true, if all messages and threads for the
	// channel has been processed.
	IsComplete(ctx context.Context, channelID string) (bool, error)
	// IsCompleteThread should return true, if all messages in the thread
	// for thread-only list entry have been processed.  The behaviour of
	// this function is undefined for non-thread-only list entries.
	IsCompleteThread(ctx context.Context, channelID string, threadID string) (bool, error)
}

type SearchType int

type Stage string

type Streamer interface {
	Conversations(ctx context.Context, proc processor.Conversations, links <-chan structures.EntityItem) error
	ListChannels(ctx context.Context, proc processor.Channels, p *slack.GetConversationsParameters) error
	ListChannelsEx(ctx context.Context, proc processor.Channels, p *slack.GetConversationsParameters, onlyMyChannels bool) error
	Users(ctx context.Context, proc processor.Users, opt ...slack.GetUsersOption) error
	WorkspaceInfo(ctx context.Context, proc processor.WorkspaceInfo) error
	SearchMessages(ctx context.Context, proc processor.MessageSearcher, query string) error
	SearchFiles(ctx context.Context, proc processor.FileSearcher, query string) error
	UsersBulk(ctx context.Context, proc processor.Users, ids ...string) error
	UsersBulkWithCustom(ctx context.Context, proc processor.Users, includeLabels bool, ids ...string) error
}

type TransformStarter interface {
	StartWithUsers(ctx context.Context, users []slack.User) error
}