handshake

Documentation

Overview

Package handshake implements the Ouroboros handshake protocol

Index

• Constants
• Variables
• func NewMsgFromCbor(msgType uint, data []byte) (protocol.Message, error)
• type CallbackContext
• type Client
  • func NewClient(protoOptions protocol.ProtocolOptions, cfg *Config) *Client
  • func (c *Client) Start()
• type Config
  • func NewConfig(options ...HandshakeOptionFunc) Config
• type FinishedFunc
• type Handshake
  • func New(protoOptions protocol.ProtocolOptions, cfg *Config) *Handshake
• type HandshakeOptionFunc
  • func WithFinishedFunc(finishedFunc FinishedFunc) HandshakeOptionFunc
  • func WithProtocolVersionMap(versionMap protocol.ProtocolVersionMap) HandshakeOptionFunc
  • func WithTimeout(timeout time.Duration) HandshakeOptionFunc
• type MsgAcceptVersion
  • func NewMsgAcceptVersion(version uint16, versionData protocol.VersionData) *MsgAcceptVersion
• type MsgProposeVersions
  • func NewMsgProposeVersions(versionMap protocol.ProtocolVersionMap) *MsgProposeVersions
• type MsgRefuse
  • func NewMsgRefuse(reason []interface{}) *MsgRefuse
• type Server
  • func NewServer(protoOptions protocol.ProtocolOptions, cfg *Config) *Server

Constants

const (
	ProtocolName = "handshake"
	ProtocolId   = 0
)

Protocol identifiers

const (
	MessageTypeProposeVersions = 0
	MessageTypeAcceptVersion   = 1
	MessageTypeRefuse          = 2
)

Message types

const (
	RefuseReasonVersionMismatch uint64 = 0
	RefuseReasonDecodeError     uint64 = 1
	RefuseReasonRefused         uint64 = 2
)

Refusal reasons

Variables

var StateMap = protocol.StateMap{
	// contains filtered or unexported fields
}

Handshake protocol state machine

Functions

func NewMsgFromCbor

func NewMsgFromCbor(msgType uint, data []byte) (protocol.Message, error)

NewMsgFromCbor parses a Handshake message from CBOR

Types

type CallbackContext

type CallbackContext struct {
	ConnectionId connection.ConnectionId
	Client       *Client
	Server       *Server
}

Callback context

type Client

type Client struct {
	*protocol.Protocol
	// contains filtered or unexported fields
}

Client implements the Handshake client

func NewClient

func NewClient(protoOptions protocol.ProtocolOptions, cfg *Config) *Client

NewClient returns a new Handshake client object

func (*Client) Start

func (c *Client) Start()

Start begins the handshake process

type Config

type Config struct {
	ProtocolVersionMap protocol.ProtocolVersionMap
	FinishedFunc       FinishedFunc
	Timeout            time.Duration
}

Config is used to configure the Handshake protocol instance

func NewConfig

func NewConfig(options ...HandshakeOptionFunc) Config

NewConfig returns a new Handshake config object with the provided options

type FinishedFunc

type FinishedFunc func(CallbackContext, uint16, protocol.VersionData) error

Callback function types

type Handshake

type Handshake struct {
	Client *Client
	Server *Server
}

Handshake is a wrapper object that holds the client and server instances

func New

func New(protoOptions protocol.ProtocolOptions, cfg *Config) *Handshake

New returns a new Handshake object

type HandshakeOptionFunc

type HandshakeOptionFunc func(*Config)

HandshakeOptionFunc represents a function used to modify the Handshake protocol config

func WithFinishedFunc

func WithFinishedFunc(finishedFunc FinishedFunc) HandshakeOptionFunc

WithFinishedFunc specifies the Finished callback function

func WithProtocolVersionMap

func WithProtocolVersionMap(
	versionMap protocol.ProtocolVersionMap,
) HandshakeOptionFunc

WithProtocolVersionMap specifies the supported protocol versions

func WithTimeout

func WithTimeout(timeout time.Duration) HandshakeOptionFunc

WithTimeout specifies the timeout for the handshake operation

type MsgAcceptVersion

type MsgAcceptVersion struct {
	protocol.MessageBase
	Version     uint16
	VersionData cbor.RawMessage
}

func NewMsgAcceptVersion

func NewMsgAcceptVersion(
	version uint16,
	versionData protocol.VersionData,
) *MsgAcceptVersion

type MsgProposeVersions

type MsgProposeVersions struct {
	protocol.MessageBase
	VersionMap map[uint16]cbor.RawMessage
}

func NewMsgProposeVersions

func NewMsgProposeVersions(
	versionMap protocol.ProtocolVersionMap,
) *MsgProposeVersions

type MsgRefuse

type MsgRefuse struct {
	protocol.MessageBase
	Reason []interface{}
}

func NewMsgRefuse

func NewMsgRefuse(reason []interface{}) *MsgRefuse

type Server

type Server struct {
	*protocol.Protocol
	// contains filtered or unexported fields
}

Server implements the Handshake server

func NewServer

func NewServer(protoOptions protocol.ProtocolOptions, cfg *Config) *Server

NewServer returns a new Handshake server object