grpccheckerhelper

type CheckerResponse struct {
	Error        error
	Status       string
	MessageRPC   string
	ConnectionTs float64
	ConnectTs    float64
	ResolveTs    float64
	Reflections  map[string]interface{}
	RespTrailers metadata.MD
}

type ClientDialOptions struct {
	Target        string
	TimeoutSec    float64
	KeepaliveSec  float64
	MaxMsgSize    int
	Network       string // tcp or unix
	CertsCA       string
	Certificate   string
	PrivateKey    string
	ServerNameTLS string
	IgnoreCert    bool
}

type CompositeSource struct {
	Reflection DescriptorSource
	File       DescriptorSource
}

type DefaultEventHandler struct {
	Out            io.Writer
	Formatter      Formatter
	VerbosityLevel int
	ConnectStart   time.Time
	NumResponses   int
	Status         *status.Status
}

type DescriptorSource interface {
	ListServices() ([]string, error)
	FindSymbol(fullyQualifiedName string) (desc.Descriptor, error)
	AllExtensionsForType(typeName string) ([]*desc.FieldDescriptor, error)
}

type Format string

type FormatOptions struct {
	EmitJSONDefaultFields bool
	AllowUnknownFields    bool
	IncludeTextSeparator  bool
}

type Formatter func(proto.Message) (string, error)

type InvokeResponse struct {
	Status       string
	MessageRPC   string
	Error        error
	ResolveTs    float64
	ConnectTs    float64
	RespTrailers metadata.MD
}

type RequestParser interface {
	Next(msg proto.Message) error
	NumRequests() int
}

type RequestSupplier func(proto.Message) error