lib

package

v0.4.0 Latest Latest Go to latest Published: Apr 27, 2023 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/beewee22/slack-backup

Links

Open Source Insights

Documentation ¶

Index ¶

func FetchThreadInQueue(ctx context.Context, slackClient *slack.Client, channelID string, ...) (threadChan chan []slack.Message)
func ReadAllMessageInChannel(ctx context.Context, slackClient *slack.Client, channelID string) (messageChan chan []slack.Message)
func SaveMessagesAsJSONFile(messages []slack.Message, fileName string) error
type SafeQueue
- func NewSafeQueue[T any]() *SafeQueue[T]

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func FetchThreadInQueue ¶

func FetchThreadInQueue(ctx context.Context, slackClient *slack.Client, channelID string, tsQueue *SafeQueue[string]) (threadChan chan []slack.Message)

func ReadAllMessageInChannel ¶

func ReadAllMessageInChannel(ctx context.Context, slackClient *slack.Client, channelID string) (messageChan chan []slack.Message)

func SaveMessagesAsJSONFile ¶

func SaveMessagesAsJSONFile(messages []slack.Message, fileName string) error

Types ¶

type SafeQueue ¶

type SafeQueue[T any] struct {
	// contains filtered or unexported fields
}

func NewSafeQueue ¶

func NewSafeQueue[T any]() *SafeQueue[T]

func (*SafeQueue[T]) Add ¶

func (q *SafeQueue[T]) Add(ts ...T)

func (*SafeQueue[T]) IsDone ¶

func (q *SafeQueue[T]) IsDone() bool

func (*SafeQueue[T]) IsEmpty ¶

func (q *SafeQueue[T]) IsEmpty() bool

func (*SafeQueue[T]) Len ¶

func (q *SafeQueue[T]) Len() int

func (*SafeQueue[T]) Pop ¶

func (q *SafeQueue[T]) Pop() T

func (*SafeQueue[T]) SetDone ¶

func (q *SafeQueue[T]) SetDone(canBeDone bool)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL