protocol

package
v0.0.3 Latest Latest
Warning

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

 Go to latest Published: May 26, 2026 License: MIT Imports: 1 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TypeConnectionAck = "connection_ack"
	TypeKeepAlive     = "ka"
	TypeUnsubscribe   = "unsubscribe"
	TypeSubscribe     = "subscribe"
	TypeData          = "data"
	TypePublish       = "publish"

	TypeSubscribeSuccess   = "subscribe_success"
	TypePublishSuccess     = "publish_success"
	TypeUnsubscribeSuccess = "unsubscribe_success"

	TypeError            = "error"
	TypeConnectionError  = "connection_error"
	TypeSubscribeError   = "subscribe_error"
	TypePublishError     = "publish_error"
	TypeUnsubscribeError = "unsubscribe_error"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type ConnectionAckMessage 

type ConnectionAckMessage struct {
	TimeoutMs int
}

type DataMessage 

type DataMessage struct {
	SubId   string
	Payload app.Payload
}

type ErrorMessage 

type ErrorMessage struct {
	ID     string
	Errors []ErrorMetadata
}

type ErrorMetadata 

type ErrorMetadata struct {
	Type    string
	Message string
}

type KeepAliveMessage 

type KeepAliveMessage struct{}

type PublishMessage 

type PublishMessage struct {
	Destination string
	Payload     app.Payload
}

type PublishResult 

type PublishResult struct {
	Err error
}

type SuccessMessage 

type SuccessMessage struct {
	ID string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.