micro

package

v0.0.29 Latest Latest Go to latest Published: Apr 23, 2024 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

func AddEndpoint(subject string, group micro.Group, fn Handler, opts ...EndpointOption) error

func UUIDMapper(t reflect.Type) []reflect.StructField

type ContextFunc func(context.Context, string, micro.Headers) context.Context

type DecoderFunc func(b []byte) (any, error)

type EncoderFunc func(v any) ([]byte, error)

type EndpointAttacher func(context.Context, micro.Group) error

type EndpointAttacherSet []EndpointAttacher

func (e EndpointAttacherSet) Endpoints() []EndpointAttacher

type EndpointOption func(*endpointOpts) error

func WithContext(ctx context.Context) EndpointOption

func WithContextFn(fn ContextFunc) EndpointOption

func WithDecoderFn(fn DecoderFunc) EndpointOption

func WithEncoderFn(fn EncoderFunc) EndpointOption

func WithErrFn(fn ErrorFunc) EndpointOption

func WithJsonSchema(reflector jsonschema.Reflector, req interface{}, res interface{}) EndpointOption

func WithMiddlewares(mws ...Middleware) EndpointOption

func WithTimeout(t time.Duration) EndpointOption

type Endpointer interface {
	Endpoints() []EndpointAttacher
}

type ErrorFunc func(err error) (string, string, []byte, micro.Headers)

type Handler func(ctx context.Context, req any) (any, error)

type Middleware func(Handler) Handler

type Schema struct {
	Request  string `json:"request"`
	Response string `json:"response"`
}

func GenerateJsonSchema(reflector jsonschema.Reflector, req interface{}, res interface{}) (*Schema, error)