service

type DefaultService struct{}

type IAdapter interface {
	Close() error
}

type IGRPCService interface {
	GetNetConfig() *NetServiceConfig
	OnRegisterGRPCServer(*grpc.Server)
	OnListenFailed(error) time.Duration
	OnStopping()
	OnStopped()
}

type IService interface {
	Listen(ctx context.Context) (IAdapter, error)
	Serve(ctx context.Context, conn IAdapter)
	OnListenFailed(error) time.Duration
	OnStopping()
	OnStopped()
}

type ITCPService interface {
	GetAddress() string
	OnNewConnection(context.Context, net.Conn) bool // DO NOT block, start a TCPConnectionTask or handle the connection in a new goroutine if needed, return false to close the connection immediately
	OnListenFailed(error) time.Duration
	OnStopping()
	OnStopped()
}

type NetServiceConfig struct {
	Address string     `json:"address" yaml:"address"` // Listening address, e.g., ":8080"
	TLS     *TLSConfig `json:"tls" yaml:"tls"`         // [Optional] TLS configuration, if provided, the service will use TLS for secure communication
}

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

type ServiceTaskFunc func(context.Context)

type TLSConfig struct {
	Cert           string   `json:"cert" yaml:"cert"`                         // [Optional] SSL Certificate content or file path
	Key            string   `json:"key" yaml:"key"`                           // [Optional] SSL Key content or file path
	CAs            []string `json:"ca" yaml:"ca"`                             // [Optional] CA Certificates content or file path for verifying client certificates, only used when SSL is enabled
	ClientAuthType string   `json:"client_auth_type" yaml:"client_auth_type"` // [Optional] Client authentication type, can be "none", "optional", "required", "must"
}

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