api

Documentation

Index

• Constants
• func GzipDecode(in []byte) ([]byte, error)
• type Client
  • func NewClient(host string, port int, endPoint string, callback MessageCallback) *Client
  • func (this *Client) Read()
  • func (this *Client) SetSecure(secure bool)
  • func (this *Client) Start() error
  • func (this *Client) Stop()
  • func (this *Client) Subscribe(subjects []string)
  • func (this *Client) UnSubscribe(subjects []string)
  • func (this *Client) Write()
• type MessageCallback
• type Server
  • func NewServer(conf config.Config, port int, endPoint string) *Server
  • func (this *Server) Publish(msg message.Message)
  • func (this *Server) Start()

Constants

const DEFAULT_END_POINT = "/source"

const DEFAULT_PORT = 7788

const HEARTBEAT_INTERVAL = 20 * time.Second

Functions

func GzipDecode

func GzipDecode(in []byte) ([]byte, error)

Types

type Client

type Client struct {
	SendCh chan *message.Message
	// contains filtered or unexported fields
}

func NewClient

func NewClient(host string, port int, endPoint string, callback MessageCallback) *Client

func (*Client) Read

func (this *Client) Read()

func (*Client) SetSecure

func (this *Client) SetSecure(secure bool)

func (*Client) Start

func (this *Client) Start() error

func (*Client) Stop

func (this *Client) Stop()

func (*Client) Subscribe

func (this *Client) Subscribe(subjects []string)

func (*Client) UnSubscribe

func (this *Client) UnSubscribe(subjects []string)

func (*Client) Write

func (this *Client) Write()

type MessageCallback

type MessageCallback interface {
	OnMessage(message *message.Message, raw []byte)
	OnError(err error)
}

type Server

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

func NewServer

func NewServer(conf config.Config, port int, endPoint string) *Server

func (*Server) Publish

func (this *Server) Publish(msg message.Message)

func (*Server) Start

func (this *Server) Start()