gate_client

Documentation

Index

• Constants
• Variables
• 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) BroadcastAccessToken()
  • func (g *GateClient) Close()
  • func (g *GateClient) Connect()
  • 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) LoadSettings() (err error)
  • func (g *GateClient) RegisterServer()
  • func (g *GateClient) RequestFromMobileProxy(message Message)
  • func (g *GateClient) Restart()
  • func (g *GateClient) SaveSettings() (err error)
  • 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(id uuid.UUID, f func(msg Message))
  • func (g *GateClient) UnSubscribe(id uuid.UUID)
  • func (g *GateClient) UpdateSettings(settings *Settings) (err error)
• type IWsCallback
• type Message
  • func NewMessage(b []byte) (message Message, err error)
  • func (m *Message) Error(err error) *Message
  • func (m *Message) IsError() (err error)
  • func (m *Message) Pack() []byte
  • func (m *Message) Response(payload map[string]interface{}) *Message
  • func (m *Message) Success() *Message
• type MobileList
• type Settings
  • func (s Settings) Valid() bool
• type StreamRequestModel
• type StreamResponseModel
• type WsClient
  • func NewWsClient(adaptors *adaptors.Adaptors, cb IWsCallback) *WsClient
  • func (client *WsClient) Close()
  • func (client *WsClient) Connect(settings *Settings)

Constants

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

const (
	GateStatusWait      = "wait"
	GateStatusDisabled  = "disabled"
	GateStatusConnected = "connected"
)

const (
	ClientTypeServer = "server"
)

Variables

var (
	ErrGateNotConnected = fmt.Errorf("gate not connected")
)

Types

type GateClient

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

func NewGateClient

func NewGateClient(adaptors *adaptors.Adaptors,
	graceful *graceful_service.GracefulService,
	stream *stream.StreamService) (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) BroadcastAccessToken

func (g *GateClient) BroadcastAccessToken()

func (*GateClient) Close

func (g *GateClient) Close()

func (*GateClient) Connect

func (g *GateClient) Connect()

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

func (g *GateClient) LoadSettings() (err error)

func (*GateClient) RegisterServer

func (g *GateClient) RegisterServer()

func (*GateClient) RequestFromMobileProxy

func (g *GateClient) RequestFromMobileProxy(message Message)

func (*GateClient) Restart

func (g *GateClient) Restart()

func (*GateClient) SaveSettings

func (g *GateClient) SaveSettings() (err error)

func (*GateClient) Send

func (g *GateClient) Send(command string, payload map[string]interface{}, ctx context.Context, f func(msg 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(id uuid.UUID, f func(msg Message))

func (*GateClient) UnSubscribe

func (g *GateClient) UnSubscribe(id uuid.UUID)

func (*GateClient) UpdateSettings

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

type IWsCallback

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

type Message

type Message struct {
	Id      uuid.UUID              `json:"id"`
	Command string                 `json:"command"`
	Payload map[string]interface{} `json:"payload"`
	Forward string                 `json:"forward"`
	Status  string                 `json:"status"`
}

func NewMessage

func NewMessage(b []byte) (message Message, err error)

func (*Message) Error

func (m *Message) Error(err error) *Message

func (*Message) IsError

func (m *Message) IsError() (err error)

func (*Message) Pack

func (m *Message) Pack() []byte

func (*Message) Response

func (m *Message) Response(payload map[string]interface{}) *Message

func (*Message) Success

func (m *Message) Success() *Message

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) 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 {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewWsClient

func NewWsClient(adaptors *adaptors.Adaptors,
	cb IWsCallback) *WsClient

func (*WsClient) Close

func (client *WsClient) Close()

func (*WsClient) Connect

func (client *WsClient) Connect(settings *Settings)