proto

Documentation

Overview

Package proto specifies websocket protocol helpers.

Index

• func Decode(data []byte) (*message.Message, error)
• func Encode(message protoreflect.ProtoMessage) ([]byte, error)
• func NewErrorResponse(request *message.Message, err error) (*message.Message, error)
• func NewOkResponse(request *message.Message) (*message.Message, error)
• func NewRuntimeEvent(subscriptionUID string, event runtime.Event) (*message.Message, error)
• func NewSubscribedResponse(request *message.Message, id string) (*message.Message, error)

Functions

func Decode

func Decode(data []byte) (*message.Message, error)

Decode implements websocket message decoding.

func Encode

func Encode(message protoreflect.ProtoMessage) ([]byte, error)

Encode implements websocket message encoding.

func NewErrorResponse

func NewErrorResponse(request *message.Message, err error) (*message.Message, error)

NewErrorResponse creates new Error message.

func NewOkResponse

func NewOkResponse(request *message.Message) (*message.Message, error)

NewOkResponse creates new Ok message.

func NewRuntimeEvent

func NewRuntimeEvent(subscriptionUID string, event runtime.Event) (*message.Message, error)

NewRuntimeEvent creates new runtime event.

func NewSubscribedResponse

func NewSubscribedResponse(request *message.Message, id string) (*message.Message, error)

NewSubscribedResponse compose subscribed response.