net

package
v0.46.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 6, 2025 License: MIT Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	NatsTimeout = 30 * time.Second
)

Variables

View Source 
var DefaultOptions = &Options{
	NatsHost:          "localhost",
	NatsPort:          4222,
	NatsDisabled:      false,
	NatsListen:        false,
	NatsLeafURL:       "",
	NatsCredentials:   "",
	HttpAddr:          "localhost:5555",
	HttpDisabled:      false,
	MonitorDisabled:   false,
	ObjectAPIDisabled: false,
	Logging:           false,
}

Functions

func HandleMonitorRequest 

func HandleMonitorRequest(w http.ResponseWriter, r *http.Request)

HandleMonitorRequest handles the monitor http request. events are emitted to the monitor event channel.

func MonitorRequestHandler added in v0.45.0 

func MonitorRequestHandler(nc *nats.Conn) http.HandlerFunc

Types

type HTTPServer added in v0.45.0 

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

func NewHTTPServer 

func NewHTTPServer(opts *HttpServerOptions) *HTTPServer

func (HTTPServer) Address added in v0.45.0 

func (s HTTPServer) Address() string

func (*HTTPServer) Restart added in v0.45.0 

func (s *HTTPServer) Restart(ctx context.Context, addr string) error

func (*HTTPServer) Router added in v0.45.0 

func (s *HTTPServer) Router() chi.Router

func (*HTTPServer) Start added in v0.45.0 

func (s *HTTPServer) Start() error

func (*HTTPServer) Stop added in v0.45.0 

func (s *HTTPServer) Stop()

type HttpServerOptions added in v0.45.0 

type HttpServerOptions struct {
	Addr string `json:"addr"`
}

type NDJSONScanner added in v0.24.0 

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

NDJSONScanner scans a reader line by line and writes to the writer.

func NewNDJSONScanner added in v0.24.0 

func NewNDJSONScanner(sleep time.Duration, repeat int) *NDJSONScanner

NewNDJSONScanner creates a new NDJSON scanner.

func (*NDJSONScanner) Scan added in v0.24.0 

func (s *NDJSONScanner) Scan(r io.Reader, w io.Writer) error

Scan scans a reader line by line and writes to the writer.

func (*NDJSONScanner) ScanFile added in v0.24.0 

func (s *NDJSONScanner) ScanFile(path string, w io.Writer) error

ScanFile scans a file line by line and writes to the writer.

type NatsServer added in v0.45.0 

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

func NewNatsServer added in v0.45.0 

func NewNatsServer(opts *NatsServerOptions) (*NatsServer, error)

func (*NatsServer) ClientURL added in v0.45.0 

func (ns *NatsServer) ClientURL() string

func (*NatsServer) Connection added in v0.45.0 

func (ns *NatsServer) Connection() (*nats.Conn, error)

func (*NatsServer) Shutdown added in v0.45.0 

func (ns *NatsServer) Shutdown() error

func (*NatsServer) Start added in v0.45.0 

func (ns *NatsServer) Start() error

type NatsServerOptions added in v0.45.0 

type NatsServerOptions struct {
	Host        string
	Port        int
	NatsListen  bool
	LeafURL     string
	Credentials string
	Logging     bool
}

type NetworkManager added in v0.45.0 

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

func NewManager added in v0.45.0 

func NewManager() *NetworkManager

func (*NetworkManager) EnableMonitor added in v0.45.0 

func (s *NetworkManager) EnableMonitor() error

func (*NetworkManager) GetMonitorAddress added in v0.45.0 

func (s *NetworkManager) GetMonitorAddress() (string, error)

func (*NetworkManager) GetSimulationAddress added in v0.45.0 

func (s *NetworkManager) GetSimulationAddress() (string, error)

func (*NetworkManager) HttpServer added in v0.45.0 

func (s *NetworkManager) HttpServer() *HTTPServer

func (*NetworkManager) MonitorEmitter added in v0.45.0 

func (s *NetworkManager) MonitorEmitter() *helper.Hook[mon.Event]

MonitorEmitter return the monitor event emitter.

func (*NetworkManager) NatsClientURL added in v0.45.0 

func (s *NetworkManager) NatsClientURL() string

func (*NetworkManager) NatsConnection added in v0.45.0 

func (s *NetworkManager) NatsConnection() (*nats.Conn, error)

func (*NetworkManager) OnMonitorEvent added in v0.45.0 

func (s *NetworkManager) OnMonitorEvent(fn func(event *mon.Event))

func (*NetworkManager) Start added in v0.45.0 

func (s *NetworkManager) Start(opts *Options) error

func (*NetworkManager) StartHTTP added in v0.45.0 

func (s *NetworkManager) StartHTTP(addr string) error

func (*NetworkManager) StartNATS added in v0.45.0 

func (s *NetworkManager) StartNATS(opts *NatsServerOptions) error

func (*NetworkManager) Stop added in v0.45.0 

func (s *NetworkManager) Stop() error

func (*NetworkManager) StopHTTP added in v0.45.0 

func (s *NetworkManager) StopHTTP() error

func (*NetworkManager) StopNATS added in v0.45.0 

func (s *NetworkManager) StopNATS() error

func (*NetworkManager) Wait added in v0.45.0 

func (s *NetworkManager) Wait(ctx context.Context) error

type Options added in v0.45.0 

type Options struct {
	NatsHost          string `json:"nats_host"`
	NatsPort          int    `json:"nats_port"`
	NatsDisabled      bool   `json:"nats_disabled"`
	NatsListen        bool   `json:"nats_inprocess_only"`
	NatsLeafURL       string `json:"nats_leaf_url"`
	NatsCredentials   string `json:"nats_credentials"`
	HttpAddr          string `json:"http_addr"`
	HttpDisabled      bool   `json:"http_disabled"`
	MonitorDisabled   bool   `json:"monitor_disabled"`
	ObjectAPIDisabled bool   `json:"object_api_disabled"`
	Logging           bool   `json:"logging"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.