apphost

Documentation

Index

• Constants
• Variables
• type Conn
• type Flat
  • func NewAdapter(ctx context.Context, serve Invoke, prefix ...string) Flat
  • func WithTimeout(ctx context.Context, serve Invoke, prefix ...string) Flat
• type FlatAdapter
  • func (api *FlatAdapter) Close() error
  • func (api *FlatAdapter) ConnAccept(service string) (data string, err error)
  • func (api *FlatAdapter) ConnClose(id string) (err error)
  • func (api *FlatAdapter) ConnRead(id string) (data string, err error)
  • func (api *FlatAdapter) ConnWrite(id string, data string) (err error)
  • func (api *FlatAdapter) Interrupt()
  • func (api *FlatAdapter) Log(arg ...any)
  • func (api *FlatAdapter) LogArr(arg []any)
  • func (api *FlatAdapter) NodeInfo(identity string) (info NodeInfo, err error)
  • func (api *FlatAdapter) Prefix() []string
  • func (api *FlatAdapter) Query(identity string, query string) (data string, err error)
  • func (api *FlatAdapter) QueryName(name string, query string) (data string, err error)
  • func (api *FlatAdapter) Resolve(name string) (id string, err error)
  • func (api *FlatAdapter) ServiceClose(service string) (err error)
  • func (api *FlatAdapter) ServiceRegister(service string) (err error)
  • func (api *FlatAdapter) Sleep(duration int64)
• type Invoke
• type Invoker
  • func NewInvoker(ctx context.Context, flat Flat, serve Invoke) (i *Invoker)
  • func (inv *Invoker) Close() error
  • func (inv *Invoker) Query(identity string, query string) (data string, err error)
• type NodeInfo
• type Timout
  • func NewTimout(timeout time.Duration, onTimeout func()) *Timout
  • func (t *Timout) Enable(value bool)
  • func (t *Timout) Start()
  • func (t *Timout) Stop()

Constants

const (
	Log             = "_log"
	Sleep           = "_sleep"
	ServiceRegister = "_astral_service_register"
	ServiceClose    = "_astral_service_close"
	ConnAccept      = "_astral_conn_accept"
	ConnClose       = "_astral_conn_close"
	ConnWrite       = "_astral_conn_write"
	ConnRead        = "_astral_conn_read"
	Query           = "_astral_query"
	QueryName       = "_astral_query_name"
	GetNodeInfo     = "_astral_node_info"
	Resolve         = "_astral_resolve"
	Interrupt       = "_astral_interrupt"
)

Variables

var ErrServiceAlreadyRunning = errors.New("service already running")

Types

type Conn

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

type Flat

type Flat interface {
	Prefix() []string
	Close() error
	Interrupt()
	Log(arg ...any)
	LogArr(arg []any)
	Sleep(duration int64)
	ServiceRegister(service string) (err error)
	ServiceClose(service string) (err error)
	ConnAccept(service string) (data string, err error)
	ConnClose(id string) (err error)
	ConnWrite(id string, data string) (err error)
	ConnRead(id string) (data string, err error)
	Query(identity string, query string) (data string, err error)
	QueryName(name string, query string) (data string, err error)
	Resolve(name string) (id string, err error)
	NodeInfo(identity string) (info NodeInfo, err error)
	// contains filtered or unexported methods
}

func NewAdapter

func NewAdapter(ctx context.Context, serve Invoke, prefix ...string) Flat

func WithTimeout

func WithTimeout(ctx context.Context, serve Invoke, prefix ...string) Flat

type FlatAdapter

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

func (*FlatAdapter) Close

func (api *FlatAdapter) Close() error

func (*FlatAdapter) ConnAccept

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

func (*FlatAdapter) ConnClose

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

func (*FlatAdapter) ConnRead

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

func (*FlatAdapter) ConnWrite

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

func (*FlatAdapter) Interrupt

func (api *FlatAdapter) Interrupt()

func (*FlatAdapter) Log

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

func (*FlatAdapter) LogArr

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

func (*FlatAdapter) NodeInfo

func (api *FlatAdapter) NodeInfo(identity string) (info NodeInfo, err error)

func (*FlatAdapter) Prefix

func (api *FlatAdapter) Prefix() []string

func (*FlatAdapter) Query

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

func (*FlatAdapter) QueryName

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

func (*FlatAdapter) Resolve

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

func (*FlatAdapter) ServiceClose

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

func (*FlatAdapter) ServiceRegister

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

func (*FlatAdapter) Sleep

func (api *FlatAdapter) Sleep(duration int64)

type Invoke

type Invoke func(prefix ...string) func(ctx context.Context) (func(query string), error)

type Invoker

type Invoker struct {
	Flat
	// contains filtered or unexported fields
}

func NewInvoker

func NewInvoker(
	ctx context.Context,
	flat Flat,
	serve Invoke,
) (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 NodeInfo

type NodeInfo struct {
	Identity string
	Name     string
}

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()