dispatcher

type AfterHandlerSelectedHook interface {
	AfterHandlerSelection(ctx context.Context, info *session.Info, rw any,
		handler i.Outbound) (context.Context, any, error)
}

type BeforeHandlerSelectionHook interface {
	BeforeHandlerSelection(ctx context.Context, info *session.Info,
		rw any) (context.Context, any, error)
}

type Dispatcher struct {
	BeforeHandlerSelectionHooks []BeforeHandlerSelectionHook
	Router                      i.Router
	OnHandlerSelectedHooks      []AfterHandlerSelectedHook
	SessionStartHooks           []SessionStartHook
	SessionEndHooks             []SessionEndHook
	TimeoutSetting              i.TimeoutSetting
	OnFallbacks                 []OnFallback
	FallbackTimeout             time.Duration

	SessionStats        bool
	RewriteIpv6ToDomain bool

	Flows       atomic.Int32
	PacketConns atomic.Int32

	HandlerErrorObservers []i.HandlerErrorObserver
	// contains filtered or unexported fields
}

type Fallback interface {
	Fallback(ctx context.Context, info *session.Info,
		rw buf.ReaderWriter, handler i.Outbound, err error) error
}

type GetCounters interface {
	GetCounters(ctx context.Context, info *session.Info, handler i.Outbound) (session.UpCounters, session.DownCounters)
}

type NullSessionErrorLogger struct{}

type OnFallback interface {
	OnFallback(info *session.Info, previousTag, tag string)
}

type OnHandlerErrorFunc func(tag string, err error)

type SessionEndHook interface {
	// should return quickly
	FlowSessionEnd(ctx context.Context, info *session.Info, err error)
	PacketConnSessionEnd(ctx context.Context, info *session.Info, err error)
}

type SessionErrorLogger interface {
	LogSessionError(info *session.Info, err error)
}

type SessionStartHook interface {
	SessionStart(ctx context.Context, info *session.Info)
}