apphost

package

v0.0.0 Latest Latest Go to latest Published: Jul 22, 2024 License: MIT Imports: 21 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cryptopunkscc/portal

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Adapter
type Conn
type Factory
- func NewFactory(invoke target.Dispatch) *Factory
- func (f Factory) NewAdapter(ctx context.Context, portal target.Portal) target.Apphost
- func (f Factory) WithTimeout(ctx context.Context, portal target.Portal) target.Apphost
type Invoker
- func NewInvoker(ctx context.Context, flat *Adapter, invoke target.Dispatch) (i *Invoker)
- func (inv *Invoker) Close() error
- func (inv *Invoker) Query(identity string, query string) (data string, err error)
type Listener
type Timout
- func NewTimout(timeout time.Duration, onTimeout func()) *Timout

Constants ¶

This section is empty.

Variables ¶

View Source

var ConnectionsThreshold = -1

Functions ¶

This section is empty.

Types ¶

type Adapter ¶

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

func (*Adapter) Close ¶

func (api *Adapter) Close() error

func (*Adapter) ConnAccept ¶

func (api *Adapter) ConnAccept(service string) (data string, err error)

func (*Adapter) ConnClose ¶

func (api *Adapter) ConnClose(id string) (err error)

func (*Adapter) ConnRead ¶

func (api *Adapter) ConnRead(id string) (data string, err error)

func (*Adapter) ConnWrite ¶

func (api *Adapter) ConnWrite(id string, data string) (err error)

func (*Adapter) Connections ¶

func (api *Adapter) Connections() (c []target.ApphostConn)

func (*Adapter) Events ¶

func (api *Adapter) Events() *sig.Queue[target.ApphostEvent]

func (*Adapter) Interrupt ¶

func (api *Adapter) Interrupt()

func (*Adapter) Listeners ¶

func (api *Adapter) Listeners() (l []target.ApphostListener)

func (*Adapter) Log ¶

func (api *Adapter) Log(arg ...any)

func (*Adapter) LogArr ¶

func (api *Adapter) LogArr(arg []any)

func (*Adapter) NodeInfo ¶

func (api *Adapter) NodeInfo(identity string) (info target.NodeInfo, err error)

func (*Adapter) Port ¶

func (api *Adapter) Port(service ...string) string

func (*Adapter) Query ¶

func (api *Adapter) Query(identity string, query string) (data string, err error)

func (*Adapter) QueryName ¶

func (api *Adapter) QueryName(name string, query string) (data string, err error)

func (*Adapter) Resolve ¶

func (api *Adapter) Resolve(name string) (id string, err error)

func (*Adapter) ServiceClose ¶

func (api *Adapter) ServiceClose(service string) (err error)

func (*Adapter) ServiceRegister ¶

func (api *Adapter) ServiceRegister(service string) (err error)

func (*Adapter) Sleep ¶

func (api *Adapter) Sleep(duration int64)

type Conn ¶

type Conn struct {
	*bufio.Reader
	io.WriteCloser
	// contains filtered or unexported fields
}

type Factory ¶

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

func NewFactory ¶

func NewFactory(invoke target.Dispatch) *Factory

func (Factory) NewAdapter ¶

func (f Factory) NewAdapter(ctx context.Context, portal target.Portal) target.Apphost

func (Factory) WithTimeout ¶

func (f Factory) WithTimeout(ctx context.Context, portal target.Portal) target.Apphost

type Invoker ¶

type Invoker struct {
	*Adapter
	// contains filtered or unexported fields
}

func NewInvoker ¶

func NewInvoker(
	ctx context.Context,
	flat *Adapter,
	invoke target.Dispatch,
) (i *Invoker)

func (*Invoker) Close ¶

func (inv *Invoker) Close() error

func (*Invoker) Query ¶

func (inv *Invoker) Query(identity string, query string) (data string, err error)

type Listener ¶

type Listener struct {
	*astral.Listener
	// contains filtered or unexported fields
}

type Timout ¶

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

func NewTimout ¶

func NewTimout(timeout time.Duration, onTimeout func()) *Timout

func (*Timout) Enable ¶

func (t *Timout) Enable(value bool)

func (*Timout) Start ¶

func (t *Timout) Start()

func (*Timout) Stop ¶

func (t *Timout) Stop()

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL