go_redisbroadcast

README

go_redisbroadcast

simple broadcast tool in go using redis

This repo only exists because we use in memory cache across distributed systems and we need a system to invalidate cache elements across multiple services.

Issue Reporting

If you found any issues or wanted to suggest any enhancement, do create an issue in the repo itself or shoot an email to bansalaman2905[at]gmail[dot]com.

Documentation

Index

• func Close()
• func Init() error
• func Publish(eventType string, message Message) error
• func Register(eventType string, process Process) error
• type Message
• type Process

Functions

func Close

func Close()

func Init

func Init() error

func Publish

func Publish(eventType string, message Message) error

func Register

func Register(eventType string, process Process) error

Types

type Message

type Message struct {
	MessageId   string `json:"message_id"`
	MessageText string `json:"message_text"`
}

type Process

type Process interface {
	Process(eventType string, message Message)
}