micro

Documentation

Index

• Variables
• func AddEndpoint(subject string, group micro.Group, fn Handler, opts ...EndpointOption) error
• func DefaultMicroOptions(cfg micro.Config) *microOpts
• func UUIDMapper(t reflect.Type) []reflect.StructField
• type ContextFunc
• type DecoderFunc
• type EncoderFunc
• type EndpointAttacher
• type EndpointAttacherSet
  • func (e EndpointAttacherSet) Endpoints() []EndpointAttacher
• type EndpointOption
  • 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 WithLogger(logger *zap.SugaredLogger, args ...interface{}) EndpointOption
  • func WithLoggerRequestFields(args ...interface{}) EndpointOption
  • func WithMiddlewares(mws ...Middleware) EndpointOption
  • func WithTimeout(t time.Duration) EndpointOption
• type Endpointer
• type ErrorFunc
• type Handler
• type MicroOption
  • func WithErrorFunc(fn ErrorFunc) MicroOption
  • func WithMicroLogger(logger *zap.SugaredLogger) MicroOption
• type Middleware
• type Schema
  • func GenerateJsonSchema(reflector jsonschema.Reflector, req interface{}, res interface{}) (*Schema, error)

Variables

var (
	ErrDecodingError = errors.New("decoding error")
)

Functions

func AddEndpoint

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

func DefaultMicroOptions

func DefaultMicroOptions(cfg micro.Config) *microOpts

func UUIDMapper

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

Types

type ContextFunc

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

type DecoderFunc

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

type EncoderFunc

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

type EndpointAttacher

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

type EndpointAttacherSet

type EndpointAttacherSet []EndpointAttacher

func (EndpointAttacherSet) Endpoints

func (e EndpointAttacherSet) Endpoints() []EndpointAttacher

type EndpointOption

type EndpointOption func(*endpointOpts) error

func WithContext

func WithContext(ctx context.Context) EndpointOption

func WithContextFn

func WithContextFn(fn ContextFunc) EndpointOption

func WithDecoderFn

func WithDecoderFn(fn DecoderFunc) EndpointOption

func WithEncoderFn

func WithEncoderFn(fn EncoderFunc) EndpointOption

func WithErrFn

func WithErrFn(fn ErrorFunc) EndpointOption

func WithJsonSchema

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

func WithLogger

func WithLogger(logger *zap.SugaredLogger, args ...interface{}) EndpointOption

func WithLoggerRequestFields

func WithLoggerRequestFields(args ...interface{}) EndpointOption

func WithMiddlewares

func WithMiddlewares(mws ...Middleware) EndpointOption

func WithTimeout

func WithTimeout(t time.Duration) EndpointOption

type Endpointer

type Endpointer interface {
	Endpoints() []EndpointAttacher
}

type ErrorFunc

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

type Handler

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

type MicroOption

type MicroOption func(*microOpts) error

func WithErrorFunc

func WithErrorFunc(fn ErrorFunc) MicroOption

func WithMicroLogger

func WithMicroLogger(logger *zap.SugaredLogger) MicroOption

type Middleware

type Middleware func(Handler) Handler

type Schema

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

func GenerateJsonSchema

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