lokerpc

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

type DecodeRequestFunc func(context.Context, json.RawMessage) (request interface{}, err error)

type EncodeResponseFunc func(context.Context, interface{}) (response json.RawMessage, err error)

type Endpoint func(ctx context.Context, request interface{}) (response interface{}, err error)

type EndpointCodec struct {
	Endpoint   Endpoint
	Decode     DecodeRequestFunc
	Help       string
	ParamNames []string
	// contains filtered or unexported fields
}

type EndpointCodecMap map[string]EndpointCodec

type EndpointCodecOption func(*EndpointCodec)

type EndpointMeta struct {
	MethodName      string      `json:"methodName"`
	ParamNames      []string    `json:"paramNames"`
	MethodTimeout   int         `json:"methodTimeout"`
	Help            string      `json:"help"`
	RequestTypeDef  *jtd.Schema `json:"requestTypeDef,omitempty"`
	ResponseTypeDef *jtd.Schema `json:"responseTypeDef,omitempty"`
}

type Failer interface {
	Failed() error
}

type Meta struct {
	ServiceName string                `json:"serviceName"`
	MultiArg    bool                  `json:"multiArg"`
	Help        string                `json:"help"`
	Interfaces  []EndpointMeta        `json:"interfaces"`
	Definitions map[string]jtd.Schema `json:"definitions,omitempty"`
}

type Mux interface {
	Handle(pattern string, handler http.Handler)
}

type NamedSchema struct {
	Name    string
	SortKey string
	Schema  jtd.Schema
}

type Resulter interface {
	Result() interface{}
}

type RootMeta struct {
	Services []*Meta `json:"services"`
}

type Service struct {
	Name string
	Help string
	// contains filtered or unexported fields
}

type StandardMethod[Req any, Res any] func(context.Context, Req) (Res, error)

type VoidMethod[Req any] func(context.Context, Req) error