network

Documentation

Index

• Constants
• func CastMessage[TargetMessageType protocol.Message](message *anypb.Any) (TargetMessageType, error)
• type Message
  • func (message *Message) FreeMessage()
  • func (message *Message) GetResponse() *protocol.Message
  • func (message *Message) ResetConn()
  • func (message *Message) Respond()
• type MessageType
• type NetworkLayer
  • func NewNetworkLayer(handleChan chan<- Message, respChan <-chan Message, localAddr *net.UnixAddr, ...) (*NetworkLayer, error)
  • func (networkLayer *NetworkLayer) Close() error
  • func (networkLayer *NetworkLayer) ResetConn()
  • func (networkLayer *NetworkLayer) RunAsync(ctx context.Context)

Constants

const (
	HEARTBEAT             = "HEARTBEAT"
	VOTE_REQUEST_RECEIVED = "VOTE_REQUEST_RECEIVED"
	VOTE_RECEIVED         = "VOTE_RECEIVED"
	LOG_ENTRY_REPLICATED  = "LOG_ENTRY_REPLICATED"
	LOG_ENTRY_COMMITTED   = "LOG_ENTRY_COMMITTED"
	LEADER_SUSPECTED      = "LEADER_SUSPECTED"
	FOLLOWER_SUSPECTED    = "FOLLOWER_SUSPECTED"
)

Functions

func CastMessage

func CastMessage[TargetMessageType protocol.Message](message *anypb.Any) (TargetMessageType, error)

Types

type Message

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

func (*Message) FreeMessage

func (message *Message) FreeMessage()

func (*Message) GetResponse

func (message *Message) GetResponse() *protocol.Message

func (*Message) ResetConn

func (message *Message) ResetConn()

func (*Message) Respond

func (message *Message) Respond()

type MessageType

type MessageType int

type NetworkLayer

type NetworkLayer struct {
	*net.UnixConn
	// contains filtered or unexported fields
}

func NewNetworkLayer

func NewNetworkLayer(handleChan chan<- Message, respChan <-chan Message, localAddr *net.UnixAddr, unixSocketPath string) (*NetworkLayer, error)

func (*NetworkLayer) Close

func (networkLayer *NetworkLayer) Close() error

func (*NetworkLayer) ResetConn

func (networkLayer *NetworkLayer) ResetConn()

func (*NetworkLayer) RunAsync

func (networkLayer *NetworkLayer) RunAsync(ctx context.Context)