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) RequestFromProxy(message stream.Message, engine *gin.Engine)
  • func (g *GateClient) Restart()
  • func (g *GateClient) Send(command string, payload map[string]interface{}, ctx context.Context, ...) (err error)
  • func (g *GateClient) SetAlexaApiEngine(engine *gin.Engine)
  • func (g *GateClient) SetMobileApiEngine(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 = "request"
	// Response ...
	Response = "response"
	// StatusSuccess ...
	StatusSuccess = "success"
	// StatusError ...
	StatusError = "error"
)

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

const (
	// MobileGateProxy ...
	MobileGateProxy = string("mobile_gate_proxy")
	// AlexaGateProxy ...
	AlexaGateProxy = string("alexa_gate_proxy")
)

const (
	// ClientTypeServer ...
	ClientTypeServer = "server"
)

Types

type GateClient

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

GateClient ...

func NewGateClient

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

NewGateClient ...

func (*GateClient) AddMobile

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

AddMobile ...

func (*GateClient) Broadcast

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

Broadcast ...

func (*GateClient) Close

func (g *GateClient) Close()

Close ...

func (*GateClient) DeleteMobile

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

DeleteMobile ...

func (*GateClient) GetMobileList

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

GetMobileList ...

func (*GateClient) GetSettings

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

GetSettings ...

func (*GateClient) RegisterServer

func (g *GateClient) RegisterServer()

RegisterServer ...

func (*GateClient) RequestFromProxy

func (g *GateClient) RequestFromProxy(message stream.Message, engine *gin.Engine)

RequestFromProxy ...

func (*GateClient) Restart

func (g *GateClient) Restart()

Restart ...

func (*GateClient) Send

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

Send ...

func (*GateClient) SetAlexaApiEngine

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

SetAlexaApiEngine ...

func (*GateClient) SetMobileApiEngine

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

SetMobileApiEngine ...

func (*GateClient) Shutdown

func (g *GateClient) Shutdown()

Shutdown ...

func (*GateClient) Status

func (g *GateClient) Status() string

Status ...

func (*GateClient) Subscribe

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

Subscribe ...

func (*GateClient) UnSubscribe

func (g *GateClient) UnSubscribe(command string)

UnSubscribe ...

func (*GateClient) UpdateSettings

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

UpdateSettings ...

type IWsCallback

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

IWsCallback ...

type MobileList

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

MobileList ...

type Settings

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

Settings ...

func (Settings) Equal

func (s Settings) Equal(v Settings) bool

Equal ...

func (Settings) Valid

func (s Settings) Valid() bool

Valid ...

type StreamRequestModel

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

StreamRequestModel ...

type StreamResponseModel

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

StreamResponseModel ...

type WsClient

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

WsClient ...

func NewWsClient

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

NewWsClient ...

func (*WsClient) Close

func (client *WsClient) Close()

Close ...

func (*WsClient) Notify

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

Notify ...

func (*WsClient) Status

func (client *WsClient) Status() string

Status ...

func (*WsClient) UpdateSettings

func (client *WsClient) UpdateSettings(settings Settings)

UpdateSettings ...

func (*WsClient) Write

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

Write ...