akasar

README

akasa

Documentation

Index

• Constants
• Variables
• func GetSingleton[T any]()
• func InstrumentHandler(label string, handler http.Handler) http.Handler
• func InstrumentHandlerFunc(label string, f func(w http.ResponseWriter, r *http.Request)) http.Handler
• func Run[T any, P PointerToRoot[T]](ctx context.Context, app func(context.Context, *T) error) error
• type AutoMarshal
  • func (*AutoMarshal) AkasarMarshal(enc *codegen.Serializer)
  • func (*AutoMarshal) AkasarUnmarshal(enc *codegen.Deserializer)
• type Components
  • func (c *Components[T]) Logger(ctx context.Context) *slog.Logger
• type DoneFunc
• type DoneInfo
• type Endpoint
• type Initializer
• type Injector
• type InstanceOf
• type Listener
• type NotRetriable
• type PointerToRoot
• type Ref
  • func (r *Ref[T]) Get() T
• type Resolver
• type Result
  • func NewResult[T any](value T, errs ...error) Result[T]
  • func (r *Result[T]) Error() error
  • func (r *Result[T]) Unwrap() T
  • func (r *Result[T]) Value() T
• type Root
• type Selector
• type Singleton
• type WithConfig
  • func (wc *WithConfig[T]) Config() *T
• type WithRouter

Constants

const HealthURL = "/debug/akasar/health"

Variables

var HealthHandler = func(w http.ResponseWriter, _ *http.Request) {
	_, _ = fmt.Fprintf(w, "OK")
}

var RemoteCallError = errors.New("service akasar remote call error")

Functions

func GetSingleton

func GetSingleton[T any]()

func InstrumentHandler

func InstrumentHandler(label string, handler http.Handler) http.Handler

func InstrumentHandlerFunc

func InstrumentHandlerFunc(label string, f func(w http.ResponseWriter, r *http.Request)) http.Handler

func Run

func Run[T any, P PointerToRoot[T]](ctx context.Context, app func(context.Context, *T) error) error

Types

type AutoMarshal

type AutoMarshal struct {
}

func (*AutoMarshal) AkasarMarshal

func (*AutoMarshal) AkasarMarshal(enc *codegen.Serializer)

func (*AutoMarshal) AkasarUnmarshal

func (*AutoMarshal) AkasarUnmarshal(enc *codegen.Deserializer)

type Components

type Components[T any] struct {
	// contains filtered or unexported fields
}

func (*Components[T]) Logger

func (c *Components[T]) Logger(ctx context.Context) *slog.Logger

type DoneFunc

type DoneFunc func(ctx context.Context, di DoneInfo)

type DoneInfo

type DoneInfo struct {
	Err           error
	BytesSent     bool
	BytesReceived bool
}

type Endpoint

type Endpoint interface {
	Call(ctx context.Context, data []byte) ([]byte, error)
	Close() error
	Name() string
}

type Initializer

type Initializer interface {
	Init(context.Context) error
}

type Injector

type Injector[T any] interface {
	New(context.Context) (T, error)
}

type InstanceOf

type InstanceOf[T any] interface {
	// contains filtered or unexported methods
}

InstanceOf 组件实例标识

type Listener

type Listener struct {
	net.Listener
	// contains filtered or unexported fields
}

type NotRetriable

type NotRetriable interface {
}

type PointerToRoot

type PointerToRoot[T any] interface {
	*T
	InstanceOf[Root]
}

type Ref

type Ref[T any] struct {
	// contains filtered or unexported fields
}

func (*Ref[T]) Get

func (r *Ref[T]) Get() T

type Resolver

type Resolver interface {
	Resolve(ctx context.Context, target string) ([]Endpoint, error)
	Scheme() string
}

type Result

type Result[T any] struct {
	// contains filtered or unexported fields
}

func NewResult

func NewResult[T any](value T, errs ...error) Result[T]

func (*Result[T]) Error

func (r *Result[T]) Error() error

func (*Result[T]) Unwrap

func (r *Result[T]) Unwrap() T

func (*Result[T]) Value

func (r *Result[T]) Value() T

type Root

type Root interface {
}

type Selector

type Selector interface {
	Select(ctx context.Context) (Endpoint, DoneFunc, error)
}

type Singleton

type Singleton[T any] struct {
}

type WithConfig

type WithConfig[T any] struct {
	// contains filtered or unexported fields
}

func (*WithConfig[T]) Config

func (wc *WithConfig[T]) Config() *T

type WithRouter

type WithRouter[T any] struct {
}