gate_client

Documentation

Index

• Constants
• type GateClient
  • func NewGateClient(adaptors *adaptors.Adaptors, graceful *graceful_service.GracefulService, ...) (gate *GateClient)
  • func (g *GateClient) AddMobile(ctx context.Context) (list *MobileList, err error)
  • func (g *GateClient) Broadcast(message []byte)
  • func (g *GateClient) Close()
  • func (g *GateClient) DeleteMobile(token string, ctx context.Context) (list *MobileList, err error)
  • func (g *GateClient) GetMobileList(ctx context.Context) (list *MobileList, err error)
  • func (g *GateClient) GetSettings() (Settings, error)
  • func (g *GateClient) RegisterServer()
  • func (g *GateClient) RequestFromMobileProxy(message stream.Message)
  • func (g *GateClient) Restart()
  • func (g *GateClient) Send(command string, payload map[string]interface{}, ctx context.Context, ...) (err error)
  • func (g *GateClient) SetEngine(engine *gin.Engine)
  • func (g *GateClient) Shutdown()
  • func (g *GateClient) Status() string
  • func (g *GateClient) Subscribe(command string, f func(client stream.IStreamClient, msg stream.Message))
  • func (g *GateClient) UnSubscribe(command string)
  • func (g *GateClient) UpdateSettings(settings Settings) (err error)
• type IWsCallback
• type MobileList
• type Settings
  • func (s Settings) Equal(v Settings) bool
  • func (s Settings) Valid() bool
• type StreamRequestModel
• type StreamResponseModel
• type WsClient
  • func NewWsClient(cb IWsCallback, metric *metrics.MetricManager) *WsClient
  • func (client *WsClient) Close()
  • func (client *WsClient) Notify(t, b string)
  • func (client *WsClient) Status() string
  • func (client *WsClient) UpdateSettings(settings Settings)
  • func (client *WsClient) Write(payload []byte) (err error)

Constants

const (
	Request       = "request"
	Response      = "response"
	StatusSuccess = "success"
	StatusError   = "error"
)

const (
	GateStatusWait         = "wait"
	GateStatusConnected    = "connected"
	GateStatusNotConnected = "not connected"
	GateStatusQuit         = "quit"
)

const (
	ClientTypeServer = "server"
)

Types

type GateClient

type GateClient struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewGateClient

func NewGateClient(adaptors *adaptors.Adaptors,
	graceful *graceful_service.GracefulService,
	metric *metrics.MetricManager) (gate *GateClient)

func (*GateClient) AddMobile

func (g *GateClient) AddMobile(ctx context.Context) (list *MobileList, err error)

func (*GateClient) Broadcast

func (g *GateClient) Broadcast(message []byte)

func (*GateClient) Close

func (g *GateClient) Close()

func (*GateClient) DeleteMobile

func (g *GateClient) DeleteMobile(token string, ctx context.Context) (list *MobileList, err error)

func (*GateClient) GetMobileList

func (g *GateClient) GetMobileList(ctx context.Context) (list *MobileList, err error)

func (*GateClient) GetSettings

func (g *GateClient) GetSettings() (Settings, error)

func (*GateClient) RegisterServer

func (g *GateClient) RegisterServer()

func (*GateClient) RequestFromMobileProxy

func (g *GateClient) RequestFromMobileProxy(message stream.Message)

func (*GateClient) Restart

func (g *GateClient) Restart()

func (*GateClient) Send

func (g *GateClient) Send(command string, payload map[string]interface{}, ctx context.Context, f func(msg stream.Message)) (err error)

func (*GateClient) SetEngine

func (g *GateClient) SetEngine(engine *gin.Engine)

func (*GateClient) Shutdown

func (g *GateClient) Shutdown()

func (*GateClient) Status

func (g *GateClient) Status() string

func (*GateClient) Subscribe

func (g *GateClient) Subscribe(command string, f func(client stream.IStreamClient, msg stream.Message))

func (*GateClient) UnSubscribe

func (g *GateClient) UnSubscribe(command string)

func (*GateClient) UpdateSettings

func (g *GateClient) UpdateSettings(settings Settings) (err error)

type IWsCallback

type IWsCallback interface {
	// contains filtered or unexported methods
}

type MobileList

type MobileList struct {
	Total     int64    `json:"total"`
	TokenList []string `json:"token_list"`
}

type Settings

type Settings struct {
	GateServerToken string `json:"gate_server_token"`
	Address         string `json:"address"`
	Enabled         bool   `json:"enabled"`
}

func (Settings) Equal

func (s Settings) Equal(v Settings) bool

func (Settings) Valid

func (s Settings) Valid() bool

type StreamRequestModel

type StreamRequestModel struct {
	URI    string      `json:"uri"`
	Method string      `json:"method"`
	Body   []byte      `json:"body"`
	Header http.Header `json:"header"`
}

type StreamResponseModel

type StreamResponseModel struct {
	Code   int         `json:"code"`
	Body   []byte      `json:"body"`
	Header http.Header `json:"header"`
}

type WsClient

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

func NewWsClient

func NewWsClient(cb IWsCallback, metric *metrics.MetricManager) *WsClient

func (*WsClient) Close

func (client *WsClient) Close()

func (*WsClient) Notify

func (client *WsClient) Notify(t, b string)

func (*WsClient) Status

func (client *WsClient) Status() string

func (*WsClient) UpdateSettings

func (client *WsClient) UpdateSettings(settings Settings)

func (*WsClient) Write

func (client *WsClient) Write(payload []byte) (err error)