cluster

Documentation

Index

• func MachineId() string
• func NewClient(remoteMachine *Machine, localMachine *Machine, context *core.Context) *client
• func UnmarshalJsonBody(re *http.Request, v any) error
• type ClientOperate
  • func NewClientOperate(context *core.Context, localMachine *Machine) *ClientOperate
  • func (ms *ClientOperate) Query(parameter *core.Parameter, localValue any) []any
• type LiteMachine
• type Machine
• type MultiMessage
• type Response
• type Server
  • func NewServer() *Server
  • func (server *Server) Init(context *core.Context)
  • func (server *Server) Name() string
  • func (server *Server) Query(parameter *core.Parameter, localValue any) []any
  • func (server *Server) Start() error
  • func (server *Server) WriteSyncMessage(iMessage message.IMessage) (fa bool, err error)
• type User
  • func NewUser(MachineId string, UserId string) *User

Functions

func MachineId

func MachineId() string

func NewClient

func NewClient(remoteMachine *Machine, localMachine *Machine, context *core.Context) *client

func UnmarshalJsonBody

func UnmarshalJsonBody(re *http.Request, v any) error

Types

type ClientOperate

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

func NewClientOperate

func NewClientOperate(context *core.Context, localMachine *Machine) *ClientOperate

func (*ClientOperate) Query

func (ms *ClientOperate) Query(parameter *core.Parameter, localValue any) []any

type LiteMachine

type LiteMachine struct {
	Link      string
	MachineId string
}

type Machine

type Machine struct {
	Link      string
	MachineId string
	IsLocal   bool
	Scheme    string
	Address   string
	Port      int
	// contains filtered or unexported fields
}

type MultiMessage

type MultiMessage struct {
	From   string
	ToUser []string
	Text   string
}

type Response

type Response struct {
	Code int
	Msg  string
}

type Server

type Server struct {
	core.IForward
	core.IHttpServer
	// contains filtered or unexported fields
}

func NewServer

func NewServer() *Server

func (*Server) Init

func (server *Server) Init(context *core.Context)

func (*Server) Name

func (server *Server) Name() string

func (*Server) Query

func (server *Server) Query(parameter *core.Parameter, localValue any) []any

func (*Server) Start

func (server *Server) Start() error

func (*Server) WriteSyncMessage

func (server *Server) WriteSyncMessage(iMessage message.IMessage) (fa bool, err error)

type User

type User struct {
	MachineId string
	UserId    string
}

func NewUser

func NewUser(MachineId string, UserId string) *User