protocol

package

v1.4.2 Latest Latest Go to latest Published: Aug 4, 2023 License: MIT Imports: 4 Imported by: 0

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

This section is empty.

This section is empty.

func NewCommandMessage(env *common.SessionEnv, command string, channel string, identifiers string, data string) *pb.CommandMessage

NewCommandMessage builds a command RPC payload from the session env, command and channel names, and connection identifiers

func NewConnectMessage(env *common.SessionEnv) *pb.ConnectionRequest

NewConnectMessage builds a connect RPC payload from the session env

func NewDisconnectMessage(env *common.SessionEnv, identifiers string, subscriptions []string) *pb.DisconnectRequest

NewDisconnectMessage builds a disconnect RPC payload from the session env, connection identifiers and subscriptions

func ParseCommandResponse(response *pb.CommandResponse) (*common.CommandResult, error)

ParseCommandResponse takes protobuf CommandResponse struct and converts into common.CommandResult and/or error

func ParseConnectResponse(response *pb.ConnectionResponse) (*common.ConnectResult, error)

ParseConnectResponse takes protobuf ConnectionResponse struct and converts into common.ConnectResult and/or error

func ParseDisconnectResponse(response *pb.DisconnectResponse) error

ParseDisconnectResponse takes protobuf DisconnectResponse struct and return error if any

This section is empty.