cable_courier

package
v0.0.0-...-4be293a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 17, 2025 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client

type Client struct {
	Redis        *redis.Client
	RedisChannel string
}

func NewClient

func NewClient(rdc *redis.Client, redisChannel string) *Client

func (*Client) BroadcastMessage

func (c *Client) BroadcastMessage(msgName string, msg proto.Message, stream, correlationID string) error

type Command

type Command struct {
	Command string `json:"command"`
	Data    string `json:"data"`
}

type Event

type Event struct {
	Stream string `json:"stream"`
	Data   string `json:"data"`
}

type EventData

type EventData struct {
	Event         string                 `json:"event"`
	Data          map[string]interface{} `json:"data"`
	CorrelationID string                 `json:"correlationId"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
JackTT - Gopher 🇻🇳