protocol

Documentation

Index

• func NewCommandMessage(env *common.SessionEnv, command string, channel string, identifiers string, ...) *pb.CommandMessage
• func NewConnectMessage(env *common.SessionEnv) *pb.ConnectionRequest
• func NewDisconnectMessage(env *common.SessionEnv, identifiers string, subscriptions []string) *pb.DisconnectRequest
• func ParseCommandResponse(response *pb.CommandResponse) (*common.CommandResult, error)
• func ParseConnectResponse(response *pb.ConnectionResponse) (*common.ConnectResult, error)
• func ParseDisconnectResponse(response *pb.DisconnectResponse) error

Functions

func NewCommandMessage

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

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

NewConnectMessage builds a connect RPC payload from the session env

func NewDisconnectMessage

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

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

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

func ParseConnectResponse

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

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

func ParseDisconnectResponse

func ParseDisconnectResponse(response *pb.DisconnectResponse) error

ParseDisconnectResponse takes protobuf DisconnectResponse struct and return error if any