ctx

type BaseCtx[TraceData any, TP TracePtr[TraceData]] struct {
	Context   context.Context
	Req       proto.Message
	Resp      proto.Message   // RPC response, acquired from pool together with Req; nil for events
	OtherResp []proto.Message // additional messages appended to the reply alongside Resp

	// for rpc reply
	NatsMsg *nats.Msg
	TD      TraceData
}

type IContext interface {
	context.Context
	define.Clear
	SetValue(any, any)
	GetTrace() Trace
	logger.ILogger
}

type IContextPtr[T any] interface {
	IContext
	*T
}

type Int64TraceCtx = BaseCtx[IntTrace, *IntTrace]

type IntTrace struct {
	basepb.IntTrace
	// contains filtered or unexported fields
}

type Trace interface {
	// GetRoleID returns the int64 role identifier used for consistent message routing.
	// The same RoleID always routes to the same worker, enabling per-entity ordering without locks.
	// A zero value means the message has no ordering requirement.
	GetRoleID() int64
	// SetRoleID overrides the RoleID on a pooled context acquired inside taskFunc.
	// Used when Data is nil and a fresh context must carry the caller's RoleID.
	SetRoleID(int64)

	TraceMarshalSize() int
	// TraceMarshalAppend marshal the object to byte slice
	TraceMarshalAppend([]byte) ([]byte, error)
	// TraceMarshalFrom unmarshal the object from byte slice
	TraceMarshalFrom([]byte) error

	TraceLogField(*logger.Event) *logger.Event

	GetServerIdAndType() (int64, string)

	SetServerIdAndType(int64, string)

	Reset()
}

type TracePtr[T any] interface {
	Trace
	*T
}