cluster

package

v0.4.2 Latest Latest Go to latest Published: Aug 6, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Details

This section is empty.

This section is empty.

func MachineId() string

func NewRequest() *request

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

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

func NewHttpClient() *HttpClient

func (client *HttpClient) Call(machine *Machine, path string, jsonData []byte) (data []byte, err error)

func (client *HttpClient) CallByLink(link string, path string, jsonData []byte) (data []byte, err error)

type Machine struct {
	Link      string
	MachineId string
}

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

func NewMachineStore(context *core.Context) *MachineStore

func (machineStore *MachineStore) GetMachineLink(machineId string) string

func (machineStore *MachineStore) GetMachineNum() int

func (machineStore *MachineStore) GetMachines() []*Machine

func (machineStore *MachineStore) GetTempMachines() []*Machine

func (machineStore *MachineStore) Query(parameter *core.Parameter, localValue any) []any

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

func NewMachines() *Machines

type Response struct {
	Code int
	Msg  string
}

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

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)