socket

Documentation

Index

• Constants
• func NewSocket() *socket
• func StartListener(ctx context.Context)
• type Event
• type Message
• type Options

Constants

const (
	AgentIdAnnotation = "onspaceship.com/agent-id"
)

Functions

func NewSocket

func NewSocket() *socket

func StartListener

func StartListener(ctx context.Context)

Types

type Event

type Event string

const (
	CloseEvent Event = "phx_close"
	ErrorEvent Event = "phx_error"
	JoinEvent  Event = "phx_join"
	ReplyEvent Event = "phx_reply"
	LeaveEvent Event = "phx_leave"
)

type Message

type Message struct {
	Topic   string      `json:"topic"`
	Event   Event       `json:"event"`
	Payload interface{} `json:"payload"`
	Ref     int64       `json:"ref"`
}

type Options

type Options = config.SocketOptions