jsonnet

package

v0.4.9 Latest Latest Go to latest Published: Jun 9, 2025 License: AGPL-3.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func InitClient(host string, port int, msgCB MsgCB, opts ...CommOption) (*Comm, error)

func InitComm(conn net.Conn, msgCB MsgCB, opts ...CommOption) (*Comm, error)

func (c *Comm) Run(ctx context.Context) error

func (c *Comm) Send(msg any) error

type CommCB func(ctx context.Context, initF InitCommF) error

type CommOption func(*Comm)

func CommWithLogger(logger *slog.Logger) CommOption

func CommWithLoggerWith(args ...any) CommOption

type InitCommF func(msgCB MsgCB, opts ...CommOption) (*Comm, error)

type MsgCB func(ctx context.Context, msg json.RawMessage)

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

func InitServer(listen string, port int, commCB CommCB, opts ...ServerOption) (*Server, error)

func (s *Server) Accept(ctx context.Context) error

type ServerOption func(*Server)

func ServerWithLogger(logger *slog.Logger) ServerOption