pem

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 2, 2025 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var CrossNetPayState_name = map[int32]string{
	0: "XNET_NULL",
	1: "XNET_SRC",
	2: "XNET_DST",
	3: "XNET_INGRESS",
	4: "XNET_EGRESS",
}
View Source
var CrossNetPayState_value = map[string]int32{
	"XNET_NULL":    0,
	"XNET_SRC":     1,
	"XNET_DST":     2,
	"XNET_INGRESS": 3,
	"XNET_EGRESS":  4,
}
View Source
var OpenChannelEventType_name = map[int32]string{
	0: "UNDEFINED_OPEN_CHANNEL_EVENT_TYPE",
	1: "OPEN_CHANNEL_REQUEST",
	2: "OPEN_CHANNEL_API",
	3: "CHANNEL_MINED",
	4: "TCB_REQUEST",
	5: "TCB_API",
}
View Source
var OpenChannelEventType_value = map[string]int32{
	"UNDEFINED_OPEN_CHANNEL_EVENT_TYPE": 0,
	"OPEN_CHANNEL_REQUEST":              1,
	"OPEN_CHANNEL_API":                  2,
	"CHANNEL_MINED":                     3,
	"TCB_REQUEST":                       4,
	"TCB_API":                           5,
}
View Source
var PayMessageType_name = map[int32]string{
	0:  "UNDEFINED_TYPE",
	1:  "COND_PAY_REQUEST",
	2:  "COND_PAY_RESPONSE",
	3:  "COND_PAY_RECEIPT",
	4:  "REVEAL_SECRET",
	5:  "REVEAL_SECRET_ACK",
	6:  "PAY_SETTLE_PROOF",
	7:  "PAY_SETTLE_REQUEST",
	8:  "PAY_SETTLE_RESPONSE",
	9:  "SEND_TOKEN_API",
	10: "SRC_SETTLE_EXPIRED_PAY_API",
	11: "DST_SETTLE_EXPIRED_PAY_API",
	12: "CONFIRM_ON_CHAIN_PAY_API",
	13: "REJECT_BOOLEAN_PAY_API",
	14: "SETTLE_ON_CHAIN_RESOLVED_PAY_API",
	15: "WITHDRAW_REQUEST",
	16: "WITHDRAW_RESPONSE",
	17: "CONFIRM_BOOLEAN_PAY_API",
	18: "ROUTING_REQUEST",
}
View Source
var PayMessageType_value = map[string]int32{
	"UNDEFINED_TYPE":                   0,
	"COND_PAY_REQUEST":                 1,
	"COND_PAY_RESPONSE":                2,
	"COND_PAY_RECEIPT":                 3,
	"REVEAL_SECRET":                    4,
	"REVEAL_SECRET_ACK":                5,
	"PAY_SETTLE_PROOF":                 6,
	"PAY_SETTLE_REQUEST":               7,
	"PAY_SETTLE_RESPONSE":              8,
	"SEND_TOKEN_API":                   9,
	"SRC_SETTLE_EXPIRED_PAY_API":       10,
	"DST_SETTLE_EXPIRED_PAY_API":       11,
	"CONFIRM_ON_CHAIN_PAY_API":         12,
	"REJECT_BOOLEAN_PAY_API":           13,
	"SETTLE_ON_CHAIN_RESOLVED_PAY_API": 14,
	"WITHDRAW_REQUEST":                 15,
	"WITHDRAW_RESPONSE":                16,
	"CONFIRM_BOOLEAN_PAY_API":          17,
	"ROUTING_REQUEST":                  18,
}

Functions

func CommitOcem

func CommitOcem(ocem *OpenChannelEventMessage)

func CommitPem

func CommitPem(pem *PayEventMessage)

Types

type CrossNetInfo

type CrossNetInfo struct {
	SrcNetId             uint64           `protobuf:"varint,1,opt,name=src_net_id,json=srcNetId,proto3" json:"src_net_id,omitempty"`
	DstNetId             uint64           `protobuf:"varint,2,opt,name=dst_net_id,json=dstNetId,proto3" json:"dst_net_id,omitempty"`
	OriginalPayId        string           `protobuf:"bytes,3,opt,name=original_pay_id,json=originalPayId,proto3" json:"original_pay_id,omitempty"`
	FromPayId            string           `protobuf:"bytes,4,opt,name=from_pay_id,json=fromPayId,proto3" json:"from_pay_id,omitempty"`
	ToBridgeAddr         string           `protobuf:"bytes,5,opt,name=to_bridge_addr,json=toBridgeAddr,proto3" json:"to_bridge_addr,omitempty"`
	ToBridgeNetId        uint64           `protobuf:"varint,6,opt,name=to_bridge_net_id,json=toBridgeNetId,proto3" json:"to_bridge_net_id,omitempty"`
	FromBridgeId         uint64           `protobuf:"varint,7,opt,name=from_bridge_id,json=fromBridgeId,proto3" json:"from_bridge_id,omitempty"`
	State                CrossNetPayState `protobuf:"varint,8,opt,name=state,proto3,enum=pem.CrossNetPayState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*CrossNetInfo) Descriptor

func (*CrossNetInfo) Descriptor() ([]byte, []int)

func (*CrossNetInfo) GetDstNetId

func (m *CrossNetInfo) GetDstNetId() uint64

func (*CrossNetInfo) GetFromBridgeId

func (m *CrossNetInfo) GetFromBridgeId() uint64

func (*CrossNetInfo) GetFromPayId

func (m *CrossNetInfo) GetFromPayId() string

func (*CrossNetInfo) GetOriginalPayId

func (m *CrossNetInfo) GetOriginalPayId() string

func (*CrossNetInfo) GetSrcNetId

func (m *CrossNetInfo) GetSrcNetId() uint64

func (*CrossNetInfo) GetState

func (m *CrossNetInfo) GetState() CrossNetPayState

func (*CrossNetInfo) GetToBridgeAddr

func (m *CrossNetInfo) GetToBridgeAddr() string

func (*CrossNetInfo) GetToBridgeNetId

func (m *CrossNetInfo) GetToBridgeNetId() uint64

func (*CrossNetInfo) ProtoMessage

func (*CrossNetInfo) ProtoMessage()

func (*CrossNetInfo) Reset

func (m *CrossNetInfo) Reset()

func (*CrossNetInfo) String

func (m *CrossNetInfo) String() string

func (*CrossNetInfo) XXX_DiscardUnknown

func (m *CrossNetInfo) XXX_DiscardUnknown()

func (*CrossNetInfo) XXX_Marshal

func (m *CrossNetInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CrossNetInfo) XXX_Merge

func (m *CrossNetInfo) XXX_Merge(src proto.Message)

func (*CrossNetInfo) XXX_Size

func (m *CrossNetInfo) XXX_Size() int

func (*CrossNetInfo) XXX_Unmarshal

func (m *CrossNetInfo) XXX_Unmarshal(b []byte) error

type CrossNetPayState

type CrossNetPayState int32
const (
	CrossNetPayState_XNET_NULL    CrossNetPayState = 0
	CrossNetPayState_XNET_SRC     CrossNetPayState = 1
	CrossNetPayState_XNET_DST     CrossNetPayState = 2
	CrossNetPayState_XNET_INGRESS CrossNetPayState = 3
	CrossNetPayState_XNET_EGRESS  CrossNetPayState = 4
)

func (CrossNetPayState) EnumDescriptor

func (CrossNetPayState) EnumDescriptor() ([]byte, []int)

func (CrossNetPayState) String

func (x CrossNetPayState) String() string

type OpenChannelEventMessage

type OpenChannelEventMessage struct {
	Type                 OpenChannelEventType              `protobuf:"varint,1,opt,name=type,proto3,enum=pem.OpenChannelEventType" json:"type,omitempty"`
	Machine              string                            `protobuf:"bytes,2,opt,name=machine,proto3" json:"machine,omitempty"`
	StartTimeStamp       int64                             `protobuf:"varint,3,opt,name=start_time_stamp,json=startTimeStamp,proto3" json:"start_time_stamp,omitempty"`
	EndTimeStamp         int64                             `protobuf:"varint,4,opt,name=end_time_stamp,json=endTimeStamp,proto3" json:"end_time_stamp,omitempty"`
	Peer                 string                            `protobuf:"bytes,5,opt,name=peer,proto3" json:"peer,omitempty"`
	Error                []string                          `protobuf:"bytes,6,rep,name=error,proto3" json:"error,omitempty"`
	TokenAddr            string                            `protobuf:"bytes,7,opt,name=token_addr,json=tokenAddr,proto3" json:"token_addr,omitempty"`
	Cid                  string                            `protobuf:"bytes,8,opt,name=cid,proto3" json:"cid,omitempty"`
	ExecutionTimeMs      float32                           `protobuf:"fixed32,9,opt,name=execution_time_ms,json=executionTimeMs,proto3" json:"execution_time_ms,omitempty"`
	OspToOsp             bool                              `protobuf:"varint,10,opt,name=osp_to_osp,json=ospToOsp,proto3" json:"osp_to_osp,omitempty"`
	ReadableInitializer  string                            `protobuf:"bytes,11,opt,name=readable_initializer,json=readableInitializer,proto3" json:"readable_initializer,omitempty"`
	Initializer          *entity.PaymentChannelInitializer `protobuf:"bytes,12,opt,name=initializer,proto3" json:"initializer,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

Next tag: 13

func NewOcem

func NewOcem(machine string) *OpenChannelEventMessage

func (*OpenChannelEventMessage) Descriptor

func (*OpenChannelEventMessage) Descriptor() ([]byte, []int)

func (*OpenChannelEventMessage) GetCid

func (m *OpenChannelEventMessage) GetCid() string

func (*OpenChannelEventMessage) GetEndTimeStamp

func (m *OpenChannelEventMessage) GetEndTimeStamp() int64

func (*OpenChannelEventMessage) GetError

func (m *OpenChannelEventMessage) GetError() []string

func (*OpenChannelEventMessage) GetExecutionTimeMs

func (m *OpenChannelEventMessage) GetExecutionTimeMs() float32

func (*OpenChannelEventMessage) GetInitializer

func (*OpenChannelEventMessage) GetMachine

func (m *OpenChannelEventMessage) GetMachine() string

func (*OpenChannelEventMessage) GetOspToOsp

func (m *OpenChannelEventMessage) GetOspToOsp() bool

func (*OpenChannelEventMessage) GetPeer

func (m *OpenChannelEventMessage) GetPeer() string

func (*OpenChannelEventMessage) GetReadableInitializer

func (m *OpenChannelEventMessage) GetReadableInitializer() string

func (*OpenChannelEventMessage) GetStartTimeStamp

func (m *OpenChannelEventMessage) GetStartTimeStamp() int64

func (*OpenChannelEventMessage) GetTokenAddr

func (m *OpenChannelEventMessage) GetTokenAddr() string

func (*OpenChannelEventMessage) GetType

func (*OpenChannelEventMessage) ProtoMessage

func (*OpenChannelEventMessage) ProtoMessage()

func (*OpenChannelEventMessage) Reset

func (m *OpenChannelEventMessage) Reset()

func (*OpenChannelEventMessage) String

func (m *OpenChannelEventMessage) String() string

func (*OpenChannelEventMessage) XXX_DiscardUnknown

func (m *OpenChannelEventMessage) XXX_DiscardUnknown()

func (*OpenChannelEventMessage) XXX_Marshal

func (m *OpenChannelEventMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OpenChannelEventMessage) XXX_Merge

func (m *OpenChannelEventMessage) XXX_Merge(src proto.Message)

func (*OpenChannelEventMessage) XXX_Size

func (m *OpenChannelEventMessage) XXX_Size() int

func (*OpenChannelEventMessage) XXX_Unmarshal

func (m *OpenChannelEventMessage) XXX_Unmarshal(b []byte) error

type OpenChannelEventType

type OpenChannelEventType int32

Next tag: 17

const (
	OpenChannelEventType_UNDEFINED_OPEN_CHANNEL_EVENT_TYPE OpenChannelEventType = 0
	OpenChannelEventType_OPEN_CHANNEL_REQUEST              OpenChannelEventType = 1
	OpenChannelEventType_OPEN_CHANNEL_API                  OpenChannelEventType = 2
	OpenChannelEventType_CHANNEL_MINED                     OpenChannelEventType = 3
	OpenChannelEventType_TCB_REQUEST                       OpenChannelEventType = 4
	OpenChannelEventType_TCB_API                           OpenChannelEventType = 5
)

func (OpenChannelEventType) EnumDescriptor

func (OpenChannelEventType) EnumDescriptor() ([]byte, []int)

func (OpenChannelEventType) String

func (x OpenChannelEventType) String() string

type PayEventMessage

type PayEventMessage struct {
	Type PayMessageType `protobuf:"varint,1,opt,name=type,proto3,enum=pem.PayMessageType" json:"type,omitempty"`
	// pay_id this message is about.
	PayId string `protobuf:"bytes,2,opt,name=pay_id,json=payId,proto3" json:"pay_id,omitempty"`
	// token used by the pay.
	Token string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	// message src
	Src string `protobuf:"bytes,5,opt,name=src,proto3" json:"src,omitempty"`
	// message dst
	Dst string `protobuf:"bytes,6,opt,name=dst,proto3" json:"dst,omitempty"`
	// direct peer the message comes from.
	MsgFrom string `protobuf:"bytes,7,opt,name=msg_from,json=msgFrom,proto3" json:"msg_from,omitempty"`
	// secret of the pay hash lock.
	Secret string `protobuf:"bytes,8,opt,name=secret,proto3" json:"secret,omitempty"`
	// reason of pay settlement
	SettleReason rpc.PaymentSettleReason `` /* 127-byte string literal not displayed */
	// direct peer the message goes to.
	MsgTo string `protobuf:"bytes,10,opt,name=msg_to,json=msgTo,proto3" json:"msg_to,omitempty"`
	// which machine processed the message
	Machine string `protobuf:"bytes,11,opt,name=machine,proto3" json:"machine,omitempty"`
	// cid this message comes from
	FromCid string `protobuf:"bytes,12,opt,name=from_cid,json=fromCid,proto3" json:"from_cid,omitempty"`
	// cid this message goes to
	ToCid string `protobuf:"bytes,13,opt,name=to_cid,json=toCid,proto3" json:"to_cid,omitempty"`
	// error occured during message processing
	Error []string `protobuf:"bytes,14,rep,name=error,proto3" json:"error,omitempty"`
	// start timestamp of message processing
	StartTimeStamp int64 `protobuf:"varint,15,opt,name=start_time_stamp,json=startTimeStamp,proto3" json:"start_time_stamp,omitempty"`
	// end timestamp of message processing
	EndTimeStamp int64 `protobuf:"varint,16,opt,name=end_time_stamp,json=endTimeStamp,proto3" json:"end_time_stamp,omitempty"`
	// execution time in milliseconds
	ExecutionTimeMs float32 `protobuf:"fixed32,17,opt,name=execution_time_ms,json=executionTimeMs,proto3" json:"execution_time_ms,omitempty"`
	// if exists in ack msg, the message may contains several pays and this field is complete pay id set.
	PayIds []string `protobuf:"bytes,20,rep,name=pay_ids,json=payIds,proto3" json:"pay_ids,omitempty"`
	// if exists in nack msg, the message may contains several pays and this field is complete pay id set.
	NackPayIds []string `protobuf:"bytes,21,rep,name=nack_pay_ids,json=nackPayIds,proto3" json:"nack_pay_ids,omitempty"`
	// indicating if this machine that processes the message is forwarding out message outside the OSP.
	ForwardingExternal bool `protobuf:"varint,22,opt,name=forwarding_external,json=forwardingExternal,proto3" json:"forwarding_external,omitempty"`
	// simplex sequence numbers
	SeqNums *SimplexSeqNums `protobuf:"bytes,23,opt,name=seq_nums,json=seqNums,proto3" json:"seq_nums,omitempty"`
	// error returned in the nack message
	Nack *rpc.Error `protobuf:"bytes,24,opt,name=nack,proto3" json:"nack,omitempty"`
	// resend messages due to nack
	Resend []*PayEventMessage `protobuf:"bytes,25,rep,name=resend,proto3" json:"resend,omitempty"`
	// event is part of a direct-payment
	DirectPay bool `protobuf:"varint,26,opt,name=direct_pay,json=directPay,proto3" json:"direct_pay,omitempty"`
	// When filled, it means the node tries to delegate receiving the pay. This field logs delegation description
	DelegationDescription *rpc.DelegationDescription `protobuf:"bytes,27,opt,name=delegation_description,json=delegationDescription,proto3" json:"delegation_description,omitempty"`
	// pay routing path
	PayPath string `protobuf:"bytes,28,opt,name=pay_path,json=payPath,proto3" json:"pay_path,omitempty"`
	// cross net payment info
	Xnet                 *CrossNetInfo `protobuf:"bytes,29,opt,name=xnet,proto3" json:"xnet,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Next tag: 30

func NewPem

func NewPem(machine string) *PayEventMessage

func (*PayEventMessage) Descriptor

func (*PayEventMessage) Descriptor() ([]byte, []int)

func (*PayEventMessage) GetDelegationDescription

func (m *PayEventMessage) GetDelegationDescription() *rpc.DelegationDescription

func (*PayEventMessage) GetDirectPay

func (m *PayEventMessage) GetDirectPay() bool

func (*PayEventMessage) GetDst

func (m *PayEventMessage) GetDst() string

func (*PayEventMessage) GetEndTimeStamp

func (m *PayEventMessage) GetEndTimeStamp() int64

func (*PayEventMessage) GetError

func (m *PayEventMessage) GetError() []string

func (*PayEventMessage) GetExecutionTimeMs

func (m *PayEventMessage) GetExecutionTimeMs() float32

func (*PayEventMessage) GetForwardingExternal

func (m *PayEventMessage) GetForwardingExternal() bool

func (*PayEventMessage) GetFromCid

func (m *PayEventMessage) GetFromCid() string

func (*PayEventMessage) GetMachine

func (m *PayEventMessage) GetMachine() string

func (*PayEventMessage) GetMsgFrom

func (m *PayEventMessage) GetMsgFrom() string

func (*PayEventMessage) GetMsgTo

func (m *PayEventMessage) GetMsgTo() string

func (*PayEventMessage) GetNack

func (m *PayEventMessage) GetNack() *rpc.Error

func (*PayEventMessage) GetNackPayIds

func (m *PayEventMessage) GetNackPayIds() []string

func (*PayEventMessage) GetPayId

func (m *PayEventMessage) GetPayId() string

func (*PayEventMessage) GetPayIds

func (m *PayEventMessage) GetPayIds() []string

func (*PayEventMessage) GetPayPath

func (m *PayEventMessage) GetPayPath() string

func (*PayEventMessage) GetResend

func (m *PayEventMessage) GetResend() []*PayEventMessage

func (*PayEventMessage) GetSecret

func (m *PayEventMessage) GetSecret() string

func (*PayEventMessage) GetSeqNums

func (m *PayEventMessage) GetSeqNums() *SimplexSeqNums

func (*PayEventMessage) GetSettleReason

func (m *PayEventMessage) GetSettleReason() rpc.PaymentSettleReason

func (*PayEventMessage) GetSrc

func (m *PayEventMessage) GetSrc() string

func (*PayEventMessage) GetStartTimeStamp

func (m *PayEventMessage) GetStartTimeStamp() int64

func (*PayEventMessage) GetToCid

func (m *PayEventMessage) GetToCid() string

func (*PayEventMessage) GetToken

func (m *PayEventMessage) GetToken() string

func (*PayEventMessage) GetType

func (m *PayEventMessage) GetType() PayMessageType

func (*PayEventMessage) GetXnet

func (m *PayEventMessage) GetXnet() *CrossNetInfo

func (*PayEventMessage) ProtoMessage

func (*PayEventMessage) ProtoMessage()

func (*PayEventMessage) Reset

func (m *PayEventMessage) Reset()

func (*PayEventMessage) String

func (m *PayEventMessage) String() string

func (*PayEventMessage) XXX_DiscardUnknown

func (m *PayEventMessage) XXX_DiscardUnknown()

func (*PayEventMessage) XXX_Marshal

func (m *PayEventMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PayEventMessage) XXX_Merge

func (m *PayEventMessage) XXX_Merge(src proto.Message)

func (*PayEventMessage) XXX_Size

func (m *PayEventMessage) XXX_Size() int

func (*PayEventMessage) XXX_Unmarshal

func (m *PayEventMessage) XXX_Unmarshal(b []byte) error

type PayMessageType

type PayMessageType int32

Next tag: 19

const (
	PayMessageType_UNDEFINED_TYPE                   PayMessageType = 0
	PayMessageType_COND_PAY_REQUEST                 PayMessageType = 1
	PayMessageType_COND_PAY_RESPONSE                PayMessageType = 2
	PayMessageType_COND_PAY_RECEIPT                 PayMessageType = 3
	PayMessageType_REVEAL_SECRET                    PayMessageType = 4
	PayMessageType_REVEAL_SECRET_ACK                PayMessageType = 5
	PayMessageType_PAY_SETTLE_PROOF                 PayMessageType = 6
	PayMessageType_PAY_SETTLE_REQUEST               PayMessageType = 7
	PayMessageType_PAY_SETTLE_RESPONSE              PayMessageType = 8
	PayMessageType_SEND_TOKEN_API                   PayMessageType = 9
	PayMessageType_SRC_SETTLE_EXPIRED_PAY_API       PayMessageType = 10
	PayMessageType_DST_SETTLE_EXPIRED_PAY_API       PayMessageType = 11
	PayMessageType_CONFIRM_ON_CHAIN_PAY_API         PayMessageType = 12
	PayMessageType_REJECT_BOOLEAN_PAY_API           PayMessageType = 13
	PayMessageType_SETTLE_ON_CHAIN_RESOLVED_PAY_API PayMessageType = 14
	PayMessageType_WITHDRAW_REQUEST                 PayMessageType = 15
	PayMessageType_WITHDRAW_RESPONSE                PayMessageType = 16
	PayMessageType_CONFIRM_BOOLEAN_PAY_API          PayMessageType = 17
	PayMessageType_ROUTING_REQUEST                  PayMessageType = 18
)

func (PayMessageType) EnumDescriptor

func (PayMessageType) EnumDescriptor() ([]byte, []int)

func (PayMessageType) String

func (x PayMessageType) String() string

type SimplexSeqNums

type SimplexSeqNums struct {
	// sequence number sent in outgoing message.
	Out uint64 `protobuf:"varint,1,opt,name=out,proto3" json:"out,omitempty"`
	// base of sequence number sent in outgoing message.
	OutBase uint64 `protobuf:"varint,2,opt,name=out_base,json=outBase,proto3" json:"out_base,omitempty"`
	// sequence number of received message
	In uint64 `protobuf:"varint,3,opt,name=in,proto3" json:"in,omitempty"`
	// base sequence number of received message
	InBase uint64 `protobuf:"varint,4,opt,name=in_base,json=inBase,proto3" json:"in_base,omitempty"`
	// stored co-signed simplex sequence number
	Stored uint64 `protobuf:"varint,5,opt,name=stored,proto3" json:"stored,omitempty"`
	// sequence number acked by the message
	Ack uint64 `protobuf:"varint,6,opt,name=ack,proto3" json:"ack,omitempty"`
	// highest inflight sequence number, usually needed only when there is a nack to trigger resend
	LastInflight         uint64   `protobuf:"varint,7,opt,name=last_inflight,json=lastInflight,proto3" json:"last_inflight,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SimplexSeqNums) Descriptor

func (*SimplexSeqNums) Descriptor() ([]byte, []int)

func (*SimplexSeqNums) GetAck

func (m *SimplexSeqNums) GetAck() uint64

func (*SimplexSeqNums) GetIn

func (m *SimplexSeqNums) GetIn() uint64

func (*SimplexSeqNums) GetInBase

func (m *SimplexSeqNums) GetInBase() uint64

func (*SimplexSeqNums) GetLastInflight

func (m *SimplexSeqNums) GetLastInflight() uint64

func (*SimplexSeqNums) GetOut

func (m *SimplexSeqNums) GetOut() uint64

func (*SimplexSeqNums) GetOutBase

func (m *SimplexSeqNums) GetOutBase() uint64

func (*SimplexSeqNums) GetStored

func (m *SimplexSeqNums) GetStored() uint64

func (*SimplexSeqNums) ProtoMessage

func (*SimplexSeqNums) ProtoMessage()

func (*SimplexSeqNums) Reset

func (m *SimplexSeqNums) Reset()

func (*SimplexSeqNums) String

func (m *SimplexSeqNums) String() string

func (*SimplexSeqNums) XXX_DiscardUnknown

func (m *SimplexSeqNums) XXX_DiscardUnknown()

func (*SimplexSeqNums) XXX_Marshal

func (m *SimplexSeqNums) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SimplexSeqNums) XXX_Merge

func (m *SimplexSeqNums) XXX_Merge(src proto.Message)

func (*SimplexSeqNums) XXX_Size

func (m *SimplexSeqNums) XXX_Size() int

func (*SimplexSeqNums) XXX_Unmarshal

func (m *SimplexSeqNums) XXX_Unmarshal(b []byte) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL