codegen

type AutoMarshal interface {
	AkasarMarshal(enc *Serializer)
	AkasarUnmarshal(enc *Deserializer)
}

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

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

type MethodLabels struct {
	Caller    string //调用方组件全名
	Component string //组件全名
	Method    string // 方法名
	Remote    bool   //是否远程调用
}

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

type Registration struct {
	Name      string // full package-prefixed component name
	Iface     reflect.Type
	Impl      reflect.Type
	Routed    bool // True if calls to this component should be routed
	Listeners []string
	NoRetry   []int //indices of methods that should not be retried.

	LocalStubFn  func(impl any, caller string, tracer trace.Tracer) any
	ClientStubFn func(stub Stub, caller string, tracer trace.Tracer) any
	ServerStubFn func(impl any) Server
}

type Serializable interface {
	int | int8 | int16 | int32 | int64 | bool |
		uint | uint8 | uint16 | uint32 | uint64 |
		float32 | float64 |
		complex64 | complex128 |
		string |
		[]byte
}

type Serialization interface {
	Serialize([]byte) error
	Deserialize([]byte) error
}

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

type Server interface {
	GetHandleFn(method string) func(ctx context.Context, args []byte) ([]byte, error)
}

type Stub interface {

	// Invoke 执行rpc调用。
	//代码生成时, 接口方法已经排序， method 就是方法切片的索引, shardKey 是路由组件的 shard key
	Invoke(ctx context.Context, method int, args []byte, shardKey uint64) (result []byte, err error)
}