micro

Documentation

Index

• Variables
• func AddEndpoint(subject string, group micro.Group, fn Handler, opts ...EndpointOption) error
• func MicroOptions(cfg micro.Config) *microOpts
• func UUIDMapper(t reflect.Type) []reflect.StructField
• type AttacherFunc
• type AttacherListFunc
• type ContextFunc
• type DecoderFunc
• type EncoderFunc
• type 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
  • func WrapEndpointOptions(mo MicroEndpointConfig, subject string, baseOptions []EndpointOption) []EndpointOption
• type ErrorFunc
• type Handler
  • func WrapTypedEndpoint[R any, T any](fn HandlerTyped[R, T]) Handler
• type HandlerTyped
• type MicroEndpointConfig
• type MicroOption
  • func WithErrorFunc(fn ErrorFunc) MicroOption
  • func WithMicroLogger(logger *zap.SugaredLogger) MicroOption
  • func WithMicroMiddlewares(mws ...Middleware) MicroOption
• type Middleware
• type Schema
  • func GenerateJsonSchema(reflector jsonschema.Reflector, req interface{}, res interface{}) (*Schema, error)
• type ServiceError
  • func NewError(err error, code string, body []byte, headers map[string][]string) *ServiceError
  • func (e *ServiceError) Error() string
  • func (e *ServiceError) ErrorParts() (string, string, []byte, micro.Headers)

Variables

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

Functions

func AddEndpoint

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

func MicroOptions

func MicroOptions(cfg micro.Config) *microOpts

func UUIDMapper

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

Types

type AttacherFunc

type AttacherFunc func(ctx context.Context, mcfg MicroEndpointConfig, group micro.Group) error

type AttacherListFunc

type AttacherListFunc func() []AttacherFunc

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 AttacherListFunc

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

func WrapEndpointOptions

func WrapEndpointOptions(mo MicroEndpointConfig, subject string, baseOptions []EndpointOption) []EndpointOption

type ErrorFunc

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

type Handler

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

func WrapTypedEndpoint

func WrapTypedEndpoint[R any, T any](fn HandlerTyped[R, T]) Handler

type HandlerTyped

type HandlerTyped[R any, T any] func(ctx context.Context, req R) (T, error)

type MicroEndpointConfig

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

type MicroOption

type MicroOption func(*microOpts) error

func WithErrorFunc

func WithErrorFunc(fn ErrorFunc) MicroOption

func WithMicroLogger

func WithMicroLogger(logger *zap.SugaredLogger) MicroOption

func WithMicroMiddlewares

func WithMicroMiddlewares(mws ...Middleware) 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)

type ServiceError

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

func NewError

func NewError(err error, code string, body []byte, headers map[string][]string) *ServiceError

func (*ServiceError) Error

func (e *ServiceError) Error() string

func (*ServiceError) ErrorParts

func (e *ServiceError) ErrorParts() (string, string, []byte, micro.Headers)