diff --git a/tcp-client.go b/tcp-client.go index a396baa..642ab89 100644 --- a/tcp-client.go +++ b/tcp-client.go @@ -27,29 +27,29 @@ func init() { host, ok := params["host"] if !ok { - return nil, fmt.Errorf("tcp client requires a host parameter") + return nil, fmt.Errorf("net.tcp.client requires a host parameter") } hostString, ok := host.(string) if !ok { - return nil, fmt.Errorf("tcp client host must be uint16") + return nil, fmt.Errorf("net.tcp.client host must be uint16") } port, ok := params["port"] if !ok { - return nil, fmt.Errorf("tcp client requires a port parameter") + return nil, fmt.Errorf("net.tcp.client requires a port parameter") } portNum, ok := port.(float64) if !ok { - return nil, fmt.Errorf("tcp client port must be uint16") + return nil, fmt.Errorf("net.tcp.client port must be uint16") } framingMethod, ok := params["framing"] if !ok { - return nil, fmt.Errorf("tcp client requires a framing method") + return nil, fmt.Errorf("net.tcp.client requires a framing method") } framingMethodString, ok := framingMethod.(string) @@ -132,7 +132,7 @@ func (tc *TCPClient) Run(ctx context.Context) error { if tc.router != nil { tc.router.HandleInput(tc.config.Id, message) } else { - slog.Error("tcp-client has no router", "id", tc.config.Id) + slog.Error("net.tcp.client has no router", "id", tc.config.Id) } } } @@ -150,7 +150,7 @@ func (tc *TCPClient) Output(payload any) error { if tc.conn != nil { payloadBytes, ok := payload.([]byte) if !ok { - return fmt.Errorf("tcp-client is only able to output bytes") + return fmt.Errorf("net.tcp.client is only able to output bytes") } _, err := tc.conn.Write(tc.framer.Encode(payloadBytes)) return err diff --git a/tcp-server.go b/tcp-server.go index b3673fd..577fcbd 100644 --- a/tcp-server.go +++ b/tcp-server.go @@ -23,18 +23,18 @@ func init() { params := config.Params port, ok := params["port"] if !ok { - return nil, fmt.Errorf("tcp server requires a port parameter") + return nil, fmt.Errorf("net.tcp.server requires a port parameter") } portNum, ok := port.(float64) if !ok { - return nil, fmt.Errorf("tcp server port must be uint16") + return nil, fmt.Errorf("net.tcp.server port must be uint16") } framingMethod, ok := params["framing"] if !ok { - return nil, fmt.Errorf("tcp server requires a framing method") + return nil, fmt.Errorf("net.tcp.server requires a framing method") } framingMethodString, ok := framingMethod.(string) @@ -129,5 +129,5 @@ func (ts TCPServer) Run(ctx context.Context) error { } func (ts *TCPServer) Output(payload any) error { - return fmt.Errorf("tcp-server output is not implemented") + return fmt.Errorf("net.tcp.server output is not implemented") } diff --git a/udp-client.go b/udp-client.go index 0a48e63..dfc2ab5 100644 --- a/udp-client.go +++ b/udp-client.go @@ -23,24 +23,24 @@ func init() { host, ok := params["host"] if !ok { - return nil, fmt.Errorf("udp client requires a host parameter") + return nil, fmt.Errorf("net.udp.client requires a host parameter") } hostString, ok := host.(string) if !ok { - return nil, fmt.Errorf("udp client host must be uint16") + return nil, fmt.Errorf("net.udp.client host must be uint16") } port, ok := params["port"] if !ok { - return nil, fmt.Errorf("udp client requires a port parameter") + return nil, fmt.Errorf("net.udp.client requires a port parameter") } portNum, ok := port.(float64) if !ok { - return nil, fmt.Errorf("udp client port must be uint16") + return nil, fmt.Errorf("net.udp.client port must be uint16") } return &UDPClient{Host: hostString, Port: uint16(portNum), config: config}, nil @@ -80,7 +80,7 @@ func (uc *UDPClient) Output(payload any) error { if uc.conn != nil { payloadBytes, ok := payload.([]byte) if !ok { - return fmt.Errorf("udp-client is only able to output bytes") + return fmt.Errorf("net.udp.client is only able to output bytes") } _, err := uc.conn.Write(payloadBytes) return err diff --git a/udp-server.go b/udp-server.go index f774ea1..5631652 100644 --- a/udp-server.go +++ b/udp-server.go @@ -21,13 +21,13 @@ func init() { params := config.Params port, ok := params["port"] if !ok { - return nil, fmt.Errorf("udp server requires a port parameter") + return nil, fmt.Errorf("net.udp.server requires a port parameter") } portNum, ok := port.(float64) if !ok { - return nil, fmt.Errorf("udp server port must be uint16") + return nil, fmt.Errorf("net.udp.server port must be uint16") } return &UDPServer{Port: uint16(portNum), config: config}, nil @@ -75,7 +75,7 @@ func (us *UDPServer) Run(ctx context.Context) error { if us.router != nil { us.router.HandleInput(us.config.Id, message) } else { - slog.Error("tcp-server has no router", "id", us.config.Id) + slog.Error("net.udp.server has no router", "id", us.config.Id) } } } @@ -83,5 +83,5 @@ func (us *UDPServer) Run(ctx context.Context) error { } func (us *UDPServer) Output(payload any) error { - return fmt.Errorf("udp-server output is not implemented") + return fmt.Errorf("net.udp.server output is not implemented") }