stream

Documentation

Index

• func NewEventHandler(broadcast func(query string, message []byte)) *eventHandler
• type BroadcastClient
• type Client
  • func NewClient(server api.StreamService_SubscribeServer) *Client
  • func (c *Client) Broadcast(query string, body []byte) (err error)
  • func (c *Client) Close()
  • func (c *Client) Notify(t, b string)
  • func (c *Client) Send(id, query string, body []byte) (err error)
  • func (c *Client) WritePump(f func(*Client, string, string, []byte)) (err error)
• type IStreamClient
• type Message
• type Stream
  • func NewStreamService(lc fx.Lifecycle, eventBus event_bus.EventBus) (s *Stream)
  • func (s *Stream) Broadcast(query string, message []byte)
  • func (s *Stream) NewConnection(server api.StreamService_SubscribeServer) error
  • func (s *Stream) Recv(client *Client, id, query string, b []byte)
  • func (s *Stream) Shutdown(_ context.Context) error
  • func (s *Stream) Start(_ context.Context) error
  • func (s *Stream) Subscribe(command string, f func(IStreamClient, string, []byte))
  • func (s *Stream) UnSubscribe(command string)

Functions

func NewEventHandler

func NewEventHandler(broadcast func(query string, message []byte)) *eventHandler

Types

type BroadcastClient

type BroadcastClient interface {
	Broadcast(query string, message []byte)
}

BroadcastClient ...

type Client

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

Client ...

func NewClient

func NewClient(server api.StreamService_SubscribeServer) *Client

NewClient ...

func (*Client) Broadcast

func (c *Client) Broadcast(query string, body []byte) (err error)

Broadcast ...

func (*Client) Close

func (c *Client) Close()

Close ...

func (*Client) Notify

func (c *Client) Notify(t, b string)

Notify ...

func (*Client) Send

func (c *Client) Send(id, query string, body []byte) (err error)

Send ...

func (*Client) WritePump

func (c *Client) WritePump(f func(*Client, string, string, []byte)) (err error)

WritePump ...

type IStreamClient

type IStreamClient interface {
	Send(id string, query string, body []byte) error
	Notify(t, b string)
}

IStreamClient ...

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"`
	Type    string                 `json:"type"`
}

Message ...

type Stream

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

Stream ...

func NewStreamService

func NewStreamService(lc fx.Lifecycle,
	eventBus event_bus.EventBus) (s *Stream)

NewStreamService ...

func (*Stream) Broadcast

func (s *Stream) Broadcast(query string, message []byte)

Broadcast ...

func (*Stream) NewConnection

func (s *Stream) NewConnection(server api.StreamService_SubscribeServer) error

NewConnection ...

func (*Stream) Recv

func (s *Stream) Recv(client *Client, id, query string, b []byte)

Recv ...

func (*Stream) Shutdown

func (s *Stream) Shutdown(_ context.Context) error

Shutdown ...

func (*Stream) Start

func (s *Stream) Start(_ context.Context) error

Start ...

func (*Stream) Subscribe

func (s *Stream) Subscribe(command string, f func(IStreamClient, string, []byte))

Subscribe ...

func (*Stream) UnSubscribe

func (s *Stream) UnSubscribe(command string)

UnSubscribe ...