Documentation ¶
Index ¶
- Constants
- Variables
- type Conn
- type 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
- type NodeInfo
- type Timout
Constants ¶
View Source
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 ¶
View Source
var ErrServiceAlreadyRunning = errors.New("service already running")
Functions ¶
This section is empty.
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 }
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) 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) 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)
Click to show internal directories.
Click to hide internal directories.