srv_repeater

package
v1.0.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 8, 2022 License: MIT Imports: 35 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CurrentExePath 

func CurrentExePath() string

func HttpPostCallReCaptcha 

func HttpPostCallReCaptcha(host string, token string) (string, error)

func SendEMail 

func SendEMail(subj string, to string, content string) error

Types

type AllNodesRequest 

type AllNodesRequest struct {
	Key string `json:"key"`
}

type AllNodesResponse 

type AllNodesResponse struct {
	Key       string   `json:"key"`
	NoChanges bool     `json:"no_changes"`
	Nodes     []string `json:"nodes"`
}

type BinFrame 

type BinFrame struct {
	Header BinFrameHeader
	Data   []byte
}

func UnmarshalBinFrame 

func UnmarshalBinFrame(frameBytes []byte) (*BinFrame, error)

func (*BinFrame) Marshal 

func (c *BinFrame) Marshal() ([]byte, error)

type BinFrameHeader 

type BinFrameHeader struct {
	TargetNodeId   string `json:"n"`
	Function       string `json:"f"`
	IsRequest      bool   `json:"r"`
	TransactionId  string `json:"t"`
	CloudSessionId string `json:"s"`
	Error          string `json:"e"`
}

type BinFrameTask 

type BinFrameTask struct {
	IsConnectedSignal    bool
	IsDisconnectedSignal bool

	Client *RepeaterBinClient
	Frame  *BinFrame
}

type BinServer 

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

func NewServer 

func NewServer(chProcessingData chan BinFrameTask) *BinServer

func (*BinServer) Start 

func (c *BinServer) Start()

func (*BinServer) Started 

func (c *BinServer) Started() bool

func (*BinServer) Stop 

func (c *BinServer) Stop()

type GetAllDBResponse 

type GetAllDBResponse struct {
	Hosts []RegDBHostInfo
	Items []RegDBItem `json:"items"`
}

type GetAllResponse 

type GetAllResponse struct {
	Items []RegDBItem `json:"items"`
}

type HttpServer 

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

func NewHttpServer 

func NewHttpServer(api IHttpApi, storage *storage.Storage) *HttpServer

func (*HttpServer) Start 

func (c *HttpServer) Start()

func (*HttpServer) Stop 

func (c *HttpServer) Stop() error

type IHttpApi 

type IHttpApi interface {
	RequestJson(function string, requestText []byte, session *storage.Session, nodeId string, addr string) ([]byte, error)
}

type LocalNodesDb 

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

func NewLocalNodesDb 

func NewLocalNodesDb() *LocalNodesDb

func (*LocalNodesDb) ActiveNodesCount 

func (c *LocalNodesDb) ActiveNodesCount() int

func (*LocalNodesDb) AllNodes 

func (c *LocalNodesDb) AllNodes(key string) *AllNodesResponse

func (*LocalNodesDb) NewNodesIDsKey 

func (c *LocalNodesDb) NewNodesIDsKey() string

func (*LocalNodesDb) SetNode 

func (c *LocalNodesDb) SetNode(nodeId string, name string, userId int64, client *RepeaterBinClient)

type Node 

type Node struct {
	NodeId   string
	NodeName string

	LastWriteDT time.Time

	UserId int64
	// contains filtered or unexported fields
}

type ProxyTask 

type ProxyTask struct {
	TransactionId string
	Function      string
	RequestText   []byte

	ResponseReceived bool
	ErrorReceived    bool
	ResponseText     []byte
}

type RegDB 

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

func NewRegDB 

func NewRegDB(storage *storage.Storage) *RegDB

func (*RegDB) ApplyDBFromHost 

func (c *RegDB) ApplyDBFromHost(host string, db *AllNodesResponse)

func (*RegDB) CountDBS 

func (c *RegDB) CountDBS() int

func (*RegDB) CountOfNodes 

func (c *RegDB) CountOfNodes() int

func (*RegDB) GetAll 

func (c *RegDB) GetAll() *GetAllResponse

func (*RegDB) GetAllDB 

func (c *RegDB) GetAllDB() *GetAllDBResponse

func (*RegDB) KeyForHost 

func (c *RegDB) KeyForHost(host string) string

func (*RegDB) RepeaterForNode 

func (c *RegDB) RepeaterForNode(nodeId string) (result RepeaterForNodeResponse, err error)

func (*RegDB) Where 

func (c *RegDB) Where(nodeId string) (host string, err error)

type RegDBHostInfo 

type RegDBHostInfo struct {
	Host  string    `json:"host"`
	Nodes []string  `json:"nodes"`
	Key   string    `json:"key"`
	DT    time.Time `json:"dt"`
	// contains filtered or unexported fields
}

type RegDBItem 

type RegDBItem struct {
	NodeId string    `json:"node_id"`
	Host   string    `json:"host"`
	DT     time.Time `json:"dt"`
}

type RepeaterBinClient 

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

func New 

func New(addr string, userName string, password string, chProcessingData chan BinFrameTask) *RepeaterBinClient

func NewByConn 

func NewByConn(conn net.Conn, chProcessingData chan BinFrameTask, stat *tools.Statistics) *RepeaterBinClient

func (*RepeaterBinClient) Connected 

func (c *RepeaterBinClient) Connected() bool

func (*RepeaterBinClient) GetRemoteAddr 

func (c *RepeaterBinClient) GetRemoteAddr() string

func (*RepeaterBinClient) LastError 

func (c *RepeaterBinClient) LastError() error

func (*RepeaterBinClient) SendData 

func (c *RepeaterBinClient) SendData(data *BinFrame)

func (*RepeaterBinClient) SessionId 

func (c *RepeaterBinClient) SessionId() string

func (*RepeaterBinClient) SetSession 

func (c *RepeaterBinClient) SetSession(sessionId string, userName string)

func (*RepeaterBinClient) SetStat 

func (c *RepeaterBinClient) SetStat(statistics *tools.Statistics)

func (*RepeaterBinClient) ShortString 

func (c *RepeaterBinClient) ShortString() string

func (*RepeaterBinClient) Start 

func (c *RepeaterBinClient) Start()

func (*RepeaterBinClient) Started 

func (c *RepeaterBinClient) Started() bool

func (*RepeaterBinClient) Stat 

func (c *RepeaterBinClient) Stat() *tools.Statistics

func (*RepeaterBinClient) Stop 

func (c *RepeaterBinClient) Stop()

func (*RepeaterBinClient) UserName 

func (c *RepeaterBinClient) UserName() string

type RepeaterForNodeResponse 

type RepeaterForNodeResponse struct {
	NodeId string                        `json:"node_id"`
	Items  []RepeaterForNodeResponseItem `json:"items"`
	Host   string                        `json:"host"`
}

type RepeaterForNodeResponseItem 

type RepeaterForNodeResponseItem struct {
	Host  string  `json:"host"`
	Score float64 `json:"score"`
}

type SrvRepeater 

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

func NewSrvRepeater 

func NewSrvRepeater() *SrvRepeater

func (*SrvRepeater) AccountInfo 

func (c *SrvRepeater) AccountInfo(session *storage.Session, requestText []byte) (bs []byte, err error)

func (*SrvRepeater) AllNodes 

func (c *SrvRepeater) AllNodes(requestText []byte) (bs []byte, err error)

func (*SrvRepeater) Buy 

func (c *SrvRepeater) Buy(requestText []byte, session *storage.Session, addr string) (bs []byte, err error)

func (*SrvRepeater) ChangePassword 

func (c *SrvRepeater) ChangePassword(session *storage.Session, requestText []byte, addr string) ([]byte, error)

func (*SrvRepeater) ConfirmRegistration 

func (c *SrvRepeater) ConfirmRegistration(requestText []byte, addr string) ([]byte, error)

func (*SrvRepeater) GetAllDB 

func (c *SrvRepeater) GetAllDB() (bs []byte, err error)

func (*SrvRepeater) GetAllNodesOfCluster 

func (c *SrvRepeater) GetAllNodesOfCluster() (bs []byte, err error)

func (*SrvRepeater) IAm 

func (c *SrvRepeater) IAm(task BinFrameTask, session *storage.Session) (err error)

func (*SrvRepeater) NodeAdd 

func (c *SrvRepeater) NodeAdd(session *storage.Session, requestText []byte, addr string) (bs []byte, err error)

func (*SrvRepeater) NodeRemove 

func (c *SrvRepeater) NodeRemove(session *storage.Session, requestText []byte, addr string) (bs []byte, err error)

func (*SrvRepeater) NodeUpdate 

func (c *SrvRepeater) NodeUpdate(session *storage.Session, requestText []byte, addr string) (bs []byte, err error)

func (*SrvRepeater) Nodes 

func (c *SrvRepeater) Nodes(session *storage.Session) (bs []byte, err error)

func (*SrvRepeater) OpenSession 

func (c *SrvRepeater) OpenSession(task BinFrameTask)

func (*SrvRepeater) RegNode 

func (c *SrvRepeater) RegNode()

func (*SrvRepeater) Registration 

func (c *SrvRepeater) Registration(requestText []byte, addr string) ([]byte, error)

func (*SrvRepeater) RepeaterForNode 

func (c *SrvRepeater) RepeaterForNode(requestText []byte) (bs []byte, err error)

func (*SrvRepeater) RequestJson 

func (c *SrvRepeater) RequestJson(function string, requestText []byte, session *storage.Session, nodeId string, addr string) ([]byte, error)

func (*SrvRepeater) RequestJsonFromBinary 

func (c *SrvRepeater) RequestJsonFromBinary(function string, requestText []byte, session *storage.Session, nodeId string, addr string) ([]byte, error)

func (*SrvRepeater) ResetPassword 

func (c *SrvRepeater) ResetPassword(session *storage.Session, requestText []byte, addr string) ([]byte, error)

func (*SrvRepeater) RestorePassword 

func (c *SrvRepeater) RestorePassword(requestText []byte, addr string) ([]byte, error)

func (*SrvRepeater) SessionActivate 

func (c *SrvRepeater) SessionActivate(requestText []byte) ([]byte, error)

func (*SrvRepeater) SessionClose 

func (c *SrvRepeater) SessionClose(requestText []byte, session *storage.Session) (err error)

func (*SrvRepeater) SessionOpen 

func (c *SrvRepeater) SessionOpen(requestText []byte) ([]byte, error)

func (*SrvRepeater) Start 

func (c *SrvRepeater) Start()

func (*SrvRepeater) State 

func (c *SrvRepeater) State() *state.System

func (*SrvRepeater) StateAsString 

func (c *SrvRepeater) StateAsString() ([]byte, error)

func (*SrvRepeater) Stop 

func (c *SrvRepeater) Stop()

func (*SrvRepeater) StopBin 

func (c *SrvRepeater) StopBin(requestText []byte, session *storage.Session, addr string) (bs []byte, err error)

func (*SrvRepeater) StopHttp 

func (c *SrvRepeater) StopHttp(requestText []byte, session *storage.Session, addr string) (bs []byte, err error)

func (*SrvRepeater) Where 

func (c *SrvRepeater) Where(requestText []byte) (bs []byte, err error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.