sse

Documentation

Index

• type Broker
  • func NewSSEServer(ctx context.Context, messageOnJoin []byte) *Broker
  • func (broker *Broker) ServeHTTP(rw http.ResponseWriter, req *http.Request)
• type CallBack
• type Client
  • func NewClient(cb CallBack) *Client
  • func (c *Client) SetURL(URL string)
  • func (c *Client) Shutdown()

Types

type Broker

type Broker struct {
	// events are pushed to this channel by the main events-gathering routine
	Notifier chan []byte
	// contains filtered or unexported fields
}

Broker

func NewSSEServer

func NewSSEServer(ctx context.Context, messageOnJoin []byte) *Broker

NewSSEServer

func (*Broker) ServeHTTP

func (broker *Broker) ServeHTTP(rw http.ResponseWriter, req *http.Request)

ServeHTTP

type CallBack

type CallBack func(v *core.Configuration)

CallBack represent callback that process new Flagger configuration

type Client

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

Client represent SSE client

func NewClient

func NewClient(cb CallBack) *Client

NewClient return the new instance SSE.Client

func (*Client) SetURL

func (c *Client) SetURL(URL string)

SetURL using to changing subscribing url

func (*Client) Shutdown

func (c *Client) Shutdown()

Shutdown - closes sse connection to free up the resources