P2Pool/zmq4
P2Pool/zmq4
1
0
Fork 0
Code Issues Pull requests Releases Activity

all: apply gofmt

Browse source 
Signed-off-by: Sebastien Binet <binet@cern.ch>
This commit is contained in:
Sebastien Binet 2022-06-01 09:24:30 +02:00
parent 9fa22f043c
commit e634baf52b
6 changed files with 20 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
msg.go
View file

@ -93,7 +93,8 @@ func (msg Msg) Clone() Msg {
}
// Cmd is a ZMTP Cmd as per:
// https://rfc.zeromq.org/spec:23/ZMTP/#formal-grammar
//
// https://rfc.zeromq.org/spec:23/ZMTP/#formal-grammar
type Cmd struct {
Name string
Body []byte
@ -126,7 +127,8 @@ func (cmd *Cmd) marshalZMTP() ([]byte, error) {
}
// ZMTP commands as per:
// https://rfc.zeromq.org/spec:23/ZMTP/#commands
//
// https://rfc.zeromq.org/spec:23/ZMTP/#commands
const (
CmdCancel = "CANCEL"
CmdError = "ERROR"

3
protocol.go
View file

@ -217,7 +217,8 @@ func (md *Metadata) UnmarshalZMTP(p []byte) error {
// Property describes a Conn metadata's entry.
// The on-wire respresentation of Property is specified by:
// https://rfc.zeromq.org/spec:23/ZMTP/
//
// https://rfc.zeromq.org/spec:23/ZMTP/
type Property struct {
K string
V string

7
security.go
View file

@ -58,9 +58,10 @@ func (nullSecurity) Type() SecurityType {
// Handshake implements the ZMTP security handshake according to
// this security mechanism.
// see:
// https://rfc.zeromq.org/spec:23/ZMTP/
// https://rfc.zeromq.org/spec:24/ZMTP-PLAIN/
// https://rfc.zeromq.org/spec:25/ZMTP-CURVE/
//
// https://rfc.zeromq.org/spec:23/ZMTP/
// https://rfc.zeromq.org/spec:24/ZMTP-PLAIN/
// https://rfc.zeromq.org/spec:25/ZMTP-CURVE/
func (nullSecurity) Handshake(conn *Conn, server bool) error {
raw, err := conn.Meta.MarshalZMTP()
if err != nil {

7
security/null/null.go
View file

@ -28,9 +28,10 @@ func (security) Type() zmq4.SecurityType {
// Handshake implements the ZMTP security handshake according to
// this security mechanism.
// see:
// https://rfc.zeromq.org/spec:23/ZMTP/
// https://rfc.zeromq.org/spec:24/ZMTP-PLAIN/
// https://rfc.zeromq.org/spec:25/ZMTP-CURVE/
//
// https://rfc.zeromq.org/spec:23/ZMTP/
// https://rfc.zeromq.org/spec:24/ZMTP-PLAIN/
// https://rfc.zeromq.org/spec:25/ZMTP-CURVE/
func (security) Handshake(conn *zmq4.Conn, server bool) error {
raw, err := conn.Meta.MarshalZMTP()
if err != nil {

7
security/plain/plain.go
View file

@ -32,9 +32,10 @@ func (security) Type() zmq4.SecurityType {
// Handshake implements the ZMTP security handshake according to
// this security mechanism.
// see:
// https://rfc.zeromq.org/spec:23/ZMTP/
// https://rfc.zeromq.org/spec:24/ZMTP-PLAIN/
// https://rfc.zeromq.org/spec:25/ZMTP-CURVE/
//
// https://rfc.zeromq.org/spec:23/ZMTP/
// https://rfc.zeromq.org/spec:24/ZMTP-PLAIN/
// https://rfc.zeromq.org/spec:25/ZMTP-CURVE/
func (sec *security) Handshake(conn *zmq4.Conn, server bool) error {
switch {
case server:

3
socket_types.go
View file

@ -89,7 +89,8 @@ func (sck SocketType) IsCompatible(peer SocketType) bool {
// SocketIdentity is the ZMTP metadata socket identity.
// See:
// https://rfc.zeromq.org/spec:23/ZMTP/.
//
// https://rfc.zeromq.org/spec:23/ZMTP/.
type SocketIdentity []byte
func (id SocketIdentity) String() string {