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
  • func (ms *ClientOperate) SendAddUser(username string)
  • func (ms *ClientOperate) SendDeleteUser(username string)
• type LiteMachine
• type Machine
• type Response
• type Server
  • func NewServer() *Server
  • func (server *Server) GetOrderUser(username string) ([]user.IOrderUser, bool)
  • func (server *Server) HandleAddUser(iUser user.IUser)
  • func (server *Server) HandleDeleteUser(username string)
  • 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) WriteMessage(msg message.IMessage, exMachineId []string, writeFunc user.WriteCallBackFunc)
• 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

func (*ClientOperate) SendAddUser

func (ms *ClientOperate) SendAddUser(username string)

func (*ClientOperate) SendDeleteUser

func (ms *ClientOperate) SendDeleteUser(username string)

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

func (server *Server) GetOrderUser(username string) ([]user.IOrderUser, bool)

func (*Server) HandleAddUser

func (server *Server) HandleAddUser(iUser user.IUser)

func (*Server) HandleDeleteUser

func (server *Server) HandleDeleteUser(username string)

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

func (server *Server) WriteMessage(msg message.IMessage, exMachineId []string, writeFunc user.WriteCallBackFunc)

type User

type User struct {
	MachineId string
	UserId    string
}

func NewUser

func NewUser(MachineId string, UserId string) *User