gorealtime

package module

v1.0.0 Latest Latest Go to latest Published: Nov 6, 2022 License: MIT Imports: 7 Imported by: 1

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/golfz/gorealtime

Links

Open Source Insights

README ¶

Golang Realtime Library

ระบบ Realtime ที่ใช้ในการสื่อสารระหว่างระบบ โดยใช้ RabbitMQ และส่งข้อมูลผ่าน Websocket

Documentation ¶

Index ¶

func Subscribe(ctxWithCancel context.Context, amqpEndpoint string, scope string, topic string, ...) error
type AMQPPublisher
- func NewAMQPPublisher(amqpEndpoint string, scope string) *AMQPPublisher
- func (p *AMQPPublisher) Publish(topic string, payload string, args map[string]string) error
type Publisher
type RealtimePayload

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Subscribe(ctxWithCancel context.Context, amqpEndpoint string, scope string, topic string, subscriberID string, filterArgs map[string][]string, returnDataCh chan<- RealtimePayload) error

Types ¶

type AMQPPublisher ¶

type AMQPPublisher struct {
	// contains filtered or unexported fields
}

func NewAMQPPublisher ¶

func NewAMQPPublisher(amqpEndpoint string, scope string) *AMQPPublisher

func (*AMQPPublisher) Publish ¶

func (p *AMQPPublisher) Publish(topic string, payload string, args map[string]string) error

type Publisher ¶

type Publisher interface {
	Publish(topic string, payload string, args map[string]string) error
}

type RealtimePayload ¶

type RealtimePayload struct {
	Scope     string            `json:"scope"`
	Topic     string            `json:"topic"`
	Timestamp time.Time         `json:"timestamp"`
	Args      map[string]string `json:"args"`
	Payload   string            `json:"payload"`
}