socket

package

v0.0.2 Latest Latest Go to latest Published: Sep 5, 2025 License: AGPL-3.0 Imports: 18 Imported by: 0

Details

View Source

const EOL = "\r\n"

View Source

const ProtoVersion = "1.0"

View Source

var ErrComplete = errors.New("scroll complete")

View Source

var ErrFatal = errors.New("fatal error")

View Source

var ServerVersion = "Chronalys/1.0"

func ServeSocket(ctx context.Context) (func() error, error)

type ErrorCode string

const (
	OK      ErrorCode = "OK"
	Info    ErrorCode = "INFO"
	Warning ErrorCode = "WARN"
	Fatal   ErrorCode = "FATAL"
)

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

func ParseExecute(cmd commands.Command) (*Execute, error)

func (e *Execute) Handle(s *Socket) error

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

func ParsePrepare(query *commands.CommandString) (*Prepare, error)

func (p *Prepare) Handle(s *Socket) error

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

func ParsePrincipal(cmd *commands.CommandString) (principal *Principal, err error)

func (p *Principal) Handle(s *Socket) error

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

func ParseQuery(cmd *commands.CommandString) (*Query, error)

func (q *Query) Handle(s *Socket) (err error)

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

func NewScanner(reader *bufio.ReadWriter) *Scanner

func (s *Scanner) Scan(ctx context.Context) (chan *commands.CommandString, chan error)

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

func ParseScroll(cmd *commands.CommandString) (scroll *Scroll, err error)

func (c *Scroll) Handle(s *Socket) error

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

func (s *Socket) Cleanup()

func (s *Socket) HandleConnection(conn net.Conn, ctx context.Context)

func (s *Socket) PerformFinalize(cmd *commands.CommandString) (err error)