client2

Jul 11, 2025

Changes in this version

type Client

+ func (c *Client) ComposeSphinxPacketForQuery(request *thin.SendChannelQuery, surbID *[sConstants.SURBIDLength]byte) (pkt []byte, surbkey []byte, rtt time.Duration, err error)

+ func (c *Client) SendChannelQuery(sendQuery *thin.SendChannelQuery, surbID *[sConstants.SURBIDLength]byte) (surbKey []byte, rtt time.Duration, err error)

type Request

+ ResumeReadChannel *thin.ResumeReadChannel

+ ResumeReadChannelQuery *thin.ResumeReadChannelQuery

+ ResumeWriteChannel *thin.ResumeWriteChannel

+ ResumeWriteChannelQuery *thin.ResumeWriteChannelQuery

+ SendChannelQuery *thin.SendChannelQuery

type Response

+ ChannelQueryReplyEvent *thin.ChannelQueryReplyEvent

+ ChannelQuerySentEvent *thin.ChannelQuerySentEvent

+ ResumeReadChannelQueryReply *thin.ResumeReadChannelQueryReply

+ ResumeReadChannelReply *thin.ResumeReadChannelReply

+ ResumeWriteChannelQueryReply *thin.ResumeWriteChannelQueryReply

+ ResumeWriteChannelReply *thin.ResumeWriteChannelReply

+ type SendDropDecoy struct

+ type SendLoopDecoy struct

Jul 8, 2025

Changes in this version

type EnvelopeDescriptor

+ func EnvelopeDescriptorFromBytes(blob []byte) *EnvelopeDescriptor

+ func (e *EnvelopeDescriptor) Bytes() []byte

type ReplyHandlerParams

+ ReplyIndex uint8

Jul 1, 2025

Changes in this version

type ChannelDescriptor

+ AppID *[AppIDLength]byte

Jun 30, 2025

Changes in this version

type NewReplyHandlerParams

+ ReplyIndex uint8

type Request

+ CloseChannel *thin.CloseChannel

Jun 27, 2025

Changes in this version

+ const ChannelIDField

+ const ErrField

+ const HaltingState

+ const MessageIDField

+ const PayloadField

+ func CreateChannelReadRequest(channelID [thin.ChannelIDLength]byte, statefulReader *bacap.StatefulReader, ...) (*pigeonhole.CourierEnvelope, nike.PrivateKey, error)

+ func CreateChannelReadRequestWithBoxID(channelID [thin.ChannelIDLength]byte, boxID *[bacap.BoxIDSize]byte, ...) (*pigeonhole.CourierEnvelope, nike.PrivateKey, error)

+ func CreateChannelWriteRequest(statefulWriter *bacap.StatefulWriter, payload []byte, doc *cpki.Document, ...) (*pigeonhole.CourierEnvelope, nike.PrivateKey, error)

+ func CreateChannelWriteRequestPrepareOnly(statefulWriter *bacap.StatefulWriter, payload []byte, doc *cpki.Document, ...) (*pigeonhole.CourierEnvelope, nike.PrivateKey, error)

+ func GetRandomCourier(doc *cpki.Document) (*[hash.HashSize]byte, []byte)

+ func NewPigeonholeChannel() (*bacap.StatefulWriter, *bacap.ReadCap, *bacap.WriteCap)

+ func TestCreateChannelWriteRequest(t *testing.T) — windows/amd64

+ func TestCreateChannelWriteRequestPayloadTooLarge(t *testing.T) — windows/amd64

+ type ChannelDescriptor struct

+ EnvelopeDescriptors map[[hash.HashSize]byte]*EnvelopeDescriptor

+ EnvelopeDescriptorsLock sync.RWMutex

+ StatefulReader *bacap.StatefulReader

+ StatefulReaderLock sync.Mutex

+ StatefulWriter *bacap.StatefulWriter

+ StatefulWriterLock sync.Mutex

+ StoredEnvelopes map[[thin.MessageIDLength]byte]*StoredEnvelopeData

+ StoredEnvelopesLock sync.RWMutex

type Client

+ func (c *Client) GetDocumentByEpoch(epoch uint64) *cpki.Document

+ type EnvelopeDescriptor struct

+ EnvelopeKey []byte

+ Epoch uint64

+ ReplicaNums [2]uint8

+ type NewReplyHandlerParams struct

+ AppID *[AppIDLength]byte

+ ChannelDesc *ChannelDescriptor

+ ChannelID uint16

+ Conn *incomingConn

+ EnvHash *[hash.HashSize]byte

+ IsReader bool

+ IsWriter bool

+ MessageID *[MessageIDLength]byte

+ type ReplyHandlerParams struct

+ AppID *[AppIDLength]byte

+ ChannelDesc *ChannelDescriptor

+ ChannelID [thin.ChannelIDLength]byte

+ Conn *incomingConn

+ EnvHash *[hash.HashSize]byte

+ IsReader bool

+ IsWriter bool

+ MessageID *[MessageIDLength]byte

type Request

+ CreateReadChannel *thin.CreateReadChannel

+ CreateWriteChannel *thin.CreateWriteChannel

+ ReadChannel *thin.ReadChannel

+ SendARQMessage *thin.SendARQMessage

+ SendDropDecoy *thin.SendDropDecoy

+ SendLoopDecoy *thin.SendLoopDecoy

+ SendMessage *thin.SendMessage

+ ThinClose *thin.ThinClose

+ WriteChannel *thin.WriteChannel

type Response

+ CreateReadChannelReply *thin.CreateReadChannelReply

+ CreateWriteChannelReply *thin.CreateWriteChannelReply

+ ReadChannelReply *thin.ReadChannelReply

+ WriteChannelReply *thin.WriteChannelReply

+ type StoredEnvelopeData struct

+ BoxID *[bacap.BoxIDSize]byte

+ Envelope *pigeonhole.CourierEnvelope

Jan 11, 2025

Changes in this version

type Client

+ DialContextFn func(ctx context.Context, network, address string) (net.Conn, error)

Sep 27, 2024

Changes in this version

+ const AppIDLength

+ const EchoService

+ const MaxRetransmissions

+ const MessageIDLength

+ const RoundTripTimeSlop

+ var ErrNotConnected = errors.New("client/conn: not connected to the Gateway")

+ var ErrShutdown = errors.New("shutdown requested")

+ var PublishDeadline = vServer.PublishConsensusDeadline

+ var WarpedEpoch = "false"

+ func IntoThinResponse(r *Response) *thin.Response

+ func NewListener(client *Client, rates *Rates, egressCh chan *Request, logBackend *log.Backend) (*listener, error)

+ type ARQMessage struct

+ AppID *[AppIDLength]byte

+ DestinationIdHash *[32]byte

+ MessageID *[MessageIDLength]byte

+ Payload []byte

+ RecipientQueueID []byte

+ ReplyETA time.Duration

+ Retransmissions uint32

+ SURBDecryptionKeys []byte

+ SURBID *[sConstants.SURBIDLength]byte

+ SentAt time.Time

+ type CachedDoc struct

+ Blob []byte

+ Doc *cpki.Document

+ type Client struct

+ PKIClient cpki.Client

+ func New(cfg *config.Config, logBackend *log.Backend) (*Client, error)

+ func (c *Client) ClockSkew() time.Duration

+ func (c *Client) ComposeSphinxPacket(request *Request) (pkt []byte, surbkey []byte, rtt time.Duration, err error)

+ func (c *Client) CurrentDocument() ([]byte, *cpki.Document)

+ func (c *Client) ForceFetch()

+ func (c *Client) ForceFetchPKI()

+ func (c *Client) GetPollInterval() time.Duration

+ func (c *Client) SendCiphertext(request *Request) ([]byte, time.Duration, error)

+ func (c *Client) SendPacket(pkt []byte) error

+ func (c *Client) SetPollInterval(interval time.Duration)

+ func (c *Client) Shutdown()

+ func (c *Client) Start() error

+ func (c *Client) WaitForCurrentDocument()

+ type ConnectError struct

+ Err error

+ func (e *ConnectError) Error() string

+ type ConsensusGetter interface

+ GetConsensus func(ctx context.Context, epoch uint64) (*commands.Consensus, error)

+ type Daemon struct

+ func NewDaemon(cfg *config.Config) (*Daemon, error)

+ func (d *Daemon) Shutdown()

+ func (d *Daemon) Start() error

+ type ExpDist struct

+ func NewExpDist() *ExpDist

+ func (e *ExpDist) OutCh() <-chan struct{}

+ func (e *ExpDist) UpdateConnectionStatus(isConnected bool)

+ func (e *ExpDist) UpdateRate(averageRate uint64, maxDelay uint64)

+ type PKIError struct

+ Err error

+ func (e *PKIError) Error() string

+ type ProtocolError struct

+ Err error

+ func (e *ProtocolError) Error() string

+ type Rates struct

+ type Request struct

+ AppID *[AppIDLength]byte

+ DestinationIdHash *[32]byte

+ ID *[MessageIDLength]byte

+ IsARQSendOp bool

+ IsDropDecoy bool

+ IsLoopDecoy bool

+ IsSendOp bool

+ IsThinClose bool

+ Payload []byte

+ RecipientQueueID []byte

+ SURBID *[sConstants.SURBIDLength]byte

+ WithSURB bool

+ func FromThinRequest(r *thin.Request, appid *[AppIDLength]byte) *Request

+ type Response struct

+ AppID *[AppIDLength]byte

+ ConnectionStatusEvent *thin.ConnectionStatusEvent

+ MessageIDGarbageCollected *thin.MessageIDGarbageCollected

+ MessageReplyEvent *thin.MessageReplyEvent

+ MessageSentEvent *thin.MessageSentEvent

+ NewPKIDocumentEvent *thin.NewPKIDocumentEvent

+ ShutdownEvent *thin.ShutdownEvent

+ type TimerQueue struct

+ func NewTimerQueue(action func(interface{})) *TimerQueue

+ func (t *TimerQueue) Len() int

+ func (t *TimerQueue) Peek() *queue.Entry

+ func (t *TimerQueue) Pop() interface{}

+ func (t *TimerQueue) Push(priority uint64, value interface{})

+ func (t *TimerQueue) Start()