Documentation
¶
Index ¶
- Variables
- func CommitOcem(ocem *OpenChannelEventMessage)
- func CommitPem(pem *PayEventMessage)
- type CrossNetInfo
- func (*CrossNetInfo) Descriptor() ([]byte, []int)deprecated
- func (x *CrossNetInfo) GetDstNetId() uint64
- func (x *CrossNetInfo) GetFromBridgeId() uint64
- func (x *CrossNetInfo) GetFromPayId() string
- func (x *CrossNetInfo) GetOriginalPayId() string
- func (x *CrossNetInfo) GetSrcNetId() uint64
- func (x *CrossNetInfo) GetState() CrossNetPayState
- func (x *CrossNetInfo) GetToBridgeAddr() string
- func (x *CrossNetInfo) GetToBridgeNetId() uint64
- func (*CrossNetInfo) ProtoMessage()
- func (x *CrossNetInfo) ProtoReflect() protoreflect.Message
- func (x *CrossNetInfo) Reset()
- func (x *CrossNetInfo) String() string
- type CrossNetPayState
- func (CrossNetPayState) Descriptor() protoreflect.EnumDescriptor
- func (x CrossNetPayState) Enum() *CrossNetPayState
- func (CrossNetPayState) EnumDescriptor() ([]byte, []int)deprecated
- func (x CrossNetPayState) Number() protoreflect.EnumNumber
- func (x CrossNetPayState) String() string
- func (CrossNetPayState) Type() protoreflect.EnumType
- type OpenChannelEventMessage
- func (*OpenChannelEventMessage) Descriptor() ([]byte, []int)deprecated
- func (x *OpenChannelEventMessage) GetCid() string
- func (x *OpenChannelEventMessage) GetEndTimeStamp() int64
- func (x *OpenChannelEventMessage) GetError() []string
- func (x *OpenChannelEventMessage) GetExecutionTimeMs() float32
- func (x *OpenChannelEventMessage) GetInitializer() *entity.PaymentChannelInitializer
- func (x *OpenChannelEventMessage) GetMachine() string
- func (x *OpenChannelEventMessage) GetOspToOsp() bool
- func (x *OpenChannelEventMessage) GetPeer() string
- func (x *OpenChannelEventMessage) GetReadableInitializer() string
- func (x *OpenChannelEventMessage) GetStartTimeStamp() int64
- func (x *OpenChannelEventMessage) GetTokenAddr() string
- func (x *OpenChannelEventMessage) GetType() OpenChannelEventType
- func (*OpenChannelEventMessage) ProtoMessage()
- func (x *OpenChannelEventMessage) ProtoReflect() protoreflect.Message
- func (x *OpenChannelEventMessage) Reset()
- func (x *OpenChannelEventMessage) String() string
- type OpenChannelEventType
- func (OpenChannelEventType) Descriptor() protoreflect.EnumDescriptor
- func (x OpenChannelEventType) Enum() *OpenChannelEventType
- func (OpenChannelEventType) EnumDescriptor() ([]byte, []int)deprecated
- func (x OpenChannelEventType) Number() protoreflect.EnumNumber
- func (x OpenChannelEventType) String() string
- func (OpenChannelEventType) Type() protoreflect.EnumType
- type PayEventMessage
- func (*PayEventMessage) Descriptor() ([]byte, []int)deprecated
- func (x *PayEventMessage) GetDelegationDescription() *rpc.DelegationDescription
- func (x *PayEventMessage) GetDirectPay() bool
- func (x *PayEventMessage) GetDst() string
- func (x *PayEventMessage) GetEndTimeStamp() int64
- func (x *PayEventMessage) GetError() []string
- func (x *PayEventMessage) GetExecutionTimeMs() float32
- func (x *PayEventMessage) GetForwardingExternal() bool
- func (x *PayEventMessage) GetFromCid() string
- func (x *PayEventMessage) GetMachine() string
- func (x *PayEventMessage) GetMsgFrom() string
- func (x *PayEventMessage) GetMsgTo() string
- func (x *PayEventMessage) GetNack() *rpc.Error
- func (x *PayEventMessage) GetNackPayIds() []string
- func (x *PayEventMessage) GetPayId() string
- func (x *PayEventMessage) GetPayIds() []string
- func (x *PayEventMessage) GetPayPath() string
- func (x *PayEventMessage) GetResend() []*PayEventMessage
- func (x *PayEventMessage) GetSecret() string
- func (x *PayEventMessage) GetSeqNums() *SimplexSeqNums
- func (x *PayEventMessage) GetSettleReason() rpc.PaymentSettleReason
- func (x *PayEventMessage) GetSrc() string
- func (x *PayEventMessage) GetStartTimeStamp() int64
- func (x *PayEventMessage) GetToCid() string
- func (x *PayEventMessage) GetToken() string
- func (x *PayEventMessage) GetType() PayMessageType
- func (x *PayEventMessage) GetXnet() *CrossNetInfo
- func (*PayEventMessage) ProtoMessage()
- func (x *PayEventMessage) ProtoReflect() protoreflect.Message
- func (x *PayEventMessage) Reset()
- func (x *PayEventMessage) String() string
- type PayMessageType
- func (PayMessageType) Descriptor() protoreflect.EnumDescriptor
- func (x PayMessageType) Enum() *PayMessageType
- func (PayMessageType) EnumDescriptor() ([]byte, []int)deprecated
- func (x PayMessageType) Number() protoreflect.EnumNumber
- func (x PayMessageType) String() string
- func (PayMessageType) Type() protoreflect.EnumType
- type SimplexSeqNums
- func (*SimplexSeqNums) Descriptor() ([]byte, []int)deprecated
- func (x *SimplexSeqNums) GetAck() uint64
- func (x *SimplexSeqNums) GetIn() uint64
- func (x *SimplexSeqNums) GetInBase() uint64
- func (x *SimplexSeqNums) GetLastInflight() uint64
- func (x *SimplexSeqNums) GetOut() uint64
- func (x *SimplexSeqNums) GetOutBase() uint64
- func (x *SimplexSeqNums) GetStored() uint64
- func (*SimplexSeqNums) ProtoMessage()
- func (x *SimplexSeqNums) ProtoReflect() protoreflect.Message
- func (x *SimplexSeqNums) Reset()
- func (x *SimplexSeqNums) String() string
Constants ¶
This section is empty.
Variables ¶
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", } 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, } )
Enum value maps for OpenChannelEventType.
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", } 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, } )
Enum value maps for PayMessageType.
View Source
var ( CrossNetPayState_name = map[int32]string{ 0: "XNET_NULL", 1: "XNET_SRC", 2: "XNET_DST", 3: "XNET_INGRESS", 4: "XNET_EGRESS", } CrossNetPayState_value = map[string]int32{ "XNET_NULL": 0, "XNET_SRC": 1, "XNET_DST": 2, "XNET_INGRESS": 3, "XNET_EGRESS": 4, } )
Enum value maps for CrossNetPayState.
View Source
var File_ocem_proto protoreflect.FileDescriptor
View Source
var File_pem_proto protoreflect.FileDescriptor
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"`
// contains filtered or unexported fields
}
func (*CrossNetInfo) Descriptor
deprecated
func (*CrossNetInfo) Descriptor() ([]byte, []int)
Deprecated: Use CrossNetInfo.ProtoReflect.Descriptor instead.
func (*CrossNetInfo) GetDstNetId ¶
func (x *CrossNetInfo) GetDstNetId() uint64
func (*CrossNetInfo) GetFromBridgeId ¶
func (x *CrossNetInfo) GetFromBridgeId() uint64
func (*CrossNetInfo) GetFromPayId ¶
func (x *CrossNetInfo) GetFromPayId() string
func (*CrossNetInfo) GetOriginalPayId ¶
func (x *CrossNetInfo) GetOriginalPayId() string
func (*CrossNetInfo) GetSrcNetId ¶
func (x *CrossNetInfo) GetSrcNetId() uint64
func (*CrossNetInfo) GetState ¶
func (x *CrossNetInfo) GetState() CrossNetPayState
func (*CrossNetInfo) GetToBridgeAddr ¶
func (x *CrossNetInfo) GetToBridgeAddr() string
func (*CrossNetInfo) GetToBridgeNetId ¶
func (x *CrossNetInfo) GetToBridgeNetId() uint64
func (*CrossNetInfo) ProtoMessage ¶
func (*CrossNetInfo) ProtoMessage()
func (*CrossNetInfo) ProtoReflect ¶ added in v1.1.0
func (x *CrossNetInfo) ProtoReflect() protoreflect.Message
func (*CrossNetInfo) Reset ¶
func (x *CrossNetInfo) Reset()
func (*CrossNetInfo) String ¶
func (x *CrossNetInfo) String() string
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) Descriptor ¶ added in v1.1.0
func (CrossNetPayState) Descriptor() protoreflect.EnumDescriptor
func (CrossNetPayState) Enum ¶ added in v1.1.0
func (x CrossNetPayState) Enum() *CrossNetPayState
func (CrossNetPayState) EnumDescriptor
deprecated
func (CrossNetPayState) EnumDescriptor() ([]byte, []int)
Deprecated: Use CrossNetPayState.Descriptor instead.
func (CrossNetPayState) Number ¶ added in v1.1.0
func (x CrossNetPayState) Number() protoreflect.EnumNumber
func (CrossNetPayState) String ¶
func (x CrossNetPayState) String() string
func (CrossNetPayState) Type ¶ added in v1.1.0
func (CrossNetPayState) Type() protoreflect.EnumType
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"`
// contains filtered or unexported fields
}
Next tag: 13
func NewOcem ¶
func NewOcem(machine string) *OpenChannelEventMessage
func (*OpenChannelEventMessage) Descriptor
deprecated
func (*OpenChannelEventMessage) Descriptor() ([]byte, []int)
Deprecated: Use OpenChannelEventMessage.ProtoReflect.Descriptor instead.
func (*OpenChannelEventMessage) GetCid ¶
func (x *OpenChannelEventMessage) GetCid() string
func (*OpenChannelEventMessage) GetEndTimeStamp ¶
func (x *OpenChannelEventMessage) GetEndTimeStamp() int64
func (*OpenChannelEventMessage) GetError ¶
func (x *OpenChannelEventMessage) GetError() []string
func (*OpenChannelEventMessage) GetExecutionTimeMs ¶
func (x *OpenChannelEventMessage) GetExecutionTimeMs() float32
func (*OpenChannelEventMessage) GetInitializer ¶
func (x *OpenChannelEventMessage) GetInitializer() *entity.PaymentChannelInitializer
func (*OpenChannelEventMessage) GetMachine ¶
func (x *OpenChannelEventMessage) GetMachine() string
func (*OpenChannelEventMessage) GetOspToOsp ¶
func (x *OpenChannelEventMessage) GetOspToOsp() bool
func (*OpenChannelEventMessage) GetPeer ¶
func (x *OpenChannelEventMessage) GetPeer() string
func (*OpenChannelEventMessage) GetReadableInitializer ¶
func (x *OpenChannelEventMessage) GetReadableInitializer() string
func (*OpenChannelEventMessage) GetStartTimeStamp ¶
func (x *OpenChannelEventMessage) GetStartTimeStamp() int64
func (*OpenChannelEventMessage) GetTokenAddr ¶
func (x *OpenChannelEventMessage) GetTokenAddr() string
func (*OpenChannelEventMessage) GetType ¶
func (x *OpenChannelEventMessage) GetType() OpenChannelEventType
func (*OpenChannelEventMessage) ProtoMessage ¶
func (*OpenChannelEventMessage) ProtoMessage()
func (*OpenChannelEventMessage) ProtoReflect ¶ added in v1.1.0
func (x *OpenChannelEventMessage) ProtoReflect() protoreflect.Message
func (*OpenChannelEventMessage) Reset ¶
func (x *OpenChannelEventMessage) Reset()
func (*OpenChannelEventMessage) String ¶
func (x *OpenChannelEventMessage) String() string
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) Descriptor ¶ added in v1.1.0
func (OpenChannelEventType) Descriptor() protoreflect.EnumDescriptor
func (OpenChannelEventType) Enum ¶ added in v1.1.0
func (x OpenChannelEventType) Enum() *OpenChannelEventType
func (OpenChannelEventType) EnumDescriptor
deprecated
func (OpenChannelEventType) EnumDescriptor() ([]byte, []int)
Deprecated: Use OpenChannelEventType.Descriptor instead.
func (OpenChannelEventType) Number ¶ added in v1.1.0
func (x OpenChannelEventType) Number() protoreflect.EnumNumber
func (OpenChannelEventType) String ¶
func (x OpenChannelEventType) String() string
func (OpenChannelEventType) Type ¶ added in v1.1.0
func (OpenChannelEventType) Type() protoreflect.EnumType
type PayEventMessage ¶
type PayEventMessage struct {
Type PayMessageType `protobuf:"varint,1,opt,name=type,proto3,enum=pem.PayMessageType" json:"type,omitempty"` // all
// pay_id this message is about.
PayId string `protobuf:"bytes,2,opt,name=pay_id,json=payId,proto3" json:"pay_id,omitempty"` // pay req in, out local/remote, pay resp, settle resp
// token used by the pay.
Token string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"` // pay req in
// message src
Src string `protobuf:"bytes,5,opt,name=src,proto3" json:"src,omitempty"` // pay req in
// message dst
Dst string `protobuf:"bytes,6,opt,name=dst,proto3" json:"dst,omitempty"` // pay req out local/remote
// direct peer the message comes from.
MsgFrom string `protobuf:"bytes,7,opt,name=msg_from,json=msgFrom,proto3" json:"msg_from,omitempty"` // all
// 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"` // pay req in, pay resp, settle resp
// which machine processed the message
Machine string `protobuf:"bytes,11,opt,name=machine,proto3" json:"machine,omitempty"` // all
// cid this message comes from
FromCid string `protobuf:"bytes,12,opt,name=from_cid,json=fromCid,proto3" json:"from_cid,omitempty"` // pay req in
// cid this message goes to
ToCid string `protobuf:"bytes,13,opt,name=to_cid,json=toCid,proto3" json:"to_cid,omitempty"` // pay req out local/remote, pay resp, settle resp
// 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"` // cond pay resp, settle pay resp
// 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"` // cond pay resp, settle pay resp
// 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"`
// contains filtered or unexported fields
}
Next tag: 30
func NewPem ¶
func NewPem(machine string) *PayEventMessage
func (*PayEventMessage) Descriptor
deprecated
func (*PayEventMessage) Descriptor() ([]byte, []int)
Deprecated: Use PayEventMessage.ProtoReflect.Descriptor instead.
func (*PayEventMessage) GetDelegationDescription ¶
func (x *PayEventMessage) GetDelegationDescription() *rpc.DelegationDescription
func (*PayEventMessage) GetDirectPay ¶
func (x *PayEventMessage) GetDirectPay() bool
func (*PayEventMessage) GetDst ¶
func (x *PayEventMessage) GetDst() string
func (*PayEventMessage) GetEndTimeStamp ¶
func (x *PayEventMessage) GetEndTimeStamp() int64
func (*PayEventMessage) GetError ¶
func (x *PayEventMessage) GetError() []string
func (*PayEventMessage) GetExecutionTimeMs ¶
func (x *PayEventMessage) GetExecutionTimeMs() float32
func (*PayEventMessage) GetForwardingExternal ¶
func (x *PayEventMessage) GetForwardingExternal() bool
func (*PayEventMessage) GetFromCid ¶
func (x *PayEventMessage) GetFromCid() string
func (*PayEventMessage) GetMachine ¶
func (x *PayEventMessage) GetMachine() string
func (*PayEventMessage) GetMsgFrom ¶
func (x *PayEventMessage) GetMsgFrom() string
func (*PayEventMessage) GetMsgTo ¶
func (x *PayEventMessage) GetMsgTo() string
func (*PayEventMessage) GetNack ¶
func (x *PayEventMessage) GetNack() *rpc.Error
func (*PayEventMessage) GetNackPayIds ¶
func (x *PayEventMessage) GetNackPayIds() []string
func (*PayEventMessage) GetPayId ¶
func (x *PayEventMessage) GetPayId() string
func (*PayEventMessage) GetPayIds ¶
func (x *PayEventMessage) GetPayIds() []string
func (*PayEventMessage) GetPayPath ¶
func (x *PayEventMessage) GetPayPath() string
func (*PayEventMessage) GetResend ¶
func (x *PayEventMessage) GetResend() []*PayEventMessage
func (*PayEventMessage) GetSecret ¶
func (x *PayEventMessage) GetSecret() string
func (*PayEventMessage) GetSeqNums ¶
func (x *PayEventMessage) GetSeqNums() *SimplexSeqNums
func (*PayEventMessage) GetSettleReason ¶
func (x *PayEventMessage) GetSettleReason() rpc.PaymentSettleReason
func (*PayEventMessage) GetSrc ¶
func (x *PayEventMessage) GetSrc() string
func (*PayEventMessage) GetStartTimeStamp ¶
func (x *PayEventMessage) GetStartTimeStamp() int64
func (*PayEventMessage) GetToCid ¶
func (x *PayEventMessage) GetToCid() string
func (*PayEventMessage) GetToken ¶
func (x *PayEventMessage) GetToken() string
func (*PayEventMessage) GetType ¶
func (x *PayEventMessage) GetType() PayMessageType
func (*PayEventMessage) GetXnet ¶
func (x *PayEventMessage) GetXnet() *CrossNetInfo
func (*PayEventMessage) ProtoMessage ¶
func (*PayEventMessage) ProtoMessage()
func (*PayEventMessage) ProtoReflect ¶ added in v1.1.0
func (x *PayEventMessage) ProtoReflect() protoreflect.Message
func (*PayEventMessage) Reset ¶
func (x *PayEventMessage) Reset()
func (*PayEventMessage) String ¶
func (x *PayEventMessage) String() string
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) Descriptor ¶ added in v1.1.0
func (PayMessageType) Descriptor() protoreflect.EnumDescriptor
func (PayMessageType) Enum ¶ added in v1.1.0
func (x PayMessageType) Enum() *PayMessageType
func (PayMessageType) EnumDescriptor
deprecated
func (PayMessageType) EnumDescriptor() ([]byte, []int)
Deprecated: Use PayMessageType.Descriptor instead.
func (PayMessageType) Number ¶ added in v1.1.0
func (x PayMessageType) Number() protoreflect.EnumNumber
func (PayMessageType) String ¶
func (x PayMessageType) String() string
func (PayMessageType) Type ¶ added in v1.1.0
func (PayMessageType) Type() protoreflect.EnumType
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"`
// contains filtered or unexported fields
}
func (*SimplexSeqNums) Descriptor
deprecated
func (*SimplexSeqNums) Descriptor() ([]byte, []int)
Deprecated: Use SimplexSeqNums.ProtoReflect.Descriptor instead.
func (*SimplexSeqNums) GetAck ¶
func (x *SimplexSeqNums) GetAck() uint64
func (*SimplexSeqNums) GetIn ¶
func (x *SimplexSeqNums) GetIn() uint64
func (*SimplexSeqNums) GetInBase ¶
func (x *SimplexSeqNums) GetInBase() uint64
func (*SimplexSeqNums) GetLastInflight ¶
func (x *SimplexSeqNums) GetLastInflight() uint64
func (*SimplexSeqNums) GetOut ¶
func (x *SimplexSeqNums) GetOut() uint64
func (*SimplexSeqNums) GetOutBase ¶
func (x *SimplexSeqNums) GetOutBase() uint64
func (*SimplexSeqNums) GetStored ¶
func (x *SimplexSeqNums) GetStored() uint64
func (*SimplexSeqNums) ProtoMessage ¶
func (*SimplexSeqNums) ProtoMessage()
func (*SimplexSeqNums) ProtoReflect ¶ added in v1.1.0
func (x *SimplexSeqNums) ProtoReflect() protoreflect.Message
func (*SimplexSeqNums) Reset ¶
func (x *SimplexSeqNums) Reset()
func (*SimplexSeqNums) String ¶
func (x *SimplexSeqNums) String() string
Click to show internal directories.
Click to hide internal directories.