body_extractor

Documentation

Index

• Constants
• func RunQuery(msg *dynamic.Message, query []Query) (interface{}, error)
• type GRPCPayloadCompressionFormat
• type GRPCPayloadHandler
  • func (b GRPCPayloadHandler) Extract(body *io.ReadCloser, protoIndex string) (interface{}, error)
• type JSONPayloadHandler
  • func (h JSONPayloadHandler) Extract(body *io.ReadCloser, key string) (interface{}, error)
• type Query
  • func ParseQuery(query string) ([]Query, error)

Constants

const (
	MessageArray = "MessageArray"
	StringArray  = "StringArray"
	String       = "String"
	Message      = "Message"
)

Functions

func RunQuery

func RunQuery(msg *dynamic.Message, query []Query) (interface{}, error)

Types

type GRPCPayloadCompressionFormat

type GRPCPayloadCompressionFormat uint8

GRPCPayloadCompressionFormat tells by reading the first byte compressed or not

type GRPCPayloadHandler

type GRPCPayloadHandler struct {
	// contains filtered or unexported fields
}

func (GRPCPayloadHandler) Extract

func (b GRPCPayloadHandler) Extract(body *io.ReadCloser, protoIndex string) (interface{}, error)

type JSONPayloadHandler

type JSONPayloadHandler struct{}

func (JSONPayloadHandler) Extract

func (h JSONPayloadHandler) Extract(body *io.ReadCloser, key string) (interface{}, error)

type Query

type Query struct {
	Field    int    `json:"field"`
	DataType string `json:"data_type"`
}

func ParseQuery

func ParseQuery(query string) ([]Query, error)