endpoint

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

type GrpcError interface {
	GrpcStatusError() error
}

type JsonRequestExtractor struct {
	Validator Validator
}

type JsonResponseMapper struct {
}

type MetricStorage interface {
	ObserveDuration(method string, duration time.Duration)
	ObserveRequestBodySize(method string, size int)
	ObserveResponseBodySize(method string, size int)
	CountStatusCode(endpoint string, code codes.Code)
}

type ParamBuilder func(ctx context.Context, message *isp.Message) (any, error)

type ParamMapper struct {
	Type    string
	Builder ParamBuilder
}

type RequestBodyExtractor interface {
	Extract(ctx context.Context, message *isp.Message, reqBodyType reflect.Type) (reflect.Value, error)
}

type ResponseBodyMapper interface {
	Map(result any) (*isp.Message, error)
}

type Validator interface {
	Validate(value any) (bool, map[string]string)
}

type Wrapper struct {
	ParamMappers  map[string]ParamMapper
	BodyExtractor RequestBodyExtractor
	BodyMapper    ResponseBodyMapper
	Middlewares   []grpc.Middleware
}