types

Documentation

Index

• func CreateResponseJson(data []byte, id string) string
• type Context
  • func (c Context) OnDisconnect() error
• type For
• type Message
• type MessageType
• type Response

Functions

func CreateResponseJson

func CreateResponseJson(data []byte, id string) string

Types

type Context

type Context struct {
	Logger  logging.Logger
	Context context.Context
	Session *common.AuthSession
	// Connection *websocket.Conn
	Mutex *sync.Mutex

	Write          func([]byte) error
	WriteJSON      func(interface{}) error
	OnDisconnectFn func() error
}

func (Context) OnDisconnect

func (c Context) OnDisconnect() error

type For

type For string

const (
	ForLogs           For = "logs"
	ForJetstreamLogs  For = "jetstram-logs"
	ForResourceUpdate For = "resource-update"
)

type Message

type Message struct {
	For  For            `json:"for"`
	Data map[string]any `json:"data"`
}

type MessageType

type MessageType string

const (
	MessageTypeError    MessageType = "error"
	MessageTypeResponse MessageType = "response"
	MessageTypeInfo     MessageType = "info"
	MessageTypeWarning  MessageType = "warning"
)

type Response

type Response[T any] struct {
	Type MessageType `json:"type"`
	For  For         `json:"for"`

	Data    T      `json:"data"`
	Message string `json:"message"`
	Id      string `json:"id"`
}