util

Documentation

Index

• func ConvertProtoToMessageType(protoMsgType protos.MsgType) message.Type
• func CtxWithDefaultLogger(ctx context.Context, route, userID string) context.Context
• func FileExists(filename string) bool
• func GetContextFromRequest(req *protos.Request, serverID string) (context.Context, error)
• func GetErrorFromPayload(serializer serialize.Serializer, payload []byte) error
• func GetErrorPayload(serializer serialize.Serializer, err error) ([]byte, error)
• func Pcall(method reflect.Method, args []reflect.Value) (rets interface{}, err error)
• func SerializeOrRaw(serializer serialize.Serializer, v interface{}) ([]byte, error)
• func SliceContainsString(slice []string, str string) bool
• func StartSpanFromRequest(ctx context.Context, serverID, route string) context.Context

Functions

func ConvertProtoToMessageType

func ConvertProtoToMessageType(protoMsgType protos.MsgType) message.Type

ConvertProtoToMessageType converts a protos.MsgType to a message.Type

func CtxWithDefaultLogger

func CtxWithDefaultLogger(ctx context.Context, route, userID string) context.Context

CtxWithDefaultLogger inserts a default logger on ctx to be used on handlers and remotes. If using logrus, userId, route and requestId will be added as fields. Otherwise the pitaya logger will be used as it is.

func FileExists

func FileExists(filename string) bool

FileExists tells if a file exists

func GetContextFromRequest

func GetContextFromRequest(req *protos.Request, serverID string) (context.Context, error)

GetContextFromRequest gets the context from a request

func GetErrorFromPayload

func GetErrorFromPayload(serializer serialize.Serializer, payload []byte) error

GetErrorFromPayload gets the error from payload

func GetErrorPayload

func GetErrorPayload(serializer serialize.Serializer, err error) ([]byte, error)

GetErrorPayload creates and serializes an error payload

func Pcall

func Pcall(method reflect.Method, args []reflect.Value) (rets interface{}, err error)

Pcall calls a method that returns an interface and an error and recovers in case of panic

func SerializeOrRaw

func SerializeOrRaw(serializer serialize.Serializer, v interface{}) ([]byte, error)

SerializeOrRaw serializes the interface if its not an array of bytes already

func SliceContainsString

func SliceContainsString(slice []string, str string) bool

SliceContainsString returns true if a slice contains the string

func StartSpanFromRequest

func StartSpanFromRequest(
	ctx context.Context,
	serverID, route string,
) context.Context

StartSpanFromRequest starts a tracing span from the request