stream_proxy

Documentation

Index

• Constants
• type StreamProxy
  • func NewStreamProxy(httpsServer *server.Server, streamService *stream.StreamService, ...) (proxy *StreamProxy)
  • func (s *StreamProxy) DoAction(client *stream.Client, message stream.Message)
  • func (g *StreamProxy) Send(command string, payload map[string]interface{}, client *stream.Client, ...) (err error)
  • func (s *StreamProxy) Shutdown()
  • func (s *StreamProxy) Start()
• type StreamRequestModel
• type StreamResponseModel

Constants

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

Types

type StreamProxy

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

func NewStreamProxy

func NewStreamProxy(httpsServer *server.Server,
	streamService *stream.StreamService,
	graceful *graceful_service.GracefulService,
	adaptors *adaptors.Adaptors) (proxy *StreamProxy)

func (*StreamProxy) DoAction

func (s *StreamProxy) DoAction(client *stream.Client, message stream.Message)

func (*StreamProxy) Send

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

func (*StreamProxy) Shutdown

func (s *StreamProxy) Shutdown()

func (*StreamProxy) Start

func (s *StreamProxy) Start()

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"`
}