api

Nov 7, 2023

Changes in this version

+ var ErrMissingScheme = errors.New("the Routes filter requires a non-empty `schemes` tag")

Aug 17, 2023

Changes in this version

+ type Late struct

+ Value any

Jul 3, 2023

Changes in this version

type UnknownTypeIdError

+ Cause error

May 26, 2023

Changes in this version

+ var ErrMissingBoundary = errors.New(`multipart: missing "boundary" parameter`)

+ var NoPolymorphism = miruken.Options(Options{ ... })

+ func FormatMediaType(format *maps.Format) string

+ func MergeHeader(header textproto.MIMEHeader, metadata map[string]any)

+ func NewHeader(metadata map[string]any) textproto.MIMEHeader

+ func ParseMediaType(mediaType string, direction maps.Direction) (*maps.Format, error)

+ type Content interface

+ Body func() any

+ MediaType func() string

+ Metadata func() map[string]any

type MultipartMapper

+ func (m *MultipartMapper) Write(_ ..., msg Message, it *maps.It, ctx miruken.HandleContext) (io.Writer, error)

+ func (m *MultipartMapper) WriteParts(_ ..., pc PartContainer, it *maps.It, ctx miruken.HandleContext) (io.Writer, error)

type PartBuilder

+ func (b *PartBuilder) Body(body any) *PartBuilder

+ func (b *PartBuilder) MediaType(mediaType string) *PartBuilder

+ func (b *PartBuilder) MetadataStrings(metadata map[string][]string) *PartBuilder

type ReadPartsBuilder

+ func (b *ReadPartsBuilder) AddParts(parts map[string][]Part) *ReadPartsBuilder

+ func (b *ReadPartsBuilder) NewPart() *PartBuilder

type WritePartsBuilder

+ func (b *WritePartsBuilder) MediaType(mediaType string) *WritePartsBuilder

Mar 13, 2023

Changes in this version

+ type MultipartMapper struct

+ func (m *MultipartMapper) Read(_ ..., reader io.Reader, it *maps.It, ctx miruken.HandleContext) (Message, error)

+ type Part interface

+ Content func() any

+ ContentType func() string

+ Filename func() string

+ Metadata func() map[string][]string

+ type PartBuilder struct

+ func (b *PartBuilder) Build() Part

+ func (b *PartBuilder) Content(content any) *PartBuilder

+ func (b *PartBuilder) ContentType(contentType string) *PartBuilder

+ func (b *PartBuilder) Filename(filename string) *PartBuilder

+ func (b *PartBuilder) Metadata(metadata map[string][]string) *PartBuilder

+ type PartContainer interface

+ ContentType func() string

+ MainPart func() Part

+ Metadata func() map[string][]string

+ Parts func() map[string]Part

+ type ReadPartsBuilder struct

+ func (b *ReadPartsBuilder) AddPart(key string, part Part) *ReadPartsBuilder

+ func (b *ReadPartsBuilder) Build() PartContainer

+ func (b *ReadPartsBuilder) MainPart(main Part) *ReadPartsBuilder

+ func (b *ReadPartsBuilder) Metadata(metadata map[string][]string) *ReadPartsBuilder

+ type WritePartsBuilder struct

+ func (b *WritePartsBuilder) Build() PartContainer

+ func (b *WritePartsBuilder) ContentType(contentType string) *WritePartsBuilder

Feb 21, 2023

Changes in this version

+ func ParseContentType(contentType string, direction maps.Direction) (*maps.Format, error)

+ type GoPolymorphism struct

+ func (m *GoPolymorphism) Dynamic(_ ..., create *creates.It, ctx miruken.HandleContext) any

+ func (m *GoPolymorphism) Static(_ ..., create *creates.It) any

+ func (m *GoPolymorphism) TypeInfo(_ ..., maps *maps.It) (TypeFieldInfo, error)

Feb 12, 2023

Changes in this version

+ var FromJson = maps.From("application/json")

+ var ToJson = maps.To("application/json")

+ type GoPolymorphismMapper struct

+ func (m *GoPolymorphismMapper) Dynamic(_ ..., create *creates.It, ctx miruken.HandleContext) any

+ func (m *GoPolymorphismMapper) Static(_ ..., create *creates.It) any

+ func (m *GoPolymorphismMapper) TypeInfo(_ ..., maps *maps.It) (TypeFieldInfo, error)

+ type MalformedErrorError struct

+ Culprit any

+ func (e *MalformedErrorError) Error() string

type Options

+ TypeFieldValue string

type Scheduler

+ func (s *Scheduler) Concurrent(_ *handles.It, concurrent ConcurrentBatch, composer miruken.Handler) *promise.Promise[ScheduledResult]

+ func (s *Scheduler) New(_ ..., create *creates.It) any

+ func (s *Scheduler) Publish(_ *handles.It, publish Published, composer miruken.Handler) (p *promise.Promise[miruken.Void], err error)

+ func (s *Scheduler) Sequential(_ *handles.It, sequential SequentialBatch, composer miruken.Handler) *promise.Promise[ScheduledResult]

+ type Surrogate interface

+ Original func() any

type TypeFieldInfo

+ TypeField string

+ TypeValue string

+ ValuesField string

Jan 27, 2023

Changes in this version

+ type UnknownTypeIdError struct

+ Reason error

+ TypeId string

+ func (e *UnknownTypeIdError) Error() string

+ func (e *UnknownTypeIdError) Unwrap() error

Jan 23, 2023

Changes in this version

type GoTypeFieldInfoMapper

+ func (m *GoTypeFieldInfoMapper) TypeFieldInfo(_ ..., maps *miruken.Maps) (TypeFieldInfo, error)

type Options

+ Polymorphism miruken.Option[Polymorphism]

+ type Polymorphism uint8

+ const PolymorphismNone

+ const PolymorphismRoot

Jan 22, 2023

Changes in this version

+ var Polymorphic miruken.Builder = miruken.Options(Options{ ... })

+ type GoTypeFieldInfoMapper struct

+ func (m *GoTypeFieldInfoMapper) GoTypeInfo(_ ..., maps *miruken.Maps) (TypeFieldInfo, error)

Jan 22, 2023

Changes in this version

+ type Options struct

+ PolymorphicHandling miruken.Option[PolymorphicHandling]

+ TypeInfoFormat string

Jan 21, 2023

Changes in this version

+ var ToTypeInfo = miruken.To("type:info")

+ type GoTypeFieldMapper struct

+ func (m *GoTypeFieldMapper) GoTypeInfo(_ ..., maps *miruken.Maps) (TypeFieldInfo, error)

type PolymorphicOptions

+ TypeInfoFormat string

+ type TypeFieldInfo struct

+ Field string

+ Value string

Jan 2, 2023

Changes in this version

+ var FromError = miruken.To("api:error")

+ var ToError = miruken.From("api:error")

+ type ErrorData struct

+ Message string

+ type Message struct

+ Payload any

+ type PolymorphicHandling uint8

+ const PolymorphicHandlingNone

+ const PolymorphicHandlingRoot

+ type PolymorphicOptions struct

+ PolymorphicHandling miruken.Option[PolymorphicHandling]

Nov 1, 2022

Changes in this version

+ var ErrMissingResponse = errors.New("missing batch response")

+ func Concurrent(handler miruken.Handler, requests ...any) *promise.Promise[[]either.Either[error, any]]

+ func Failure(val error) either.Either[error, any]

+ func Feature(config ...func(installer *Installer)) miruken.Feature

+ func Post(handler miruken.Handler, message any) (p *promise.Promise[miruken.Void], err error)

+ func Publish(handler miruken.Handler, message any) (p *promise.Promise[miruken.Void], err error)

+ func Send(handler miruken.Handler, request any) (r TResponse, pr *promise.Promise[TResponse], err error)

+ func Sequential(handler miruken.Handler, requests ...any) *promise.Promise[[]either.Either[error, any]]

+ func StashDrop(handler miruken.Handler) error

+ func StashDropKey(handler miruken.Handler, key any) (err error)

+ func StashGet(handler miruken.Handler) (t T, ok bool)

+ func StashGetKey(handler miruken.Handler, key any) (val any, ok bool)

+ func StashGetOrPut(handler miruken.Handler, val T) (T, error)

+ func StashGetOrPutFunc(handler miruken.Handler, fun func() (T, *promise.Promise[T])) (T, *promise.Promise[T], error)

+ func StashGetOrPutKey(handler miruken.Handler, key any, val any) (any, error)

+ func StashGetOrPutKeyFunc(handler miruken.Handler, key any, fun func() (any, *promise.Promise[any])) (any, *promise.Promise[any], error)

+ func StashPut(handler miruken.Handler, val T) error

+ func StashPutKey(handler miruken.Handler, key any, val any) error

+ func Success(val R) either.Either[error, R]

+ type ConcurrentBatch struct

+ Requests []any

+ type Installer struct

+ func (v *Installer) Install(setup *miruken.SetupBuilder) error

+ type PassThroughRouter struct

+ func (p *PassThroughRouter) Pass(_ ..., routed Routed, composer miruken.Handler) (any, miruken.HandleResult)

+ type Published struct

+ Message any

+ type RouteReply struct

+ Responses []any

+ Uri string

+ type Routed struct

+ Message any

+ Route string

+ func RouteTo(message any, route string) Routed

+ type Routes struct

+ func (r *Routes) AppliesTo(callback miruken.Callback) bool

+ func (r *Routes) Filters(binding miruken.Binding, callback any, composer miruken.Handler) ([]miruken.Filter, error)

+ func (r *Routes) InitWithTag(tag reflect.StructTag) error

+ func (r *Routes) Required() bool

+ func (r *Routes) Satisfies(routed Routed) bool

+ type ScheduledResult struct

+ Responses []either.Either[error, any]

+ type Scheduler struct

+ func (s *Scheduler) Constructor(_ ...)

+ func (s *Scheduler) HandleConcurrent(_ *miruken.Handles, concurrent ConcurrentBatch, composer miruken.Handler) *promise.Promise[ScheduledResult]

+ func (s *Scheduler) HandlePublish(_ *miruken.Handles, publish Published, composer miruken.Handler) (p *promise.Promise[miruken.Void], err error)

+ func (s *Scheduler) HandleSequential(_ *miruken.Handles, sequential SequentialBatch, composer miruken.Handler) *promise.Promise[ScheduledResult]

+ type SequentialBatch struct

+ Requests []any

+ type Stash struct

+ func NewStash(root bool) *Stash

+ func (s *Stash) Drop(_ *miruken.Handles, drop *stashDrop)

+ func (s *Stash) Get(_ *miruken.Handles, get *stashGet) miruken.HandleResult

+ func (s *Stash) NoConstructor()

+ func (s *Stash) Provide(_ ..., provides *miruken.Provides) any

+ func (s *Stash) Put(_ *miruken.Handles, put *stashPut)