public

Documentation

Index

• type CallBack
• type IBroker
• type IBrokerFactory
• type IDeadLetter
• type IMigrateLog
• type IProcessLog
• type IStatus
• type Stream

Types

type CallBack

type CallBack func(ctx context.Context, data map[string]any) error

IBroker main job

type IBroker

type IBroker interface {
	Enqueue(ctx context.Context, data map[string]any) error
	Dequeue(ctx context.Context, channel, topic string, do CallBack)
}

IBroker main job

type IBrokerFactory

type IBrokerFactory interface {
	Mood(moodType btype.MoodType) IBroker
}

IBroker main job

type IDeadLetter

type IDeadLetter interface {
	DeadLetter(ctx context.Context, channel, topic string)
}

IBroker main job

type IMigrateLog

type IMigrateLog interface {
	Migrate(ctx context.Context, data []map[string]any) error
}

IMigrateLog migrate redis log to other db for example: to mongodb

type IProcessLog

type IProcessLog interface {
	AddLog(ctx context.Context, data map[string]any) error
}

IProcessLog process log

type IStatus

type IStatus interface {
	Status(ctx context.Context, channel, topic, id string) (map[string]string, error)
}

IStatus check the status of the message based on the ID

type Stream

type Stream struct {
	Data    map[string]any
	Id      string
	Channel string
	Stream  string
}

IBroker main job