redisutil

package

v0.0.0-...-1f26eb9 Latest Latest Go to latest Published: Jan 10, 2023 License: MIT Imports: 3 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/eth-library/dataset-dj

Links

Open Source Insights

Documentation ¶

Index ¶

func InitRedisConnection(addr string) *redis.Client
func PublishArchiveTask(client *redis.Client, archiveTask interface{}) error
func PublishEmailTask(client *redis.Client, emailParts EmailParts) error
func PublishSourceBucketTask(client *redis.Client, bucket interface{}) error
func PublishTask(client *redis.Client, TaskMessage interface{}, channelName string) error
func SubscribeToRedisChannel(rdbClient *redis.Client, handlers map[string]interface{})
type EmailParts

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func InitRedisConnection ¶

func InitRedisConnection(addr string) *redis.Client

func PublishArchiveTask ¶

func PublishArchiveTask(client *redis.Client, archiveTask interface{}) error

PublishArchiveTask marshals an archiveTask into json and publishes to the 'archive' redis channel where the archive request will be handled by a subscriber/worker

func PublishEmailTask ¶

func PublishEmailTask(client *redis.Client, emailParts EmailParts) error

func PublishSourceBucketTask ¶

func PublishSourceBucketTask(client *redis.Client, bucket interface{}) error

func PublishTask ¶

func PublishTask(client *redis.Client, TaskMessage interface{}, channelName string) error

PublishTask marshals a struct into json and publishes to the channelName redis channel where the task will be handled by a subscriber/worker returns number of workers that are subscribed to the channel

func SubscribeToRedisChannel ¶

func SubscribeToRedisChannel(rdbClient *redis.Client, handlers map[string]interface{})

Types ¶

type EmailParts ¶

type EmailParts struct {
	To       string
	Subject  string
	BodyType string // e.g.: text/plain
	Body     string
}

EmailParts required by the mailHandler to send an email

Source Files ¶

View all Source files

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