hub

Documentation

Index

• func Run(ctx context.Context, options *Options) error
• type EdgeHubServer
  • func New(options *Options) (*EdgeHubServer, error)
  • func (s *EdgeHubServer) HTTPAPI() http.Handler
  • func (s *EdgeHubServer) Run(ctx context.Context) error
• type Options
  • func NewDefaultOptions() *Options

Functions

func Run

func Run(ctx context.Context, options *Options) error

Types

type EdgeHubServer

type EdgeHubServer struct {
	tunnel.GrpcTunnelServer
	// contains filtered or unexported fields
}

func New

func New(options *Options) (*EdgeHubServer, error)

func (*EdgeHubServer) HTTPAPI

func (s *EdgeHubServer) HTTPAPI() http.Handler

func (*EdgeHubServer) Run

func (s *EdgeHubServer) Run(ctx context.Context) error

type Options

type Options struct {
	Listen         string      `json:"listen,omitempty"`
	ListenGrpc     string      `json:"listenGrpc,omitempty"`
	Host           string      `json:"host,omitempty" validate:"required"`
	ServerID       string      `json:"serverID,omitempty" validate:"required"`
	TLS            *system.TLS `json:"tls,omitempty"`
	EdgeServerAddr string      `json:"edgeServerAddr,omitempty"`
}

func NewDefaultOptions

func NewDefaultOptions() *Options