Versions in this module Expand all Collapse all v0 v0.25.1 Mar 8, 2025 Changes in this version + func CatchPanics(r interface{}) error + func ComponentConfigValidator(path, cfg string) error + func ExtractEdges(data []byte) [][2]string + func MakeEdgeString(src, dst string) string + func MakeListenersString(component string, listeners []string) string + func Register(reg Registration) + func RegisterSerializable[T AutoMarshal]() + type AutoMarshal interface + WeaverMarshal func(enc *Encoder) + WeaverUnmarshal func(dec *Decoder) + type CallEdge struct + Callee reflect.Type + Caller reflect.Type + func CallGraph() []CallEdge + type ComponentListeners struct + Component string + Listeners []string + func ExtractListeners(data []byte) []ComponentListeners + type Decoder struct + func NewDecoder(data []byte) *Decoder + func (d *Decoder) Bool() bool + func (d *Decoder) Byte() byte + func (d *Decoder) Bytes() []byte + func (d *Decoder) Complex128() complex128 + func (d *Decoder) Complex64() complex64 + func (d *Decoder) DecodeBinaryUnmarshaler(value encoding.BinaryUnmarshaler) + func (d *Decoder) DecodeProto(value proto.Message) + func (d *Decoder) Empty() bool + func (d *Decoder) Error() error + func (d *Decoder) Float32() float32 + func (d *Decoder) Float64() float64 + func (d *Decoder) Int() int + func (d *Decoder) Int16() int16 + func (d *Decoder) Int32() int32 + func (d *Decoder) Int64() int64 + func (d *Decoder) Int8() int8 + func (d *Decoder) Interface() any + func (d *Decoder) Len() int + func (d *Decoder) Read(n int) []byte + func (d *Decoder) Rune() rune + func (d *Decoder) String() string + func (d *Decoder) Uint() uint + func (d *Decoder) Uint16() uint16 + func (d *Decoder) Uint32() uint32 + func (d *Decoder) Uint64() uint64 + func (d *Decoder) Uint8() uint8 + type Encoder struct + func NewEncoder() *Encoder + func (e *Encoder) Bool(arg bool) + func (e *Encoder) Byte(arg byte) + func (e *Encoder) Bytes(arg []byte) + func (e *Encoder) Complex128(arg complex128) + func (e *Encoder) Complex64(arg complex64) + func (e *Encoder) Data() []byte + func (e *Encoder) EncodeBinaryMarshaler(value encoding.BinaryMarshaler) + func (e *Encoder) EncodeProto(value proto.Message) + func (e *Encoder) Error(err error) + func (e *Encoder) Float32(arg float32) + func (e *Encoder) Float64(arg float64) + func (e *Encoder) Grow(bytesNeeded int) []byte + func (e *Encoder) Int(arg int) + func (e *Encoder) Int16(arg int16) + func (e *Encoder) Int32(arg int32) + func (e *Encoder) Int64(arg int64) + func (e *Encoder) Int8(arg int8) + func (e *Encoder) Interface(value AutoMarshal) + func (e *Encoder) Len(l int) + func (e *Encoder) Reset(n int) + func (e *Encoder) Rune(arg rune) + func (e *Encoder) String(arg string) + func (e *Encoder) Uint(arg uint) + func (e *Encoder) Uint16(arg uint16) + func (e *Encoder) Uint32(arg uint32) + func (e *Encoder) Uint64(arg uint64) + func (e *Encoder) Uint8(arg uint8) + type Hasher struct + func (h *Hasher) Sum64() uint64 + func (h *Hasher) WriteFloat32(v float32) + func (h *Hasher) WriteFloat64(v float64) + func (h *Hasher) WriteInt(v int) + func (h *Hasher) WriteInt16(v int16) + func (h *Hasher) WriteInt32(v int32) + func (h *Hasher) WriteInt64(v int64) + func (h *Hasher) WriteInt8(v int8) + func (h *Hasher) WriteString(v string) + func (h *Hasher) WriteUint(v uint) + func (h *Hasher) WriteUint16(v uint16) + func (h *Hasher) WriteUint32(v uint32) + func (h *Hasher) WriteUint64(v uint64) + func (h *Hasher) WriteUint8(v uint8) + type LatestVersion = Version[[version.CodegenMajor][version.CodegenMinor]struct{}] + type MethodCallHandle struct + type MethodLabels struct + Caller string + Component string + Generated bool + Method string + Remote bool + type MethodMetrics struct + func MethodMetricsFor(labels MethodLabels) *MethodMetrics + func (m *MethodMetrics) Begin() MethodCallHandle + func (m *MethodMetrics) End(h MethodCallHandle, failed bool, requestBytes, replyBytes int) + type OrderedCode string + const Infinity + type OrderedEncoder struct + func (e *OrderedEncoder) Encode() OrderedCode + func (e *OrderedEncoder) Reset() + func (e *OrderedEncoder) WriteFloat32(f float32) + func (e *OrderedEncoder) WriteFloat64(f float64) + func (e *OrderedEncoder) WriteInt(x int) + func (e *OrderedEncoder) WriteInt16(x int16) + func (e *OrderedEncoder) WriteInt32(x int32) + func (e *OrderedEncoder) WriteInt64(x int64) + func (e *OrderedEncoder) WriteInt8(x int8) + func (e *OrderedEncoder) WriteString(s string) + func (e *OrderedEncoder) WriteUint(x uint) + func (e *OrderedEncoder) WriteUint16(x uint16) + func (e *OrderedEncoder) WriteUint32(x uint32) + func (e *OrderedEncoder) WriteUint64(x uint64) + func (e *OrderedEncoder) WriteUint8(x uint8) + type Registration struct + ClientStubFn func(stub Stub, caller string) any + Iface reflect.Type + Impl reflect.Type + Listeners []string + LocalStubFn func(impl any, caller string, tracer trace.Tracer) any + Name string + NoRetry []int + RefData string + ReflectStubFn func(func(method string, ctx context.Context, args []any, returns []any) error) any + Routed bool + RoutedLocalStubFn func(impl any, stub Stub, caller string, tracer trace.Tracer, ...) any + ServerStubFn func(impl any, load func(key uint64, load float64)) Server + func Find(name string) (*Registration, bool) + func Registered() []*Registration + type Server interface + GetStubFn func(method string) func(ctx context.Context, args []byte) ([]byte, error) + type Stub interface + Run func(ctx context.Context, method int, args []byte, shardKey uint64) (results []byte, err error) + Tracer func() trace.Tracer + type Version string
Go to main page