rpc

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: 19 Imported by: 0

Documentation

Overview

Package rpc is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
var DepositState_name = map[int32]string{
	0: "Deposit_NOT_FOUND",
	1: "Deposit_QUEUED",
	2: "Deposit_SUBMITTED",
	3: "Deposit_SUCCEEDED",
	4: "Deposit_FAILED",
}
View Source
var DepositState_value = map[string]int32{
	"Deposit_NOT_FOUND": 0,
	"Deposit_QUEUED":    1,
	"Deposit_SUBMITTED": 2,
	"Deposit_SUCCEEDED": 3,
	"Deposit_FAILED":    4,
}
View Source
var ErrCode_name = map[int32]string{
	0:  "OK",
	1:  "UNAUTHORIZED",
	2:  "INVALID_SIG",
	3:  "INCORRECT_CLOCK",
	4:  "WRONG_PEER",
	5:  "INVALID_SEQ_NUM",
	6:  "PAY_ROUTE_LOOP",
	7:  "NO_ROUTE_TO_DST",
	8:  "NOT_ENOUGH_BALANCE",
	9:  "PEER_NOT_ONLINE",
	10: "MISC_ERROR",
}
View Source
var ErrCode_value = map[string]int32{
	"OK":                 0,
	"UNAUTHORIZED":       1,
	"INVALID_SIG":        2,
	"INCORRECT_CLOCK":    3,
	"WRONG_PEER":         4,
	"INVALID_SEQ_NUM":    5,
	"PAY_ROUTE_LOOP":     6,
	"NO_ROUTE_TO_DST":    7,
	"NOT_ENOUGH_BALANCE": 8,
	"PEER_NOT_ONLINE":    9,
	"MISC_ERROR":         10,
}
View Source
var JoinCelerStatus_name = map[int32]string{
	0: "NOT_JOIN",
	1: "LOCAL",
	2: "REMOTE",
}
View Source
var JoinCelerStatus_value = map[string]int32{
	"NOT_JOIN": 0,
	"LOCAL":    1,
	"REMOTE":   2,
}
View Source
var OpenChannelBy_name = map[int32]string{
	0: "UNDEFINED_OPEN_BY",
	1: "OPEN_CHANNEL_PROPOSER",
	2: "OPEN_CHANNEL_APPROVER",
}
View Source
var OpenChannelBy_value = map[string]int32{
	"UNDEFINED_OPEN_BY":     0,
	"OPEN_CHANNEL_PROPOSER": 1,
	"OPEN_CHANNEL_APPROVER": 2,
}
View Source
var OpenChannelStatus_name = map[int32]string{
	0: "UNDEFINED_OPEN_CHANNEL_STATUS",
	1: "OPEN_CHANNEL_APPROVED",
	2: "OPEN_CHANNEL_TX_SUBMITTED",
	3: "OPEN_CHANNEL_TCB_OPENED",
}
View Source
var OpenChannelStatus_value = map[string]int32{
	"UNDEFINED_OPEN_CHANNEL_STATUS": 0,
	"OPEN_CHANNEL_APPROVED":         1,
	"OPEN_CHANNEL_TX_SUBMITTED":     2,
	"OPEN_CHANNEL_TCB_OPENED":       3,
}
View Source
var PaymentSettleReason_name = map[int32]string{
	0: "NONE",
	1: "PAY_EXPIRED",
	2: "PAY_REJECTED",
	3: "PAY_RESOLVED_ONCHAIN",
	4: "PAY_PAID_MAX",
	5: "PAY_DEST_UNREACHABLE",
	6: "PAY_VOUCHED",
}
View Source
var PaymentSettleReason_value = map[string]int32{
	"NONE":                 0,
	"PAY_EXPIRED":          1,
	"PAY_REJECTED":         2,
	"PAY_RESOLVED_ONCHAIN": 3,
	"PAY_PAID_MAX":         4,
	"PAY_DEST_UNREACHABLE": 5,
	"PAY_VOUCHED":          6,
}

Functions

func RegisterAdminHandler

func RegisterAdminHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterAdminHandler registers the http handlers for service Admin to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterAdminHandlerClient

func RegisterAdminHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AdminClient) error

RegisterAdminHandlerClient registers the http handlers for service Admin to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "AdminClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "AdminClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "AdminClient" to call the correct interceptors.

func RegisterAdminHandlerFromEndpoint

func RegisterAdminHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterAdminHandlerFromEndpoint is same as RegisterAdminHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterAdminServer

func RegisterAdminServer(s *grpc.Server, srv AdminServer)

func RegisterMultiServerServer

func RegisterMultiServerServer(s *grpc.Server, srv MultiServerServer)

func RegisterRpcServer

func RegisterRpcServer(s *grpc.Server, srv RpcServer)

Types

type AdminClient

type AdminClient interface {
	// ConfirmOnChainResolvedPaysWithPeerOsps instructs Osp to confirm on-chain resolved pays between itself and connected osps.
	ConfirmOnChainResolvedPaysWithPeerOsps(ctx context.Context, in *ConfirmOnChainResolvedPaysRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// ClearExpiredPaysWithPeerOsps instructs Osp to clear expired pays between itself and connected osps.
	ClearExpiredPaysWithPeerOsps(ctx context.Context, in *ClearExpiredPaysRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// BuildRoutingTable instructs Osp to build routing table.
	BuildRoutingTable(ctx context.Context, in *BuildRoutingTableRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// RecvBcastRoutingInfo gives the OSP (listener & router) the incoming
	// broadcast routing information (OSP server forwarding to the listener).
	RecvBcastRoutingInfo(ctx context.Context, in *RoutingRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// GetPeerOsps returns info of all peer osps.
	GetPeerOsps(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*PeerOspsResponse, error)
	// OspOpenChannel instructs Osp to open a state channel with a peer described in request.
	OspOpenChannel(ctx context.Context, in *OspOpenChannelRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// SendToken instructs the OSP to send token specified in SendTokenRequest.
	SendToken(ctx context.Context, in *SendTokenRequest, opts ...grpc.CallOption) (*SendTokenResponse, error)
	// Deposit instructs the OSP to deposit token specified in DepositRequest.
	Deposit(ctx context.Context, in *DepositRequest, opts ...grpc.CallOption) (*DepositResponse, error)
	// QueryDeposit asks OSP about the deposit status
	QueryDeposit(ctx context.Context, in *QueryDepositRequest, opts ...grpc.CallOption) (*QueryDepositResponse, error)
	// RegisterStream instructs the OSP to connect with other osp specified in RegisterStreamRequest.
	RegisterStream(ctx context.Context, in *RegisterStreamRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	CooperativeWithdraw(ctx context.Context, in *ChannelOpRequest, opts ...grpc.CallOption) (*ChannelOpResponse, error)
	CooperativeSettle(ctx context.Context, in *ChannelOpRequest, opts ...grpc.CallOption) (*ChannelOpResponse, error)
}

AdminClient is the client API for Admin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewAdminClient

func NewAdminClient(cc *grpc.ClientConn) AdminClient

type AdminServer

type AdminServer interface {
	// ConfirmOnChainResolvedPaysWithPeerOsps instructs Osp to confirm on-chain resolved pays between itself and connected osps.
	ConfirmOnChainResolvedPaysWithPeerOsps(context.Context, *ConfirmOnChainResolvedPaysRequest) (*empty.Empty, error)
	// ClearExpiredPaysWithPeerOsps instructs Osp to clear expired pays between itself and connected osps.
	ClearExpiredPaysWithPeerOsps(context.Context, *ClearExpiredPaysRequest) (*empty.Empty, error)
	// BuildRoutingTable instructs Osp to build routing table.
	BuildRoutingTable(context.Context, *BuildRoutingTableRequest) (*empty.Empty, error)
	// RecvBcastRoutingInfo gives the OSP (listener & router) the incoming
	// broadcast routing information (OSP server forwarding to the listener).
	RecvBcastRoutingInfo(context.Context, *RoutingRequest) (*empty.Empty, error)
	// GetPeerOsps returns info of all peer osps.
	GetPeerOsps(context.Context, *empty.Empty) (*PeerOspsResponse, error)
	// OspOpenChannel instructs Osp to open a state channel with a peer described in request.
	OspOpenChannel(context.Context, *OspOpenChannelRequest) (*empty.Empty, error)
	// SendToken instructs the OSP to send token specified in SendTokenRequest.
	SendToken(context.Context, *SendTokenRequest) (*SendTokenResponse, error)
	// Deposit instructs the OSP to deposit token specified in DepositRequest.
	Deposit(context.Context, *DepositRequest) (*DepositResponse, error)
	// QueryDeposit asks OSP about the deposit status
	QueryDeposit(context.Context, *QueryDepositRequest) (*QueryDepositResponse, error)
	// RegisterStream instructs the OSP to connect with other osp specified in RegisterStreamRequest.
	RegisterStream(context.Context, *RegisterStreamRequest) (*empty.Empty, error)
	CooperativeWithdraw(context.Context, *ChannelOpRequest) (*ChannelOpResponse, error)
	CooperativeSettle(context.Context, *ChannelOpRequest) (*ChannelOpResponse, error)
}

AdminServer is the server API for Admin service.

type AuthAck

type AuthAck struct {
	// expect requester to set mid to start_mid in next message
	// including the assigned tag
	StartMid *MID `protobuf:"bytes,1,opt,name=start_mid,json=startMid,proto3" json:"start_mid,omitempty"`
	// if req set mutual_auth, return acker's sig of authreq.timestamp
	// we assume requester has context to verify against expect_peer
	MySig []byte `protobuf:"bytes,2,opt,name=my_sig,json=mySig,proto3" json:"my_sig,omitempty"`
	// channels to be syned w/ auth requester
	SyncChannels         []*ChannelInAuth `protobuf:"bytes,3,rep,name=sync_channels,json=syncChannels,proto3" json:"sync_channels,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*AuthAck) Descriptor

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

func (*AuthAck) GetMySig

func (m *AuthAck) GetMySig() []byte

func (*AuthAck) GetStartMid

func (m *AuthAck) GetStartMid() *MID

func (*AuthAck) GetSyncChannels

func (m *AuthAck) GetSyncChannels() []*ChannelInAuth

func (*AuthAck) ProtoMessage

func (*AuthAck) ProtoMessage()

func (*AuthAck) Reset

func (m *AuthAck) Reset()

func (*AuthAck) String

func (m *AuthAck) String() string

func (*AuthAck) XXX_DiscardUnknown

func (m *AuthAck) XXX_DiscardUnknown()

func (*AuthAck) XXX_Marshal

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

func (*AuthAck) XXX_Merge

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

func (*AuthAck) XXX_Size

func (m *AuthAck) XXX_Size() int

func (*AuthAck) XXX_Unmarshal

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

type AuthReq

type AuthReq struct {
	MyAddr []byte `protobuf:"bytes,1,opt,name=my_addr,json=myAddr,proto3" json:"my_addr,omitempty"`
	// protect against replay attack
	Timestamp uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// sig of timestamp field
	MySig      []byte `protobuf:"bytes,3,opt,name=my_sig,json=mySig,proto3" json:"my_sig,omitempty"`
	ExpectPeer []byte `protobuf:"bytes,4,opt,name=expect_peer,json=expectPeer,proto3" json:"expect_peer,omitempty"`
	// whether to require peer proving it owns expect_peer
	MutualAuth bool `protobuf:"varint,5,opt,name=mutual_auth,json=mutualAuth,proto3" json:"mutual_auth,omitempty"`
	// r0.15 doesn't have this field so it's 0
	// r0.16 has 1 to support sync in auth
	ProtocolVersion uint64 `protobuf:"varint,6,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	// client's view of channels. empty if never openchan or recover case
	OpenedChannels       []*ChannelSummary `protobuf:"bytes,7,rep,name=opened_channels,json=openedChannels,proto3" json:"opened_channels,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

prove to peer I own this addr

func (*AuthReq) Descriptor

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

func (*AuthReq) GetExpectPeer

func (m *AuthReq) GetExpectPeer() []byte

func (*AuthReq) GetMutualAuth

func (m *AuthReq) GetMutualAuth() bool

func (*AuthReq) GetMyAddr

func (m *AuthReq) GetMyAddr() []byte

func (*AuthReq) GetMySig

func (m *AuthReq) GetMySig() []byte

func (*AuthReq) GetOpenedChannels

func (m *AuthReq) GetOpenedChannels() []*ChannelSummary

func (*AuthReq) GetProtocolVersion

func (m *AuthReq) GetProtocolVersion() uint64

func (*AuthReq) GetTimestamp

func (m *AuthReq) GetTimestamp() uint64

func (*AuthReq) ProtoMessage

func (*AuthReq) ProtoMessage()

func (*AuthReq) Reset

func (m *AuthReq) Reset()

func (*AuthReq) String

func (m *AuthReq) String() string

func (*AuthReq) XXX_DiscardUnknown

func (m *AuthReq) XXX_DiscardUnknown()

func (*AuthReq) XXX_Marshal

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

func (*AuthReq) XXX_Merge

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

func (*AuthReq) XXX_Size

func (m *AuthReq) XXX_Size() int

func (*AuthReq) XXX_Unmarshal

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

type BcastRoutingReply

type BcastRoutingReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next tag: 1

func (*BcastRoutingReply) Descriptor

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

func (*BcastRoutingReply) ProtoMessage

func (*BcastRoutingReply) ProtoMessage()

func (*BcastRoutingReply) Reset

func (m *BcastRoutingReply) Reset()

func (*BcastRoutingReply) String

func (m *BcastRoutingReply) String() string

func (*BcastRoutingReply) XXX_DiscardUnknown

func (m *BcastRoutingReply) XXX_DiscardUnknown()

func (*BcastRoutingReply) XXX_Marshal

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

func (*BcastRoutingReply) XXX_Merge

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

func (*BcastRoutingReply) XXX_Size

func (m *BcastRoutingReply) XXX_Size() int

func (*BcastRoutingReply) XXX_Unmarshal

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

type BcastRoutingRequest

type BcastRoutingRequest struct {
	// the routing request to broadcast
	Req *RoutingRequest `protobuf:"bytes,1,opt,name=req,proto3" json:"req,omitempty"`
	// peer OSPs to send the request to
	Osps                 []string `protobuf:"bytes,2,rep,name=osps,proto3" json:"osps,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next tag: 3

func (*BcastRoutingRequest) Descriptor

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

func (*BcastRoutingRequest) GetOsps

func (m *BcastRoutingRequest) GetOsps() []string

func (*BcastRoutingRequest) GetReq

func (m *BcastRoutingRequest) GetReq() *RoutingRequest

func (*BcastRoutingRequest) ProtoMessage

func (*BcastRoutingRequest) ProtoMessage()

func (*BcastRoutingRequest) Reset

func (m *BcastRoutingRequest) Reset()

func (*BcastRoutingRequest) String

func (m *BcastRoutingRequest) String() string

func (*BcastRoutingRequest) XXX_DiscardUnknown

func (m *BcastRoutingRequest) XXX_DiscardUnknown()

func (*BcastRoutingRequest) XXX_Marshal

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

func (*BcastRoutingRequest) XXX_Merge

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

func (*BcastRoutingRequest) XXX_Size

func (m *BcastRoutingRequest) XXX_Size() int

func (*BcastRoutingRequest) XXX_Unmarshal

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

type BuildRoutingTableRequest

type BuildRoutingTableRequest struct {
	TokenAddress         []byte   `protobuf:"bytes,1,opt,name=token_address,json=tokenAddress,proto3" json:"token_address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Admin request to build routing table. Next tag: 2

func (*BuildRoutingTableRequest) Descriptor

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

func (*BuildRoutingTableRequest) GetTokenAddress

func (m *BuildRoutingTableRequest) GetTokenAddress() []byte

func (*BuildRoutingTableRequest) ProtoMessage

func (*BuildRoutingTableRequest) ProtoMessage()

func (*BuildRoutingTableRequest) Reset

func (m *BuildRoutingTableRequest) Reset()

func (*BuildRoutingTableRequest) String

func (m *BuildRoutingTableRequest) String() string

func (*BuildRoutingTableRequest) XXX_DiscardUnknown

func (m *BuildRoutingTableRequest) XXX_DiscardUnknown()

func (*BuildRoutingTableRequest) XXX_Marshal

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

func (*BuildRoutingTableRequest) XXX_Merge

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

func (*BuildRoutingTableRequest) XXX_Size

func (m *BuildRoutingTableRequest) XXX_Size() int

func (*BuildRoutingTableRequest) XXX_Unmarshal

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

type CelerMsg

type CelerMsg struct {
	Mid *MID `protobuf:"bytes,1,opt,name=mid,proto3" json:"mid,omitempty"`
	// if ret_mid is set in received msg, use it as mid in next msg to send
	// this is to support multi-msg exchanges and let both ends be able to correlate
	// their own MID req/resp
	RetMid *MID `protobuf:"bytes,2,opt,name=ret_mid,json=retMid,proto3" json:"ret_mid,omitempty"`
	// bitmask flags for nature of this msg, eg. End2End, First msg in subflow, Last of subflow etc
	Flag uint64 `protobuf:"varint,3,opt,name=flag,proto3" json:"flag,omitempty"`
	// to_addr is only used for end-to-end msg to save relay node looking into payload
	// for hop-by-hop, expected peer addr is already checked in authreq/ack so no need in every msg
	ToAddr []byte `protobuf:"bytes,4,opt,name=to_addr,json=toAddr,proto3" json:"to_addr,omitempty"`
	// Types that are valid to be assigned to Message:
	//	*CelerMsg_Error
	//	*CelerMsg_AuthReq
	//	*CelerMsg_AuthAck
	//	*CelerMsg_CondPayRequest
	//	*CelerMsg_CondPayResponse
	//	*CelerMsg_PaymentSettleProof
	//	*CelerMsg_PaymentSettleRequest
	//	*CelerMsg_PaymentSettleResponse
	//	*CelerMsg_WithdrawRequest
	//	*CelerMsg_WithdrawResponse
	//	*CelerMsg_RoutingRequest
	//	*CelerMsg_CondPayReceipt
	//	*CelerMsg_RevealSecret
	//	*CelerMsg_RevealSecretAck
	//	*CelerMsg_PayResultVouchRequest
	//	*CelerMsg_PayResultVouchResponse
	Message              isCelerMsg_Message `protobuf_oneof:"message"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Envelope msg for unified bidi-streaming

func (*CelerMsg) Descriptor

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

func (*CelerMsg) GetAuthAck

func (m *CelerMsg) GetAuthAck() *AuthAck

func (*CelerMsg) GetAuthReq

func (m *CelerMsg) GetAuthReq() *AuthReq

func (*CelerMsg) GetCondPayReceipt

func (m *CelerMsg) GetCondPayReceipt() *CondPayReceipt

func (*CelerMsg) GetCondPayRequest

func (m *CelerMsg) GetCondPayRequest() *CondPayRequest

func (*CelerMsg) GetCondPayResponse

func (m *CelerMsg) GetCondPayResponse() *CondPayResponse

func (*CelerMsg) GetError

func (m *CelerMsg) GetError() *Error

func (*CelerMsg) GetFlag

func (m *CelerMsg) GetFlag() uint64

func (*CelerMsg) GetMessage

func (m *CelerMsg) GetMessage() isCelerMsg_Message

func (*CelerMsg) GetMid

func (m *CelerMsg) GetMid() *MID

func (*CelerMsg) GetPayResultVouchRequest

func (m *CelerMsg) GetPayResultVouchRequest() *entity.VouchedCondPayResult

func (*CelerMsg) GetPayResultVouchResponse

func (m *CelerMsg) GetPayResultVouchResponse() *entity.VouchedCondPayResult

func (*CelerMsg) GetPaymentSettleProof

func (m *CelerMsg) GetPaymentSettleProof() *PaymentSettleProof

func (*CelerMsg) GetPaymentSettleRequest

func (m *CelerMsg) GetPaymentSettleRequest() *PaymentSettleRequest

func (*CelerMsg) GetPaymentSettleResponse

func (m *CelerMsg) GetPaymentSettleResponse() *PaymentSettleResponse

func (*CelerMsg) GetRetMid

func (m *CelerMsg) GetRetMid() *MID

func (*CelerMsg) GetRevealSecret

func (m *CelerMsg) GetRevealSecret() *RevealSecret

func (*CelerMsg) GetRevealSecretAck

func (m *CelerMsg) GetRevealSecretAck() *RevealSecretAck

func (*CelerMsg) GetRoutingRequest

func (m *CelerMsg) GetRoutingRequest() *RoutingRequest

func (*CelerMsg) GetToAddr

func (m *CelerMsg) GetToAddr() []byte

func (*CelerMsg) GetWithdrawRequest

func (m *CelerMsg) GetWithdrawRequest() *CooperativeWithdrawRequest

func (*CelerMsg) GetWithdrawResponse

func (m *CelerMsg) GetWithdrawResponse() *CooperativeWithdrawResponse

func (*CelerMsg) ProtoMessage

func (*CelerMsg) ProtoMessage()

func (*CelerMsg) Reset

func (m *CelerMsg) Reset()

func (*CelerMsg) String

func (m *CelerMsg) String() string

func (*CelerMsg) XXX_DiscardUnknown

func (m *CelerMsg) XXX_DiscardUnknown()

func (*CelerMsg) XXX_Marshal

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

func (*CelerMsg) XXX_Merge

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

func (*CelerMsg) XXX_OneofWrappers

func (*CelerMsg) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*CelerMsg) XXX_Size

func (m *CelerMsg) XXX_Size() int

func (*CelerMsg) XXX_Unmarshal

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

type CelerMsg_AuthAck

type CelerMsg_AuthAck struct {
	AuthAck *AuthAck `protobuf:"bytes,8,opt,name=auth_ack,json=authAck,proto3,oneof"`
}

type CelerMsg_AuthReq

type CelerMsg_AuthReq struct {
	AuthReq *AuthReq `protobuf:"bytes,7,opt,name=auth_req,json=authReq,proto3,oneof"`
}

type CelerMsg_CondPayReceipt

type CelerMsg_CondPayReceipt struct {
	CondPayReceipt *CondPayReceipt `protobuf:"bytes,31,opt,name=cond_pay_receipt,json=condPayReceipt,proto3,oneof"`
}

type CelerMsg_CondPayRequest

type CelerMsg_CondPayRequest struct {
	CondPayRequest *CondPayRequest `protobuf:"bytes,9,opt,name=cond_pay_request,json=condPayRequest,proto3,oneof"`
}

type CelerMsg_CondPayResponse

type CelerMsg_CondPayResponse struct {
	CondPayResponse *CondPayResponse `protobuf:"bytes,10,opt,name=cond_pay_response,json=condPayResponse,proto3,oneof"`
}

type CelerMsg_Error

type CelerMsg_Error struct {
	Error *Error `protobuf:"bytes,6,opt,name=error,proto3,oneof"`
}

type CelerMsg_PayResultVouchRequest

type CelerMsg_PayResultVouchRequest struct {
	PayResultVouchRequest *entity.VouchedCondPayResult `protobuf:"bytes,34,opt,name=pay_result_vouch_request,json=payResultVouchRequest,proto3,oneof"`
}

type CelerMsg_PayResultVouchResponse

type CelerMsg_PayResultVouchResponse struct {
	PayResultVouchResponse *entity.VouchedCondPayResult `protobuf:"bytes,35,opt,name=pay_result_vouch_response,json=payResultVouchResponse,proto3,oneof"`
}

type CelerMsg_PaymentSettleProof

type CelerMsg_PaymentSettleProof struct {
	PaymentSettleProof *PaymentSettleProof `protobuf:"bytes,11,opt,name=payment_settle_proof,json=paymentSettleProof,proto3,oneof"`
}

type CelerMsg_PaymentSettleRequest

type CelerMsg_PaymentSettleRequest struct {
	PaymentSettleRequest *PaymentSettleRequest `protobuf:"bytes,12,opt,name=payment_settle_request,json=paymentSettleRequest,proto3,oneof"`
}

type CelerMsg_PaymentSettleResponse

type CelerMsg_PaymentSettleResponse struct {
	PaymentSettleResponse *PaymentSettleResponse `protobuf:"bytes,13,opt,name=payment_settle_response,json=paymentSettleResponse,proto3,oneof"`
}

type CelerMsg_RevealSecret

type CelerMsg_RevealSecret struct {
	RevealSecret *RevealSecret `protobuf:"bytes,32,opt,name=reveal_secret,json=revealSecret,proto3,oneof"`
}

type CelerMsg_RevealSecretAck

type CelerMsg_RevealSecretAck struct {
	RevealSecretAck *RevealSecretAck `protobuf:"bytes,33,opt,name=reveal_secret_ack,json=revealSecretAck,proto3,oneof"`
}

type CelerMsg_RoutingRequest

type CelerMsg_RoutingRequest struct {
	RoutingRequest *RoutingRequest `protobuf:"bytes,16,opt,name=routing_request,json=routingRequest,proto3,oneof"`
}

type CelerMsg_WithdrawRequest

type CelerMsg_WithdrawRequest struct {
	WithdrawRequest *CooperativeWithdrawRequest `protobuf:"bytes,14,opt,name=withdraw_request,json=withdrawRequest,proto3,oneof"`
}

type CelerMsg_WithdrawResponse

type CelerMsg_WithdrawResponse struct {
	WithdrawResponse *CooperativeWithdrawResponse `protobuf:"bytes,15,opt,name=withdraw_response,json=withdrawResponse,proto3,oneof"`
}

type CelerStream

type CelerStream interface {
	Send(*CelerMsg) error
	Recv() (*CelerMsg, error)
}

type ChannelInAuth

type ChannelInAuth struct {
	Cid []byte `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	// Channel state defined in agent-pay channel-fsm.go.
	ChannelState int64 `protobuf:"varint,2,opt,name=channel_state,json=channelState,proto3" json:"channel_state,omitempty"`
	// open channel response for case of TCB.
	OpenChannelResponse *OpenChannelResponse `protobuf:"bytes,3,opt,name=open_channel_response,json=openChannelResponse,proto3" json:"open_channel_response,omitempty"`
	// cosigned simplex belong to auth ack node
	AuthackSimplex *SignedSimplexState `protobuf:"bytes,4,opt,name=authack_simplex,json=authackSimplex,proto3" json:"authack_simplex,omitempty"`
	// pending pays in authack_simplex
	AuthackPays []*PayInAuthAck `protobuf:"bytes,5,rep,name=authack_pays,json=authackPays,proto3" json:"authack_pays,omitempty"`
	// cosigned simplex belong to auth requester
	AuthreqSimplex *SignedSimplexState `protobuf:"bytes,6,opt,name=authreq_simplex,json=authreqSimplex,proto3" json:"authreq_simplex,omitempty"`
	// pending pays in authreq_simplex
	AuthreqPays []*PayInAuthAck `protobuf:"bytes,7,rep,name=authreq_pays,json=authreqPays,proto3" json:"authreq_pays,omitempty"`
	// ledger address that the channel is operating on.
	LedgerAddr           []byte   `protobuf:"bytes,8,opt,name=ledger_addr,json=ledgerAddr,proto3" json:"ledger_addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

In AuthAck if need to sync channels Next tag: 9

func (*ChannelInAuth) Descriptor

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

func (*ChannelInAuth) GetAuthackPays

func (m *ChannelInAuth) GetAuthackPays() []*PayInAuthAck

func (*ChannelInAuth) GetAuthackSimplex

func (m *ChannelInAuth) GetAuthackSimplex() *SignedSimplexState

func (*ChannelInAuth) GetAuthreqPays

func (m *ChannelInAuth) GetAuthreqPays() []*PayInAuthAck

func (*ChannelInAuth) GetAuthreqSimplex

func (m *ChannelInAuth) GetAuthreqSimplex() *SignedSimplexState

func (*ChannelInAuth) GetChannelState

func (m *ChannelInAuth) GetChannelState() int64

func (*ChannelInAuth) GetCid

func (m *ChannelInAuth) GetCid() []byte

func (*ChannelInAuth) GetLedgerAddr

func (m *ChannelInAuth) GetLedgerAddr() []byte

func (*ChannelInAuth) GetOpenChannelResponse

func (m *ChannelInAuth) GetOpenChannelResponse() *OpenChannelResponse

func (*ChannelInAuth) ProtoMessage

func (*ChannelInAuth) ProtoMessage()

func (*ChannelInAuth) Reset

func (m *ChannelInAuth) Reset()

func (*ChannelInAuth) String

func (m *ChannelInAuth) String() string

func (*ChannelInAuth) XXX_DiscardUnknown

func (m *ChannelInAuth) XXX_DiscardUnknown()

func (*ChannelInAuth) XXX_Marshal

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

func (*ChannelInAuth) XXX_Merge

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

func (*ChannelInAuth) XXX_Size

func (m *ChannelInAuth) XXX_Size() int

func (*ChannelInAuth) XXX_Unmarshal

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

type ChannelOpRequest

type ChannelOpRequest struct {
	Cid                  string   `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	Wei                  string   `protobuf:"bytes,2,opt,name=wei,proto3" json:"wei,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

cooperative withdraw/settle channel request

func (*ChannelOpRequest) Descriptor

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

func (*ChannelOpRequest) GetCid

func (m *ChannelOpRequest) GetCid() string

func (*ChannelOpRequest) GetWei

func (m *ChannelOpRequest) GetWei() string

func (*ChannelOpRequest) ProtoMessage

func (*ChannelOpRequest) ProtoMessage()

func (*ChannelOpRequest) Reset

func (m *ChannelOpRequest) Reset()

func (*ChannelOpRequest) String

func (m *ChannelOpRequest) String() string

func (*ChannelOpRequest) XXX_DiscardUnknown

func (m *ChannelOpRequest) XXX_DiscardUnknown()

func (*ChannelOpRequest) XXX_Marshal

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

func (*ChannelOpRequest) XXX_Merge

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

func (*ChannelOpRequest) XXX_Size

func (m *ChannelOpRequest) XXX_Size() int

func (*ChannelOpRequest) XXX_Unmarshal

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

type ChannelOpResponse

type ChannelOpResponse struct {
	Status               int32    `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Error                string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ChannelOpResponse) Descriptor

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

func (*ChannelOpResponse) GetError

func (m *ChannelOpResponse) GetError() string

func (*ChannelOpResponse) GetStatus

func (m *ChannelOpResponse) GetStatus() int32

func (*ChannelOpResponse) ProtoMessage

func (*ChannelOpResponse) ProtoMessage()

func (*ChannelOpResponse) Reset

func (m *ChannelOpResponse) Reset()

func (*ChannelOpResponse) String

func (m *ChannelOpResponse) String() string

func (*ChannelOpResponse) XXX_DiscardUnknown

func (m *ChannelOpResponse) XXX_DiscardUnknown()

func (*ChannelOpResponse) XXX_Marshal

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

func (*ChannelOpResponse) XXX_Merge

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

func (*ChannelOpResponse) XXX_Size

func (m *ChannelOpResponse) XXX_Size() int

func (*ChannelOpResponse) XXX_Unmarshal

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

type ChannelRoutingInfo

type ChannelRoutingInfo struct {
	// channel identifier
	Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	// channel liquidity amount
	Balance              string   `protobuf:"bytes,2,opt,name=balance,proto3" json:"balance,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next tag: 3

func (*ChannelRoutingInfo) Descriptor

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

func (*ChannelRoutingInfo) GetBalance

func (m *ChannelRoutingInfo) GetBalance() string

func (*ChannelRoutingInfo) GetCid

func (m *ChannelRoutingInfo) GetCid() string

func (*ChannelRoutingInfo) ProtoMessage

func (*ChannelRoutingInfo) ProtoMessage()

func (*ChannelRoutingInfo) Reset

func (m *ChannelRoutingInfo) Reset()

func (*ChannelRoutingInfo) String

func (m *ChannelRoutingInfo) String() string

func (*ChannelRoutingInfo) XXX_DiscardUnknown

func (m *ChannelRoutingInfo) XXX_DiscardUnknown()

func (*ChannelRoutingInfo) XXX_Marshal

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

func (*ChannelRoutingInfo) XXX_Merge

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

func (*ChannelRoutingInfo) XXX_Size

func (m *ChannelRoutingInfo) XXX_Size() int

func (*ChannelRoutingInfo) XXX_Unmarshal

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

type ChannelSummary

type ChannelSummary struct {
	ChannelId            []byte   `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	MySeqNum             uint64   `protobuf:"varint,2,opt,name=my_seq_num,json=mySeqNum,proto3" json:"my_seq_num,omitempty"`
	PeerSeqNum           uint64   `protobuf:"varint,3,opt,name=peer_seq_num,json=peerSeqNum,proto3" json:"peer_seq_num,omitempty"`
	LedgerAddr           []byte   `protobuf:"bytes,4,opt,name=ledger_addr,json=ledgerAddr,proto3" json:"ledger_addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

For Auth handshake and auto recovery note with only seq num we lost the ability to sync if client side has higher value. but it's ok because after authreq/ack, osp msg queue will re-send un-acked msgs Next tag: 5

func (*ChannelSummary) Descriptor

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

func (*ChannelSummary) GetChannelId

func (m *ChannelSummary) GetChannelId() []byte

func (*ChannelSummary) GetLedgerAddr

func (m *ChannelSummary) GetLedgerAddr() []byte

func (*ChannelSummary) GetMySeqNum

func (m *ChannelSummary) GetMySeqNum() uint64

func (*ChannelSummary) GetPeerSeqNum

func (m *ChannelSummary) GetPeerSeqNum() uint64

func (*ChannelSummary) ProtoMessage

func (*ChannelSummary) ProtoMessage()

func (*ChannelSummary) Reset

func (m *ChannelSummary) Reset()

func (*ChannelSummary) String

func (m *ChannelSummary) String() string

func (*ChannelSummary) XXX_DiscardUnknown

func (m *ChannelSummary) XXX_DiscardUnknown()

func (*ChannelSummary) XXX_Marshal

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

func (*ChannelSummary) XXX_Merge

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

func (*ChannelSummary) XXX_Size

func (m *ChannelSummary) XXX_Size() int

func (*ChannelSummary) XXX_Unmarshal

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

type ClearExpiredPaysRequest

type ClearExpiredPaysRequest struct {
	TokenAddress         []byte   `protobuf:"bytes,1,opt,name=token_address,json=tokenAddress,proto3" json:"token_address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Admin request to clear expired pays. Next tag: 2

func (*ClearExpiredPaysRequest) Descriptor

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

func (*ClearExpiredPaysRequest) GetTokenAddress

func (m *ClearExpiredPaysRequest) GetTokenAddress() []byte

func (*ClearExpiredPaysRequest) ProtoMessage

func (*ClearExpiredPaysRequest) ProtoMessage()

func (*ClearExpiredPaysRequest) Reset

func (m *ClearExpiredPaysRequest) Reset()

func (*ClearExpiredPaysRequest) String

func (m *ClearExpiredPaysRequest) String() string

func (*ClearExpiredPaysRequest) XXX_DiscardUnknown

func (m *ClearExpiredPaysRequest) XXX_DiscardUnknown()

func (*ClearExpiredPaysRequest) XXX_Marshal

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

func (*ClearExpiredPaysRequest) XXX_Merge

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

func (*ClearExpiredPaysRequest) XXX_Size

func (m *ClearExpiredPaysRequest) XXX_Size() int

func (*ClearExpiredPaysRequest) XXX_Unmarshal

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

type CondPayReceipt

type CondPayReceipt struct {
	// refer to pay by its id is enough
	PayId []byte `protobuf:"bytes,1,opt,name=pay_id,json=payId,proto3" json:"pay_id,omitempty"`
	// either pay_dest signs payid or pay delegator signs pay id
	PayDestSig      []byte           `protobuf:"bytes,2,opt,name=pay_dest_sig,json=payDestSig,proto3" json:"pay_dest_sig,omitempty"`
	PayDelegatorSig []byte           `protobuf:"bytes,3,opt,name=pay_delegator_sig,json=payDelegatorSig,proto3" json:"pay_delegator_sig,omitempty"`
	DelegationProof *DelegationProof `protobuf:"bytes,4,opt,name=delegation_proof,json=delegationProof,proto3" json:"delegation_proof,omitempty"`
	// used for cross net pay
	OriginalPayId        []byte   `protobuf:"bytes,5,opt,name=original_pay_id,json=originalPayId,proto3" json:"original_pay_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next Tag: 5

func (*CondPayReceipt) Descriptor

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

func (*CondPayReceipt) GetDelegationProof

func (m *CondPayReceipt) GetDelegationProof() *DelegationProof

func (*CondPayReceipt) GetOriginalPayId

func (m *CondPayReceipt) GetOriginalPayId() []byte

func (*CondPayReceipt) GetPayDelegatorSig

func (m *CondPayReceipt) GetPayDelegatorSig() []byte

func (*CondPayReceipt) GetPayDestSig

func (m *CondPayReceipt) GetPayDestSig() []byte

func (*CondPayReceipt) GetPayId

func (m *CondPayReceipt) GetPayId() []byte

func (*CondPayReceipt) ProtoMessage

func (*CondPayReceipt) ProtoMessage()

func (*CondPayReceipt) Reset

func (m *CondPayReceipt) Reset()

func (*CondPayReceipt) String

func (m *CondPayReceipt) String() string

func (*CondPayReceipt) XXX_DiscardUnknown

func (m *CondPayReceipt) XXX_DiscardUnknown()

func (*CondPayReceipt) XXX_Marshal

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

func (*CondPayReceipt) XXX_Merge

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

func (*CondPayReceipt) XXX_Size

func (m *CondPayReceipt) XXX_Size() int

func (*CondPayReceipt) XXX_Unmarshal

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

type CondPayRequest

type CondPayRequest struct {
	// use serialized entity.ConditionalPay to ensure byte-perfect consistency across all platforms
	// and simplify payment info verification especially during on-chain settlement
	CondPay              []byte              `protobuf:"bytes,1,opt,name=cond_pay,json=condPay,proto3" json:"cond_pay,omitempty"`
	StateOnlyPeerFromSig *SignedSimplexState `` /* 127-byte string literal not displayed */
	Note                 *any.Any            `protobuf:"bytes,3,opt,name=note,proto3" json:"note,omitempty"`
	// Sequence num of the previous simplex state that this new state is based on.
	// Useful for failure recover.
	BaseSeq uint64 `protobuf:"varint,4,opt,name=base_seq,json=baseSeq,proto3" json:"base_seq,omitempty"`
	// Optimization: payment between direct peers needs only one roundtrip.
	// A direct payment is one where the source and destination of the payment
	// are directly-connected peers (e.g. client sending a payment to its OSP)
	// and the payment is unconditional.
	DirectPay bool `protobuf:"varint,5,opt,name=direct_pay,json=directPay,proto3" json:"direct_pay,omitempty"`
	// used for cross network payment
	CrossNet             *CrossNetPay `protobuf:"bytes,6,opt,name=cross_net,json=crossNet,proto3" json:"cross_net,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

CondPayRequest is the first request setting up a pay path.

func (*CondPayRequest) Descriptor

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

func (*CondPayRequest) GetBaseSeq

func (m *CondPayRequest) GetBaseSeq() uint64

func (*CondPayRequest) GetCondPay

func (m *CondPayRequest) GetCondPay() []byte

func (*CondPayRequest) GetCrossNet

func (m *CondPayRequest) GetCrossNet() *CrossNetPay

func (*CondPayRequest) GetDirectPay

func (m *CondPayRequest) GetDirectPay() bool

func (*CondPayRequest) GetNote

func (m *CondPayRequest) GetNote() *any.Any

func (*CondPayRequest) GetStateOnlyPeerFromSig

func (m *CondPayRequest) GetStateOnlyPeerFromSig() *SignedSimplexState

func (*CondPayRequest) ProtoMessage

func (*CondPayRequest) ProtoMessage()

func (*CondPayRequest) Reset

func (m *CondPayRequest) Reset()

func (*CondPayRequest) String

func (m *CondPayRequest) String() string

func (*CondPayRequest) XXX_DiscardUnknown

func (m *CondPayRequest) XXX_DiscardUnknown()

func (*CondPayRequest) XXX_Marshal

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

func (*CondPayRequest) XXX_Merge

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

func (*CondPayRequest) XXX_Size

func (m *CondPayRequest) XXX_Size() int

func (*CondPayRequest) XXX_Unmarshal

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

type CondPayResponse

type CondPayResponse struct {
	StateCosigned        *SignedSimplexState `protobuf:"bytes,1,opt,name=state_cosigned,json=stateCosigned,proto3" json:"state_cosigned,omitempty"`
	Error                *Error              `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

CondPayResponse is returning the signature of the other side in the channel.

func (*CondPayResponse) Descriptor

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

func (*CondPayResponse) GetError

func (m *CondPayResponse) GetError() *Error

func (*CondPayResponse) GetStateCosigned

func (m *CondPayResponse) GetStateCosigned() *SignedSimplexState

func (*CondPayResponse) ProtoMessage

func (*CondPayResponse) ProtoMessage()

func (*CondPayResponse) Reset

func (m *CondPayResponse) Reset()

func (*CondPayResponse) String

func (m *CondPayResponse) String() string

func (*CondPayResponse) XXX_DiscardUnknown

func (m *CondPayResponse) XXX_DiscardUnknown()

func (*CondPayResponse) XXX_Marshal

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

func (*CondPayResponse) XXX_Merge

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

func (*CondPayResponse) XXX_Size

func (m *CondPayResponse) XXX_Size() int

func (*CondPayResponse) XXX_Unmarshal

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

type ConfirmOnChainResolvedPaysRequest

type ConfirmOnChainResolvedPaysRequest struct {
	TokenAddress         []byte   `protobuf:"bytes,1,opt,name=token_address,json=tokenAddress,proto3" json:"token_address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Admin request to confirm on-chain resolved pays. Next tag: 2

func (*ConfirmOnChainResolvedPaysRequest) Descriptor

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

func (*ConfirmOnChainResolvedPaysRequest) GetTokenAddress

func (m *ConfirmOnChainResolvedPaysRequest) GetTokenAddress() []byte

func (*ConfirmOnChainResolvedPaysRequest) ProtoMessage

func (*ConfirmOnChainResolvedPaysRequest) ProtoMessage()

func (*ConfirmOnChainResolvedPaysRequest) Reset

func (*ConfirmOnChainResolvedPaysRequest) String

func (*ConfirmOnChainResolvedPaysRequest) XXX_DiscardUnknown

func (m *ConfirmOnChainResolvedPaysRequest) XXX_DiscardUnknown()

func (*ConfirmOnChainResolvedPaysRequest) XXX_Marshal

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

func (*ConfirmOnChainResolvedPaysRequest) XXX_Merge

func (*ConfirmOnChainResolvedPaysRequest) XXX_Size

func (m *ConfirmOnChainResolvedPaysRequest) XXX_Size() int

func (*ConfirmOnChainResolvedPaysRequest) XXX_Unmarshal

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

type ConnectionManager

type ConnectionManager struct {
	// contains filtered or unexported fields
}

func NewConnectionManager

func NewConnectionManager(regClient RegisterClientCallbackFunc) *ConnectionManager

func (*ConnectionManager) AddCelerStream

func (m *ConnectionManager) AddCelerStream(peerAddr ctype.Addr, stream CelerStream, msgProcessor chan *CelerMsg) context.Context

func (*ConnectionManager) AddConnection

func (m *ConnectionManager) AddConnection(peerAddr ctype.Addr, cc *grpc.ClientConn)

func (*ConnectionManager) AddErrorCallback

func (m *ConnectionManager) AddErrorCallback(peerAddr ctype.Addr, cb ErrCallbackFunc)

func (*ConnectionManager) CleanupStreams

func (m *ConnectionManager) CleanupStreams(peerAddr ctype.Addr)

CleanupStreams terminate and cleanup the existing (old) hop & flow stream goroutines to allow for new streams & goroutines to be registered for the same address. It helps call from external to aquire lock.

func (*ConnectionManager) CloseConnection

func (m *ConnectionManager) CloseConnection(peerAddr ctype.Addr)

func (*ConnectionManager) CloseNoRetry

func (m *ConnectionManager) CloseNoRetry(onchainAddr ctype.Addr)

CloseNoRetry remove errCallbacks so no more retry, then close the underlying grpc conn expect to be only called in cNode.Close

func (*ConnectionManager) GetCelerStream

func (m *ConnectionManager) GetCelerStream(peerAddr ctype.Addr) *SafeSendCelerStream

func (*ConnectionManager) GetClient

func (m *ConnectionManager) GetClient(peerAddr ctype.Addr) (RpcClient, error)

func (*ConnectionManager) GetClientByAddr

func (m *ConnectionManager) GetClientByAddr(peerAddr ctype.Addr) (RpcClient, error)

func (*ConnectionManager) GetNumCelerStreams

func (m *ConnectionManager) GetNumCelerStreams() int

func (*ConnectionManager) SetMsgQueueCallback

func (m *ConnectionManager) SetMsgQueueCallback(enable, disable MsgQueueCallbackFunc)

type CooperativeWithdrawRequest

type CooperativeWithdrawRequest struct {
	WithdrawInfo         *entity.CooperativeWithdrawInfo `protobuf:"bytes,1,opt,name=withdraw_info,json=withdrawInfo,proto3" json:"withdraw_info,omitempty"`
	RequesterSig         []byte                          `protobuf:"bytes,2,opt,name=requester_sig,json=requesterSig,proto3" json:"requester_sig,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

Next Tag: 3

func (*CooperativeWithdrawRequest) Descriptor

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

func (*CooperativeWithdrawRequest) GetRequesterSig

func (m *CooperativeWithdrawRequest) GetRequesterSig() []byte

func (*CooperativeWithdrawRequest) GetWithdrawInfo

func (*CooperativeWithdrawRequest) ProtoMessage

func (*CooperativeWithdrawRequest) ProtoMessage()

func (*CooperativeWithdrawRequest) Reset

func (m *CooperativeWithdrawRequest) Reset()

func (*CooperativeWithdrawRequest) String

func (m *CooperativeWithdrawRequest) String() string

func (*CooperativeWithdrawRequest) XXX_DiscardUnknown

func (m *CooperativeWithdrawRequest) XXX_DiscardUnknown()

func (*CooperativeWithdrawRequest) XXX_Marshal

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

func (*CooperativeWithdrawRequest) XXX_Merge

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

func (*CooperativeWithdrawRequest) XXX_Size

func (m *CooperativeWithdrawRequest) XXX_Size() int

func (*CooperativeWithdrawRequest) XXX_Unmarshal

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

type CooperativeWithdrawResponse

type CooperativeWithdrawResponse struct {
	WithdrawInfo         *entity.CooperativeWithdrawInfo `protobuf:"bytes,1,opt,name=withdraw_info,json=withdrawInfo,proto3" json:"withdraw_info,omitempty"`
	RequesterSig         []byte                          `protobuf:"bytes,2,opt,name=requester_sig,json=requesterSig,proto3" json:"requester_sig,omitempty"`
	ApproverSig          []byte                          `protobuf:"bytes,3,opt,name=approver_sig,json=approverSig,proto3" json:"approver_sig,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

Next Tag: 4

func (*CooperativeWithdrawResponse) Descriptor

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

func (*CooperativeWithdrawResponse) GetApproverSig

func (m *CooperativeWithdrawResponse) GetApproverSig() []byte

func (*CooperativeWithdrawResponse) GetRequesterSig

func (m *CooperativeWithdrawResponse) GetRequesterSig() []byte

func (*CooperativeWithdrawResponse) GetWithdrawInfo

func (*CooperativeWithdrawResponse) ProtoMessage

func (*CooperativeWithdrawResponse) ProtoMessage()

func (*CooperativeWithdrawResponse) Reset

func (m *CooperativeWithdrawResponse) Reset()

func (*CooperativeWithdrawResponse) String

func (m *CooperativeWithdrawResponse) String() string

func (*CooperativeWithdrawResponse) XXX_DiscardUnknown

func (m *CooperativeWithdrawResponse) XXX_DiscardUnknown()

func (*CooperativeWithdrawResponse) XXX_Marshal

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

func (*CooperativeWithdrawResponse) XXX_Merge

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

func (*CooperativeWithdrawResponse) XXX_Size

func (m *CooperativeWithdrawResponse) XXX_Size() int

func (*CooperativeWithdrawResponse) XXX_Unmarshal

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

type CrossNetPay

type CrossNetPay struct {
	// vars 1-3 are updated by pay src
	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"`
	OriginalPay []byte `protobuf:"bytes,3,opt,name=original_pay,json=originalPay,proto3" json:"original_pay,omitempty"`
	// vars 4-7 are updated by bridge OSPs
	Crossing             bool     `protobuf:"varint,4,opt,name=crossing,proto3" json:"crossing,omitempty"`
	BridgeAddr           []byte   `protobuf:"bytes,5,opt,name=bridge_addr,json=bridgeAddr,proto3" json:"bridge_addr,omitempty"`
	BridgeNetId          uint64   `protobuf:"varint,6,opt,name=bridge_net_id,json=bridgeNetId,proto3" json:"bridge_net_id,omitempty"`
	Timeout              uint64   `protobuf:"varint,7,opt,name=timeout,proto3" json:"timeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CrossNetPay) Descriptor

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

func (*CrossNetPay) GetBridgeAddr

func (m *CrossNetPay) GetBridgeAddr() []byte

func (*CrossNetPay) GetBridgeNetId

func (m *CrossNetPay) GetBridgeNetId() uint64

func (*CrossNetPay) GetCrossing

func (m *CrossNetPay) GetCrossing() bool

func (*CrossNetPay) GetDstNetId

func (m *CrossNetPay) GetDstNetId() uint64

func (*CrossNetPay) GetOriginalPay

func (m *CrossNetPay) GetOriginalPay() []byte

func (*CrossNetPay) GetSrcNetId

func (m *CrossNetPay) GetSrcNetId() uint64

func (*CrossNetPay) GetTimeout

func (m *CrossNetPay) GetTimeout() uint64

func (*CrossNetPay) ProtoMessage

func (*CrossNetPay) ProtoMessage()

func (*CrossNetPay) Reset

func (m *CrossNetPay) Reset()

func (*CrossNetPay) String

func (m *CrossNetPay) String() string

func (*CrossNetPay) XXX_DiscardUnknown

func (m *CrossNetPay) XXX_DiscardUnknown()

func (*CrossNetPay) XXX_Marshal

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

func (*CrossNetPay) XXX_Merge

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

func (*CrossNetPay) XXX_Size

func (m *CrossNetPay) XXX_Size() int

func (*CrossNetPay) XXX_Unmarshal

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

type DelegationDescription

type DelegationDescription struct {
	// address of delegator
	Delegator []byte `protobuf:"bytes,1,opt,name=delegator,proto3" json:"delegator,omitempty"`
	// address of delegatee
	Delegatee         []byte `protobuf:"bytes,2,opt,name=delegatee,proto3" json:"delegatee,omitempty"`
	ExpiresAfterBlock int64  `protobuf:"varint,3,opt,name=expires_after_block,json=expiresAfterBlock,proto3" json:"expires_after_block,omitempty"`
	// token addresses to be delegated
	TokenToDelegate      [][]byte `protobuf:"bytes,4,rep,name=token_to_delegate,json=tokenToDelegate,proto3" json:"token_to_delegate,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next tag: 5

func (*DelegationDescription) Descriptor

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

func (*DelegationDescription) GetDelegatee

func (m *DelegationDescription) GetDelegatee() []byte

func (*DelegationDescription) GetDelegator

func (m *DelegationDescription) GetDelegator() []byte

func (*DelegationDescription) GetExpiresAfterBlock

func (m *DelegationDescription) GetExpiresAfterBlock() int64

func (*DelegationDescription) GetTokenToDelegate

func (m *DelegationDescription) GetTokenToDelegate() [][]byte

func (*DelegationDescription) ProtoMessage

func (*DelegationDescription) ProtoMessage()

func (*DelegationDescription) Reset

func (m *DelegationDescription) Reset()

func (*DelegationDescription) String

func (m *DelegationDescription) String() string

func (*DelegationDescription) XXX_DiscardUnknown

func (m *DelegationDescription) XXX_DiscardUnknown()

func (*DelegationDescription) XXX_Marshal

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

func (*DelegationDescription) XXX_Merge

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

func (*DelegationDescription) XXX_Size

func (m *DelegationDescription) XXX_Size() int

func (*DelegationDescription) XXX_Unmarshal

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

type DelegationProof

type DelegationProof struct {
	// Serialized DelegationDescription.
	DelegationDescriptionBytes []byte `` /* 141-byte string literal not displayed */
	// signature of delegation_description_bytes signed by signer.
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// addresses of signer. Should be same to "delegator" in DelegationDescription.
	Signer               []byte   `protobuf:"bytes,3,opt,name=signer,proto3" json:"signer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next tag: 4

func (*DelegationProof) Descriptor

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

func (*DelegationProof) GetDelegationDescriptionBytes

func (m *DelegationProof) GetDelegationDescriptionBytes() []byte

func (*DelegationProof) GetSignature

func (m *DelegationProof) GetSignature() []byte

func (*DelegationProof) GetSigner

func (m *DelegationProof) GetSigner() []byte

func (*DelegationProof) ProtoMessage

func (*DelegationProof) ProtoMessage()

func (*DelegationProof) Reset

func (m *DelegationProof) Reset()

func (*DelegationProof) String

func (m *DelegationProof) String() string

func (*DelegationProof) XXX_DiscardUnknown

func (m *DelegationProof) XXX_DiscardUnknown()

func (*DelegationProof) XXX_Marshal

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

func (*DelegationProof) XXX_Merge

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

func (*DelegationProof) XXX_Size

func (m *DelegationProof) XXX_Size() int

func (*DelegationProof) XXX_Unmarshal

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

type DelegationRequest

type DelegationRequest struct {
	Proof                *DelegationProof `protobuf:"bytes,1,opt,name=proof,proto3" json:"proof,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Next tag: 2

func (*DelegationRequest) Descriptor

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

func (*DelegationRequest) GetProof

func (m *DelegationRequest) GetProof() *DelegationProof

func (*DelegationRequest) ProtoMessage

func (*DelegationRequest) ProtoMessage()

func (*DelegationRequest) Reset

func (m *DelegationRequest) Reset()

func (*DelegationRequest) String

func (m *DelegationRequest) String() string

func (*DelegationRequest) XXX_DiscardUnknown

func (m *DelegationRequest) XXX_DiscardUnknown()

func (*DelegationRequest) XXX_Marshal

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

func (*DelegationRequest) XXX_Merge

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

func (*DelegationRequest) XXX_Size

func (m *DelegationRequest) XXX_Size() int

func (*DelegationRequest) XXX_Unmarshal

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

type DelegationResponse

type DelegationResponse struct {
	Error                string   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next tag: 2

func (*DelegationResponse) Descriptor

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

func (*DelegationResponse) GetError

func (m *DelegationResponse) GetError() string

func (*DelegationResponse) ProtoMessage

func (*DelegationResponse) ProtoMessage()

func (*DelegationResponse) Reset

func (m *DelegationResponse) Reset()

func (*DelegationResponse) String

func (m *DelegationResponse) String() string

func (*DelegationResponse) XXX_DiscardUnknown

func (m *DelegationResponse) XXX_DiscardUnknown()

func (*DelegationResponse) XXX_Marshal

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

func (*DelegationResponse) XXX_Merge

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

func (*DelegationResponse) XXX_Size

func (m *DelegationResponse) XXX_Size() int

func (*DelegationResponse) XXX_Unmarshal

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

type DepositRequest

type DepositRequest struct {
	// payment channel peer address
	PeerAddr string `protobuf:"bytes,1,opt,name=peer_addr,json=peerAddr,proto3" json:"peer_addr,omitempty"`
	// payment channel token address
	TokenAddr string `protobuf:"bytes,2,opt,name=token_addr,json=tokenAddr,proto3" json:"token_addr,omitempty"`
	// deposit to channel peer or self (default: false, to self)
	ToPeer bool `protobuf:"varint,3,opt,name=to_peer,json=toPeer,proto3" json:"to_peer,omitempty"`
	// deposit amount in wei
	AmtWei string `protobuf:"bytes,4,opt,name=amt_wei,json=amtWei,proto3" json:"amt_wei,omitempty"`
	// time (in seconds) allowed for OSP to wait and batch requests before submitting the on-chain transaction
	MaxWaitS             uint64   `protobuf:"varint,5,opt,name=max_wait_s,json=maxWaitS,proto3" json:"max_wait_s,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next Tag: 6

func (*DepositRequest) Descriptor

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

func (*DepositRequest) GetAmtWei

func (m *DepositRequest) GetAmtWei() string

func (*DepositRequest) GetMaxWaitS

func (m *DepositRequest) GetMaxWaitS() uint64

func (*DepositRequest) GetPeerAddr

func (m *DepositRequest) GetPeerAddr() string

func (*DepositRequest) GetToPeer

func (m *DepositRequest) GetToPeer() bool

func (*DepositRequest) GetTokenAddr

func (m *DepositRequest) GetTokenAddr() string

func (*DepositRequest) ProtoMessage

func (*DepositRequest) ProtoMessage()

func (*DepositRequest) Reset

func (m *DepositRequest) Reset()

func (*DepositRequest) String

func (m *DepositRequest) String() string

func (*DepositRequest) XXX_DiscardUnknown

func (m *DepositRequest) XXX_DiscardUnknown()

func (*DepositRequest) XXX_Marshal

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

func (*DepositRequest) XXX_Merge

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

func (*DepositRequest) XXX_Size

func (m *DepositRequest) XXX_Size() int

func (*DepositRequest) XXX_Unmarshal

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

type DepositResponse

type DepositResponse struct {
	Status               int32    `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Error                string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	DepositId            string   `protobuf:"bytes,3,opt,name=deposit_id,json=depositId,proto3" json:"deposit_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next Tag: 4

func (*DepositResponse) Descriptor

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

func (*DepositResponse) GetDepositId

func (m *DepositResponse) GetDepositId() string

func (*DepositResponse) GetError

func (m *DepositResponse) GetError() string

func (*DepositResponse) GetStatus

func (m *DepositResponse) GetStatus() int32

func (*DepositResponse) ProtoMessage

func (*DepositResponse) ProtoMessage()

func (*DepositResponse) Reset

func (m *DepositResponse) Reset()

func (*DepositResponse) String

func (m *DepositResponse) String() string

func (*DepositResponse) XXX_DiscardUnknown

func (m *DepositResponse) XXX_DiscardUnknown()

func (*DepositResponse) XXX_Marshal

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

func (*DepositResponse) XXX_Merge

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

func (*DepositResponse) XXX_Size

func (m *DepositResponse) XXX_Size() int

func (*DepositResponse) XXX_Unmarshal

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

type DepositState

type DepositState int32
const (
	DepositState_Deposit_NOT_FOUND DepositState = 0
	DepositState_Deposit_QUEUED    DepositState = 1
	DepositState_Deposit_SUBMITTED DepositState = 2
	DepositState_Deposit_SUCCEEDED DepositState = 3
	DepositState_Deposit_FAILED    DepositState = 4
)

func (DepositState) EnumDescriptor

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

func (DepositState) String

func (x DepositState) String() string

type ErrCallbackFunc

type ErrCallbackFunc func(addr ctype.Addr, err error)

type ErrCode

type ErrCode int32

Next Tag: 11

const (
	// reserve 0 so not setting this is not a valid error code
	ErrCode_OK ErrCode = 0
	// not yet authreq/authack
	ErrCode_UNAUTHORIZED ErrCode = 1
	// sig in authreq can't recover claimed my_addr
	ErrCode_INVALID_SIG ErrCode = 2
	// timestamp in req out of allowed range
	ErrCode_INCORRECT_CLOCK ErrCode = 3
	// I'm not your expected peer
	ErrCode_WRONG_PEER ErrCode = 4
	// invalid simplex state sequence number
	ErrCode_INVALID_SEQ_NUM ErrCode = 5
	// forwared the pay before and receiving again, probably a loop.
	ErrCode_PAY_ROUTE_LOOP ErrCode = 6
	// can't find a route to dst.
	ErrCode_NO_ROUTE_TO_DST ErrCode = 7
	// not enough balance
	ErrCode_NOT_ENOUGH_BALANCE ErrCode = 8
	// peer not online
	ErrCode_PEER_NOT_ONLINE ErrCode = 9
	// no specified error code
	ErrCode_MISC_ERROR ErrCode = 10
)

func (ErrCode) EnumDescriptor

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

func (ErrCode) String

func (x ErrCode) String() string

type Error

type Error struct {
	Code   ErrCode `protobuf:"varint,1,opt,name=code,proto3,enum=rpc.ErrCode" json:"code,omitempty"`
	Reason string  `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// sequence number (if exists) of the errored message
	Seq                  uint64   `protobuf:"varint,3,opt,name=seq,proto3" json:"seq,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Error) Descriptor

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

func (*Error) GetCode

func (m *Error) GetCode() ErrCode

func (*Error) GetReason

func (m *Error) GetReason() string

func (*Error) GetSeq

func (m *Error) GetSeq() uint64

func (*Error) ProtoMessage

func (*Error) ProtoMessage()

func (*Error) Reset

func (m *Error) Reset()

func (*Error) String

func (m *Error) String() string

func (*Error) XXX_DiscardUnknown

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal

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

func (*Error) XXX_Merge

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

func (*Error) XXX_Size

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal

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

type FwdReply

type FwdReply struct {
	Accepted             bool     `protobuf:"varint,1,opt,name=accepted,proto3" json:"accepted,omitempty"`
	Err                  string   `protobuf:"bytes,2,opt,name=err,proto3" json:"err,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next tag: 3

func (*FwdReply) Descriptor

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

func (*FwdReply) GetAccepted

func (m *FwdReply) GetAccepted() bool

func (*FwdReply) GetErr

func (m *FwdReply) GetErr() string

func (*FwdReply) ProtoMessage

func (*FwdReply) ProtoMessage()

func (*FwdReply) Reset

func (m *FwdReply) Reset()

func (*FwdReply) String

func (m *FwdReply) String() string

func (*FwdReply) XXX_DiscardUnknown

func (m *FwdReply) XXX_DiscardUnknown()

func (*FwdReply) XXX_Marshal

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

func (*FwdReply) XXX_Merge

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

func (*FwdReply) XXX_Size

func (m *FwdReply) XXX_Size() int

func (*FwdReply) XXX_Unmarshal

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

type FwdReq

type FwdReq struct {
	Dest                 string    `protobuf:"bytes,1,opt,name=dest,proto3" json:"dest,omitempty"`
	Message              *CelerMsg `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

Next tag: 6

func (*FwdReq) Descriptor

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

func (*FwdReq) GetDest

func (m *FwdReq) GetDest() string

func (*FwdReq) GetMessage

func (m *FwdReq) GetMessage() *CelerMsg

func (*FwdReq) ProtoMessage

func (*FwdReq) ProtoMessage()

func (*FwdReq) Reset

func (m *FwdReq) Reset()

func (*FwdReq) String

func (m *FwdReq) String() string

func (*FwdReq) XXX_DiscardUnknown

func (m *FwdReq) XXX_DiscardUnknown()

func (*FwdReq) XXX_Marshal

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

func (*FwdReq) XXX_Merge

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

func (*FwdReq) XXX_Size

func (m *FwdReq) XXX_Size() int

func (*FwdReq) XXX_Unmarshal

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

type GetPayHistoryRequest

type GetPayHistoryRequest struct {
	// request pay history of peer.
	Peer string `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer,omitempty"`
	// request pay history before certain timestamp.
	BeforeTs int64 `protobuf:"varint,2,opt,name=before_ts,json=beforeTs,proto3" json:"before_ts,omitempty"`
	// max result in the response.
	ItemsPerPage int32 `protobuf:"varint,3,opt,name=items_per_page,json=itemsPerPage,proto3" json:"items_per_page,omitempty"`
	// signature to verify peer.
	TsSig []byte `protobuf:"bytes,4,opt,name=ts_sig,json=tsSig,proto3" json:"ts_sig,omitempty"`
	Ts    uint64 `protobuf:"varint,5,opt,name=ts,proto3" json:"ts,omitempty"`
	// if result has pays that have payIDs equal to before_ts, only return those that have higher pay ids than smallest_pay_id.
	SmallestPayId        string   `protobuf:"bytes,6,opt,name=smallest_pay_id,json=smallestPayId,proto3" json:"smallest_pay_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next tag: 7

func (*GetPayHistoryRequest) Descriptor

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

func (*GetPayHistoryRequest) GetBeforeTs

func (m *GetPayHistoryRequest) GetBeforeTs() int64

func (*GetPayHistoryRequest) GetItemsPerPage

func (m *GetPayHistoryRequest) GetItemsPerPage() int32

func (*GetPayHistoryRequest) GetPeer

func (m *GetPayHistoryRequest) GetPeer() string

func (*GetPayHistoryRequest) GetSmallestPayId

func (m *GetPayHistoryRequest) GetSmallestPayId() string

func (*GetPayHistoryRequest) GetTs

func (m *GetPayHistoryRequest) GetTs() uint64

func (*GetPayHistoryRequest) GetTsSig

func (m *GetPayHistoryRequest) GetTsSig() []byte

func (*GetPayHistoryRequest) ProtoMessage

func (*GetPayHistoryRequest) ProtoMessage()

func (*GetPayHistoryRequest) Reset

func (m *GetPayHistoryRequest) Reset()

func (*GetPayHistoryRequest) String

func (m *GetPayHistoryRequest) String() string

func (*GetPayHistoryRequest) XXX_DiscardUnknown

func (m *GetPayHistoryRequest) XXX_DiscardUnknown()

func (*GetPayHistoryRequest) XXX_Marshal

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

func (*GetPayHistoryRequest) XXX_Merge

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

func (*GetPayHistoryRequest) XXX_Size

func (m *GetPayHistoryRequest) XXX_Size() int

func (*GetPayHistoryRequest) XXX_Unmarshal

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

type GetPayHistoryResponse

type GetPayHistoryResponse struct {
	Pays                 []*OneHistoricalPay `protobuf:"bytes,1,rep,name=pays,proto3" json:"pays,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Next tag: 2

func (*GetPayHistoryResponse) Descriptor

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

func (*GetPayHistoryResponse) GetPays

func (m *GetPayHistoryResponse) GetPays() []*OneHistoricalPay

func (*GetPayHistoryResponse) ProtoMessage

func (*GetPayHistoryResponse) ProtoMessage()

func (*GetPayHistoryResponse) Reset

func (m *GetPayHistoryResponse) Reset()

func (*GetPayHistoryResponse) String

func (m *GetPayHistoryResponse) String() string

func (*GetPayHistoryResponse) XXX_DiscardUnknown

func (m *GetPayHistoryResponse) XXX_DiscardUnknown()

func (*GetPayHistoryResponse) XXX_Marshal

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

func (*GetPayHistoryResponse) XXX_Merge

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

func (*GetPayHistoryResponse) XXX_Size

func (m *GetPayHistoryResponse) XXX_Size() int

func (*GetPayHistoryResponse) XXX_Unmarshal

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

type JoinCelerStatus

type JoinCelerStatus int32

JoinCelerStatus describes the status of a endpoint in Celer network Next Tag: 3

const (
	// Endpoint has not joined in Celer Network yet,
	// does not have any celer channel with any Osp in Celer Network
	JoinCelerStatus_NOT_JOIN JoinCelerStatus = 0
	// Endpoint has a celer channel with the Osp responding this msg
	JoinCelerStatus_LOCAL JoinCelerStatus = 1
	// Endpoint does not have a celer channel with the Osp responding this msg,
	// but has a celer channel with another remote Osp
	JoinCelerStatus_REMOTE JoinCelerStatus = 2
)

func (JoinCelerStatus) EnumDescriptor

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

func (JoinCelerStatus) String

func (x JoinCelerStatus) String() string

type MID

type MID struct {
	// tag is string to identify requester to avoid seq conflict
	// for a typical req/resp flow, both req and resp messages have the same tag
	// that identifies requester, and same seq so requester side can correlate
	// resp with req
	Tag string `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	// sender must increment seq for new messages
	Seq                  uint64   `protobuf:"varint,2,opt,name=seq,proto3" json:"seq,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

MID is the message identifier, used as map key for unary over stream NOTE: all field types must be golang comparable so map[MID] can work Auth requester should set its mid to start_mid in AuthAck

func (*MID) Descriptor

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

func (*MID) GetSeq

func (m *MID) GetSeq() uint64

func (*MID) GetTag

func (m *MID) GetTag() string

func (*MID) ProtoMessage

func (*MID) ProtoMessage()

func (*MID) Reset

func (m *MID) Reset()

func (*MID) String

func (m *MID) String() string

func (*MID) XXX_DiscardUnknown

func (m *MID) XXX_DiscardUnknown()

func (*MID) XXX_Marshal

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

func (*MID) XXX_Merge

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

func (*MID) XXX_Size

func (m *MID) XXX_Size() int

func (*MID) XXX_Unmarshal

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

type MigrateChannelRequest

type MigrateChannelRequest struct {
	// Serialized entity.ChannelMigrationInfo
	ChannelMigrationInfo []byte `protobuf:"bytes,1,opt,name=channel_migration_info,json=channelMigrationInfo,proto3" json:"channel_migration_info,omitempty"`
	// Signature of channel_migration_info signed by request sender
	RequesterSig         []byte   `protobuf:"bytes,2,opt,name=requester_sig,json=requesterSig,proto3" json:"requester_sig,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next tag: 3

func (*MigrateChannelRequest) Descriptor

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

func (*MigrateChannelRequest) GetChannelMigrationInfo

func (m *MigrateChannelRequest) GetChannelMigrationInfo() []byte

func (*MigrateChannelRequest) GetRequesterSig

func (m *MigrateChannelRequest) GetRequesterSig() []byte

func (*MigrateChannelRequest) ProtoMessage

func (*MigrateChannelRequest) ProtoMessage()

func (*MigrateChannelRequest) Reset

func (m *MigrateChannelRequest) Reset()

func (*MigrateChannelRequest) String

func (m *MigrateChannelRequest) String() string

func (*MigrateChannelRequest) XXX_DiscardUnknown

func (m *MigrateChannelRequest) XXX_DiscardUnknown()

func (*MigrateChannelRequest) XXX_Marshal

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

func (*MigrateChannelRequest) XXX_Merge

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

func (*MigrateChannelRequest) XXX_Size

func (m *MigrateChannelRequest) XXX_Size() int

func (*MigrateChannelRequest) XXX_Unmarshal

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

type MigrateChannelResponse

type MigrateChannelResponse struct {
	// Signature of channel_migration_info signed by request approver
	ApproverSig          []byte   `protobuf:"bytes,1,opt,name=approver_sig,json=approverSig,proto3" json:"approver_sig,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next tag: 2

func (*MigrateChannelResponse) Descriptor

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

func (*MigrateChannelResponse) GetApproverSig

func (m *MigrateChannelResponse) GetApproverSig() []byte

func (*MigrateChannelResponse) ProtoMessage

func (*MigrateChannelResponse) ProtoMessage()

func (*MigrateChannelResponse) Reset

func (m *MigrateChannelResponse) Reset()

func (*MigrateChannelResponse) String

func (m *MigrateChannelResponse) String() string

func (*MigrateChannelResponse) XXX_DiscardUnknown

func (m *MigrateChannelResponse) XXX_DiscardUnknown()

func (*MigrateChannelResponse) XXX_Marshal

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

func (*MigrateChannelResponse) XXX_Merge

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

func (*MigrateChannelResponse) XXX_Size

func (m *MigrateChannelResponse) XXX_Size() int

func (*MigrateChannelResponse) XXX_Unmarshal

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

type MsgQueueCallbackFunc

type MsgQueueCallbackFunc func(peer ctype.Addr) error

type MultiServerClient

type MultiServerClient interface {
	FwdMsg(ctx context.Context, in *FwdReq, opts ...grpc.CallOption) (*FwdReply, error)
	Ping(ctx context.Context, in *PingReq, opts ...grpc.CallOption) (*PingReply, error)
	PickServer(ctx context.Context, in *PickReq, opts ...grpc.CallOption) (*PickReply, error)
	BcastRoutingInfo(ctx context.Context, in *BcastRoutingRequest, opts ...grpc.CallOption) (*BcastRoutingReply, error)
}

MultiServerClient is the client API for MultiServer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMultiServerClient

func NewMultiServerClient(cc *grpc.ClientConn) MultiServerClient

type MultiServerServer

type MultiServerServer interface {
	FwdMsg(context.Context, *FwdReq) (*FwdReply, error)
	Ping(context.Context, *PingReq) (*PingReply, error)
	PickServer(context.Context, *PickReq) (*PickReply, error)
	BcastRoutingInfo(context.Context, *BcastRoutingRequest) (*BcastRoutingReply, error)
}

MultiServerServer is the server API for MultiServer service.

type OneHistoricalPay

type OneHistoricalPay struct {
	// pay destination
	Dst string `protobuf:"bytes,1,opt,name=dst,proto3" json:"dst,omitempty"`
	// token address used by the pay.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// amount of the payment
	Amt string `protobuf:"bytes,3,opt,name=amt,proto3" json:"amt,omitempty"`
	// pay status
	State int64 `protobuf:"varint,4,opt,name=state,proto3" json:"state,omitempty"`
	// pay id
	PayId string `protobuf:"bytes,5,opt,name=pay_id,json=payId,proto3" json:"pay_id,omitempty"`
	// pay creation timestamp
	CreateTs int64 `protobuf:"varint,6,opt,name=create_ts,json=createTs,proto3" json:"create_ts,omitempty"`
	// pay source
	Src                  string   `protobuf:"bytes,7,opt,name=src,proto3" json:"src,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next tag: 8

func (*OneHistoricalPay) Descriptor

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

func (*OneHistoricalPay) GetAmt

func (m *OneHistoricalPay) GetAmt() string

func (*OneHistoricalPay) GetCreateTs

func (m *OneHistoricalPay) GetCreateTs() int64

func (*OneHistoricalPay) GetDst

func (m *OneHistoricalPay) GetDst() string

func (*OneHistoricalPay) GetPayId

func (m *OneHistoricalPay) GetPayId() string

func (*OneHistoricalPay) GetSrc

func (m *OneHistoricalPay) GetSrc() string

func (*OneHistoricalPay) GetState

func (m *OneHistoricalPay) GetState() int64

func (*OneHistoricalPay) GetToken

func (m *OneHistoricalPay) GetToken() string

func (*OneHistoricalPay) ProtoMessage

func (*OneHistoricalPay) ProtoMessage()

func (*OneHistoricalPay) Reset

func (m *OneHistoricalPay) Reset()

func (*OneHistoricalPay) String

func (m *OneHistoricalPay) String() string

func (*OneHistoricalPay) XXX_DiscardUnknown

func (m *OneHistoricalPay) XXX_DiscardUnknown()

func (*OneHistoricalPay) XXX_Marshal

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

func (*OneHistoricalPay) XXX_Merge

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

func (*OneHistoricalPay) XXX_Size

func (m *OneHistoricalPay) XXX_Size() int

func (*OneHistoricalPay) XXX_Unmarshal

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

type OpenChannelBy

type OpenChannelBy int32

Next Tag: 3

const (
	OpenChannelBy_UNDEFINED_OPEN_BY     OpenChannelBy = 0
	OpenChannelBy_OPEN_CHANNEL_PROPOSER OpenChannelBy = 1
	OpenChannelBy_OPEN_CHANNEL_APPROVER OpenChannelBy = 2
)

func (OpenChannelBy) EnumDescriptor

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

func (OpenChannelBy) String

func (x OpenChannelBy) String() string

type OpenChannelRequest

type OpenChannelRequest struct {
	// serialized entity.PaymentChannelInitializer
	ChannelInitializer []byte        `protobuf:"bytes,1,opt,name=channel_initializer,json=channelInitializer,proto3" json:"channel_initializer,omitempty"`
	RequesterSig       []byte        `protobuf:"bytes,2,opt,name=requester_sig,json=requesterSig,proto3" json:"requester_sig,omitempty"`
	OpenBy             OpenChannelBy `protobuf:"varint,3,opt,name=open_by,json=openBy,proto3,enum=rpc.OpenChannelBy" json:"open_by,omitempty"`
	// osp_to_osp set to true to indicate the channel is an OSP-OSP channel.
	OspToOsp             bool     `protobuf:"varint,4,opt,name=osp_to_osp,json=ospToOsp,proto3" json:"osp_to_osp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

OpenChannelRequest when one wants to open a channel with peer. Next Tag: 5

func (*OpenChannelRequest) Descriptor

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

func (*OpenChannelRequest) GetChannelInitializer

func (m *OpenChannelRequest) GetChannelInitializer() []byte

func (*OpenChannelRequest) GetOpenBy

func (m *OpenChannelRequest) GetOpenBy() OpenChannelBy

func (*OpenChannelRequest) GetOspToOsp

func (m *OpenChannelRequest) GetOspToOsp() bool

func (*OpenChannelRequest) GetRequesterSig

func (m *OpenChannelRequest) GetRequesterSig() []byte

func (*OpenChannelRequest) ProtoMessage

func (*OpenChannelRequest) ProtoMessage()

func (*OpenChannelRequest) Reset

func (m *OpenChannelRequest) Reset()

func (*OpenChannelRequest) String

func (m *OpenChannelRequest) String() string

func (*OpenChannelRequest) XXX_DiscardUnknown

func (m *OpenChannelRequest) XXX_DiscardUnknown()

func (*OpenChannelRequest) XXX_Marshal

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

func (*OpenChannelRequest) XXX_Merge

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

func (*OpenChannelRequest) XXX_Size

func (m *OpenChannelRequest) XXX_Size() int

func (*OpenChannelRequest) XXX_Unmarshal

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

type OpenChannelResponse

type OpenChannelResponse struct {
	// serialized entity.PaymentChannelInitializer
	ChannelInitializer   []byte            `protobuf:"bytes,1,opt,name=channel_initializer,json=channelInitializer,proto3" json:"channel_initializer,omitempty"`
	RequesterSig         []byte            `protobuf:"bytes,2,opt,name=requester_sig,json=requesterSig,proto3" json:"requester_sig,omitempty"`
	ApproverSig          []byte            `protobuf:"bytes,3,opt,name=approver_sig,json=approverSig,proto3" json:"approver_sig,omitempty"`
	Status               OpenChannelStatus `protobuf:"varint,4,opt,name=status,proto3,enum=rpc.OpenChannelStatus" json:"status,omitempty"`
	PaymentChannelId     []byte            `protobuf:"bytes,5,opt,name=payment_channel_id,json=paymentChannelId,proto3" json:"payment_channel_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Next Tag: 6

func (*OpenChannelResponse) Descriptor

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

func (*OpenChannelResponse) GetApproverSig

func (m *OpenChannelResponse) GetApproverSig() []byte

func (*OpenChannelResponse) GetChannelInitializer

func (m *OpenChannelResponse) GetChannelInitializer() []byte

func (*OpenChannelResponse) GetPaymentChannelId

func (m *OpenChannelResponse) GetPaymentChannelId() []byte

func (*OpenChannelResponse) GetRequesterSig

func (m *OpenChannelResponse) GetRequesterSig() []byte

func (*OpenChannelResponse) GetStatus

func (m *OpenChannelResponse) GetStatus() OpenChannelStatus

func (*OpenChannelResponse) ProtoMessage

func (*OpenChannelResponse) ProtoMessage()

func (*OpenChannelResponse) Reset

func (m *OpenChannelResponse) Reset()

func (*OpenChannelResponse) String

func (m *OpenChannelResponse) String() string

func (*OpenChannelResponse) XXX_DiscardUnknown

func (m *OpenChannelResponse) XXX_DiscardUnknown()

func (*OpenChannelResponse) XXX_Marshal

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

func (*OpenChannelResponse) XXX_Merge

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

func (*OpenChannelResponse) XXX_Size

func (m *OpenChannelResponse) XXX_Size() int

func (*OpenChannelResponse) XXX_Unmarshal

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

type OpenChannelStatus

type OpenChannelStatus int32

Next Tag: 4

const (
	OpenChannelStatus_UNDEFINED_OPEN_CHANNEL_STATUS OpenChannelStatus = 0
	// OpenChannel is approved by approver.
	// But no on-chain transaction has been made.
	OpenChannelStatus_OPEN_CHANNEL_APPROVED OpenChannelStatus = 1
	// OpenChannel transaction is submitted on-chain by approver.
	OpenChannelStatus_OPEN_CHANNEL_TX_SUBMITTED OpenChannelStatus = 2
	OpenChannelStatus_OPEN_CHANNEL_TCB_OPENED   OpenChannelStatus = 3
)

func (OpenChannelStatus) EnumDescriptor

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

func (OpenChannelStatus) String

func (x OpenChannelStatus) String() string

type OspOpenChannelRequest

type OspOpenChannelRequest struct {
	// Peer to open channel with the osp.
	PeerEthAddress []byte `protobuf:"bytes,1,opt,name=peer_eth_address,json=peerEthAddress,proto3" json:"peer_eth_address,omitempty"`
	// ETH or ERC20
	TokenType entity.TokenType `protobuf:"varint,2,opt,name=token_type,json=tokenType,proto3,enum=entity.TokenType" json:"token_type,omitempty"`
	// where the token is defined.
	TokenAddress []byte `protobuf:"bytes,3,opt,name=token_address,json=tokenAddress,proto3" json:"token_address,omitempty"`
	// Deposit from myself in wei in decimal
	SelfDepositAmtWei string `protobuf:"bytes,4,opt,name=self_deposit_amt_wei,json=selfDepositAmtWei,proto3" json:"self_deposit_amt_wei,omitempty"`
	// Deposit asking to peer in wei in decimal
	PeerDepositAmtWei    string   `protobuf:"bytes,5,opt,name=peer_deposit_amt_wei,json=peerDepositAmtWei,proto3" json:"peer_deposit_amt_wei,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Admin request to ask the receiving osp to open a channel with peer. Next tag: 6

func (*OspOpenChannelRequest) Descriptor

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

func (*OspOpenChannelRequest) GetPeerDepositAmtWei

func (m *OspOpenChannelRequest) GetPeerDepositAmtWei() string

func (*OspOpenChannelRequest) GetPeerEthAddress

func (m *OspOpenChannelRequest) GetPeerEthAddress() []byte

func (*OspOpenChannelRequest) GetSelfDepositAmtWei

func (m *OspOpenChannelRequest) GetSelfDepositAmtWei() string

func (*OspOpenChannelRequest) GetTokenAddress

func (m *OspOpenChannelRequest) GetTokenAddress() []byte

func (*OspOpenChannelRequest) GetTokenType

func (m *OspOpenChannelRequest) GetTokenType() entity.TokenType

func (*OspOpenChannelRequest) ProtoMessage

func (*OspOpenChannelRequest) ProtoMessage()

func (*OspOpenChannelRequest) Reset

func (m *OspOpenChannelRequest) Reset()

func (*OspOpenChannelRequest) String

func (m *OspOpenChannelRequest) String() string

func (*OspOpenChannelRequest) XXX_DiscardUnknown

func (m *OspOpenChannelRequest) XXX_DiscardUnknown()

func (*OspOpenChannelRequest) XXX_Marshal

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

func (*OspOpenChannelRequest) XXX_Merge

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

func (*OspOpenChannelRequest) XXX_Size

func (m *OspOpenChannelRequest) XXX_Size() int

func (*OspOpenChannelRequest) XXX_Unmarshal

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

type PayHop

type PayHop struct {
	PayId                []byte   `protobuf:"bytes,1,opt,name=pay_id,json=payId,proto3" json:"pay_id,omitempty"`
	PrevHopAddr          []byte   `protobuf:"bytes,2,opt,name=prev_hop_addr,json=prevHopAddr,proto3" json:"prev_hop_addr,omitempty"`
	NextHopAddr          []byte   `protobuf:"bytes,3,opt,name=next_hop_addr,json=nextHopAddr,proto3" json:"next_hop_addr,omitempty"`
	Err                  *Error   `protobuf:"bytes,4,opt,name=err,proto3" json:"err,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next Tag: 5

func (*PayHop) Descriptor

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

func (*PayHop) GetErr

func (m *PayHop) GetErr() *Error

func (*PayHop) GetNextHopAddr

func (m *PayHop) GetNextHopAddr() []byte

func (*PayHop) GetPayId

func (m *PayHop) GetPayId() []byte

func (*PayHop) GetPrevHopAddr

func (m *PayHop) GetPrevHopAddr() []byte

func (*PayHop) ProtoMessage

func (*PayHop) ProtoMessage()

func (*PayHop) Reset

func (m *PayHop) Reset()

func (*PayHop) String

func (m *PayHop) String() string

func (*PayHop) XXX_DiscardUnknown

func (m *PayHop) XXX_DiscardUnknown()

func (*PayHop) XXX_Marshal

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

func (*PayHop) XXX_Merge

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

func (*PayHop) XXX_Size

func (m *PayHop) XXX_Size() int

func (*PayHop) XXX_Unmarshal

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

type PayInAuthAck

type PayInAuthAck struct {
	Pay  []byte   `protobuf:"bytes,1,opt,name=pay,proto3" json:"pay,omitempty"`
	Note *any.Any `protobuf:"bytes,2,opt,name=note,proto3" json:"note,omitempty"`
	// pay state, from instate or outstate depending on which simplex
	State                int64    `protobuf:"varint,3,opt,name=state,proto3" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PayInAuthAck) Descriptor

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

func (*PayInAuthAck) GetNote

func (m *PayInAuthAck) GetNote() *any.Any

func (*PayInAuthAck) GetPay

func (m *PayInAuthAck) GetPay() []byte

func (*PayInAuthAck) GetState

func (m *PayInAuthAck) GetState() int64

func (*PayInAuthAck) ProtoMessage

func (*PayInAuthAck) ProtoMessage()

func (*PayInAuthAck) Reset

func (m *PayInAuthAck) Reset()

func (*PayInAuthAck) String

func (m *PayInAuthAck) String() string

func (*PayInAuthAck) XXX_DiscardUnknown

func (m *PayInAuthAck) XXX_DiscardUnknown()

func (*PayInAuthAck) XXX_Marshal

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

func (*PayInAuthAck) XXX_Merge

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

func (*PayInAuthAck) XXX_Size

func (m *PayInAuthAck) XXX_Size() int

func (*PayInAuthAck) XXX_Unmarshal

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

type PayPath

type PayPath struct {
	Hops                 []*SignedPayHop `protobuf:"bytes,1,rep,name=hops,proto3" json:"hops,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Next Tag: 2

func (*PayPath) Descriptor

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

func (*PayPath) GetHops

func (m *PayPath) GetHops() []*SignedPayHop

func (*PayPath) ProtoMessage

func (*PayPath) ProtoMessage()

func (*PayPath) Reset

func (m *PayPath) Reset()

func (*PayPath) String

func (m *PayPath) String() string

func (*PayPath) XXX_DiscardUnknown

func (m *PayPath) XXX_DiscardUnknown()

func (*PayPath) XXX_Marshal

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

func (*PayPath) XXX_Merge

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

func (*PayPath) XXX_Size

func (m *PayPath) XXX_Size() int

func (*PayPath) XXX_Unmarshal

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

type PaymentSettleProof

type PaymentSettleProof struct {
	VouchedCondPayResults []*entity.VouchedCondPayResult `` /* 128-byte string literal not displayed */
	// valid reasons for settled_pays in PaymentSettleProof
	// EXPIRED, REJECTED, RESOLVED_ONCHAIN, DEST_UNREACHABLE
	SettledPays          []*SettledPayment `protobuf:"bytes,2,rep,name=settled_pays,json=settledPays,proto3" json:"settled_pays,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

PaymentSettleProof provides all condition results to settle a pay. Expect after receives this msg, peer will send PaymentSettleRequest Next Tag: 3

func (*PaymentSettleProof) Descriptor

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

func (*PaymentSettleProof) GetSettledPays

func (m *PaymentSettleProof) GetSettledPays() []*SettledPayment

func (*PaymentSettleProof) GetVouchedCondPayResults

func (m *PaymentSettleProof) GetVouchedCondPayResults() []*entity.VouchedCondPayResult

func (*PaymentSettleProof) ProtoMessage

func (*PaymentSettleProof) ProtoMessage()

func (*PaymentSettleProof) Reset

func (m *PaymentSettleProof) Reset()

func (*PaymentSettleProof) String

func (m *PaymentSettleProof) String() string

func (*PaymentSettleProof) XXX_DiscardUnknown

func (m *PaymentSettleProof) XXX_DiscardUnknown()

func (*PaymentSettleProof) XXX_Marshal

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

func (*PaymentSettleProof) XXX_Merge

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

func (*PaymentSettleProof) XXX_Size

func (m *PaymentSettleProof) XXX_Size() int

func (*PaymentSettleProof) XXX_Unmarshal

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

type PaymentSettleReason

type PaymentSettleReason int32

Next Tag: 7

const (
	PaymentSettleReason_NONE                 PaymentSettleReason = 0
	PaymentSettleReason_PAY_EXPIRED          PaymentSettleReason = 1
	PaymentSettleReason_PAY_REJECTED         PaymentSettleReason = 2
	PaymentSettleReason_PAY_RESOLVED_ONCHAIN PaymentSettleReason = 3
	PaymentSettleReason_PAY_PAID_MAX         PaymentSettleReason = 4
	PaymentSettleReason_PAY_DEST_UNREACHABLE PaymentSettleReason = 5
	PaymentSettleReason_PAY_VOUCHED          PaymentSettleReason = 6
)

func (PaymentSettleReason) EnumDescriptor

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

func (PaymentSettleReason) String

func (x PaymentSettleReason) String() string

type PaymentSettleRequest

type PaymentSettleRequest struct {
	SettledPays          []*SettledPayment   `protobuf:"bytes,1,rep,name=settled_pays,json=settledPays,proto3" json:"settled_pays,omitempty"`
	StateOnlyPeerFromSig *SignedSimplexState `` /* 127-byte string literal not displayed */
	// Sequence num of the previous simplex state that this new state is based on.
	// Useful for failure recover.
	BaseSeq              uint64   `protobuf:"varint,3,opt,name=base_seq,json=baseSeq,proto3" json:"base_seq,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

When peer_from of a simplex channel wants to settle a pay the updated simplex will be sent along with its signature.

func (*PaymentSettleRequest) Descriptor

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

func (*PaymentSettleRequest) GetBaseSeq

func (m *PaymentSettleRequest) GetBaseSeq() uint64

func (*PaymentSettleRequest) GetSettledPays

func (m *PaymentSettleRequest) GetSettledPays() []*SettledPayment

func (*PaymentSettleRequest) GetStateOnlyPeerFromSig

func (m *PaymentSettleRequest) GetStateOnlyPeerFromSig() *SignedSimplexState

func (*PaymentSettleRequest) ProtoMessage

func (*PaymentSettleRequest) ProtoMessage()

func (*PaymentSettleRequest) Reset

func (m *PaymentSettleRequest) Reset()

func (*PaymentSettleRequest) String

func (m *PaymentSettleRequest) String() string

func (*PaymentSettleRequest) XXX_DiscardUnknown

func (m *PaymentSettleRequest) XXX_DiscardUnknown()

func (*PaymentSettleRequest) XXX_Marshal

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

func (*PaymentSettleRequest) XXX_Merge

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

func (*PaymentSettleRequest) XXX_Size

func (m *PaymentSettleRequest) XXX_Size() int

func (*PaymentSettleRequest) XXX_Unmarshal

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

type PaymentSettleResponse

type PaymentSettleResponse struct {
	StateCosigned        *SignedSimplexState `protobuf:"bytes,1,opt,name=state_cosigned,json=stateCosigned,proto3" json:"state_cosigned,omitempty"`
	Error                *Error              `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

peer_to of a simplex channel confirms the settlement by providing its sig Next Tag: 4

func (*PaymentSettleResponse) Descriptor

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

func (*PaymentSettleResponse) GetError

func (m *PaymentSettleResponse) GetError() *Error

func (*PaymentSettleResponse) GetStateCosigned

func (m *PaymentSettleResponse) GetStateCosigned() *SignedSimplexState

func (*PaymentSettleResponse) ProtoMessage

func (*PaymentSettleResponse) ProtoMessage()

func (*PaymentSettleResponse) Reset

func (m *PaymentSettleResponse) Reset()

func (*PaymentSettleResponse) String

func (m *PaymentSettleResponse) String() string

func (*PaymentSettleResponse) XXX_DiscardUnknown

func (m *PaymentSettleResponse) XXX_DiscardUnknown()

func (*PaymentSettleResponse) XXX_Marshal

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

func (*PaymentSettleResponse) XXX_Merge

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

func (*PaymentSettleResponse) XXX_Size

func (m *PaymentSettleResponse) XXX_Size() int

func (*PaymentSettleResponse) XXX_Unmarshal

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

type PeerAddress

type PeerAddress struct {
	Address              string   `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	TokenAddr            string   `protobuf:"bytes,2,opt,name=token_addr,json=tokenAddr,proto3" json:"token_addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerAddress) Descriptor

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

func (*PeerAddress) GetAddress

func (m *PeerAddress) GetAddress() string

func (*PeerAddress) GetTokenAddr

func (m *PeerAddress) GetTokenAddr() string

func (*PeerAddress) ProtoMessage

func (*PeerAddress) ProtoMessage()

func (*PeerAddress) Reset

func (m *PeerAddress) Reset()

func (*PeerAddress) String

func (m *PeerAddress) String() string

func (*PeerAddress) XXX_DiscardUnknown

func (m *PeerAddress) XXX_DiscardUnknown()

func (*PeerAddress) XXX_Marshal

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

func (*PeerAddress) XXX_Merge

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

func (*PeerAddress) XXX_Size

func (m *PeerAddress) XXX_Size() int

func (*PeerAddress) XXX_Unmarshal

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

type PeerOsp

type PeerOsp struct {
	// eth addr of peer osp
	OspAddress string `protobuf:"bytes,1,opt,name=osp_address,json=ospAddress,proto3" json:"osp_address,omitempty"`
	// channels with the peer osp
	TokenCidPairs []*TokenCidPair `protobuf:"bytes,2,rep,name=token_cid_pairs,json=tokenCidPairs,proto3" json:"token_cid_pairs,omitempty"`
	// last update timestamp
	UpdateTs             uint64   `protobuf:"varint,3,opt,name=update_ts,json=updateTs,proto3" json:"update_ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerOsp) Descriptor

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

func (*PeerOsp) GetOspAddress

func (m *PeerOsp) GetOspAddress() string

func (*PeerOsp) GetTokenCidPairs

func (m *PeerOsp) GetTokenCidPairs() []*TokenCidPair

func (*PeerOsp) GetUpdateTs

func (m *PeerOsp) GetUpdateTs() uint64

func (*PeerOsp) ProtoMessage

func (*PeerOsp) ProtoMessage()

func (*PeerOsp) Reset

func (m *PeerOsp) Reset()

func (*PeerOsp) String

func (m *PeerOsp) String() string

func (*PeerOsp) XXX_DiscardUnknown

func (m *PeerOsp) XXX_DiscardUnknown()

func (*PeerOsp) XXX_Marshal

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

func (*PeerOsp) XXX_Merge

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

func (*PeerOsp) XXX_Size

func (m *PeerOsp) XXX_Size() int

func (*PeerOsp) XXX_Unmarshal

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

type PeerOspsResponse

type PeerOspsResponse struct {
	// info of peer osps.
	PeerOsps             []*PeerOsp `protobuf:"bytes,1,rep,name=peer_osps,json=peerOsps,proto3" json:"peer_osps,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

Admin request to list all peer osps. Next tag: 2

func (*PeerOspsResponse) Descriptor

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

func (*PeerOspsResponse) GetPeerOsps

func (m *PeerOspsResponse) GetPeerOsps() []*PeerOsp

func (*PeerOspsResponse) ProtoMessage

func (*PeerOspsResponse) ProtoMessage()

func (*PeerOspsResponse) Reset

func (m *PeerOspsResponse) Reset()

func (*PeerOspsResponse) String

func (m *PeerOspsResponse) String() string

func (*PeerOspsResponse) XXX_DiscardUnknown

func (m *PeerOspsResponse) XXX_DiscardUnknown()

func (*PeerOspsResponse) XXX_Marshal

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

func (*PeerOspsResponse) XXX_Merge

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

func (*PeerOspsResponse) XXX_Size

func (m *PeerOspsResponse) XXX_Size() int

func (*PeerOspsResponse) XXX_Unmarshal

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

type PeerStatus

type PeerStatus struct {
	FreeBalance          string          `protobuf:"bytes,1,opt,name=free_balance,json=freeBalance,proto3" json:"free_balance,omitempty"`
	JoinStatus           JoinCelerStatus `protobuf:"varint,2,opt,name=join_status,json=joinStatus,proto3,enum=rpc.JoinCelerStatus" json:"join_status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Next Tag: 3

func (*PeerStatus) Descriptor

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

func (*PeerStatus) GetFreeBalance

func (m *PeerStatus) GetFreeBalance() string

func (*PeerStatus) GetJoinStatus

func (m *PeerStatus) GetJoinStatus() JoinCelerStatus

func (*PeerStatus) ProtoMessage

func (*PeerStatus) ProtoMessage()

func (*PeerStatus) Reset

func (m *PeerStatus) Reset()

func (*PeerStatus) String

func (m *PeerStatus) String() string

func (*PeerStatus) XXX_DiscardUnknown

func (m *PeerStatus) XXX_DiscardUnknown()

func (*PeerStatus) XXX_Marshal

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

func (*PeerStatus) XXX_Merge

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

func (*PeerStatus) XXX_Size

func (m *PeerStatus) XXX_Size() int

func (*PeerStatus) XXX_Unmarshal

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

type PickReply

type PickReply struct {
	Server               string   `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next tag: 2

func (*PickReply) Descriptor

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

func (*PickReply) GetServer

func (m *PickReply) GetServer() string

func (*PickReply) ProtoMessage

func (*PickReply) ProtoMessage()

func (*PickReply) Reset

func (m *PickReply) Reset()

func (*PickReply) String

func (m *PickReply) String() string

func (*PickReply) XXX_DiscardUnknown

func (m *PickReply) XXX_DiscardUnknown()

func (*PickReply) XXX_Marshal

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

func (*PickReply) XXX_Merge

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

func (*PickReply) XXX_Size

func (m *PickReply) XXX_Size() int

func (*PickReply) XXX_Unmarshal

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

type PickReq

type PickReq struct {
	Client               string   `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next tag: 2

func (*PickReq) Descriptor

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

func (*PickReq) GetClient

func (m *PickReq) GetClient() string

func (*PickReq) ProtoMessage

func (*PickReq) ProtoMessage()

func (*PickReq) Reset

func (m *PickReq) Reset()

func (*PickReq) String

func (m *PickReq) String() string

func (*PickReq) XXX_DiscardUnknown

func (m *PickReq) XXX_DiscardUnknown()

func (*PickReq) XXX_Marshal

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

func (*PickReq) XXX_Merge

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

func (*PickReq) XXX_Size

func (m *PickReq) XXX_Size() int

func (*PickReq) XXX_Unmarshal

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

type PingReply

type PingReply struct {
	Numclients           uint32   `protobuf:"varint,1,opt,name=numclients,proto3" json:"numclients,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next tag: 2

func (*PingReply) Descriptor

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

func (*PingReply) GetNumclients

func (m *PingReply) GetNumclients() uint32

func (*PingReply) ProtoMessage

func (*PingReply) ProtoMessage()

func (*PingReply) Reset

func (m *PingReply) Reset()

func (*PingReply) String

func (m *PingReply) String() string

func (*PingReply) XXX_DiscardUnknown

func (m *PingReply) XXX_DiscardUnknown()

func (*PingReply) XXX_Marshal

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

func (*PingReply) XXX_Merge

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

func (*PingReply) XXX_Size

func (m *PingReply) XXX_Size() int

func (*PingReply) XXX_Unmarshal

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

type PingReq

type PingReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next tag: 1

func (*PingReq) Descriptor

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

func (*PingReq) ProtoMessage

func (*PingReq) ProtoMessage()

func (*PingReq) Reset

func (m *PingReq) Reset()

func (*PingReq) String

func (m *PingReq) String() string

func (*PingReq) XXX_DiscardUnknown

func (m *PingReq) XXX_DiscardUnknown()

func (*PingReq) XXX_Marshal

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

func (*PingReq) XXX_Merge

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

func (*PingReq) XXX_Size

func (m *PingReq) XXX_Size() int

func (*PingReq) XXX_Unmarshal

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

type QueryDelegationRequest

type QueryDelegationRequest struct {
	// delegatee to query delegation.
	Delegatee            []byte   `protobuf:"bytes,1,opt,name=delegatee,proto3" json:"delegatee,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next tag: 2

func (*QueryDelegationRequest) Descriptor

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

func (*QueryDelegationRequest) GetDelegatee

func (m *QueryDelegationRequest) GetDelegatee() []byte

func (*QueryDelegationRequest) ProtoMessage

func (*QueryDelegationRequest) ProtoMessage()

func (*QueryDelegationRequest) Reset

func (m *QueryDelegationRequest) Reset()

func (*QueryDelegationRequest) String

func (m *QueryDelegationRequest) String() string

func (*QueryDelegationRequest) XXX_DiscardUnknown

func (m *QueryDelegationRequest) XXX_DiscardUnknown()

func (*QueryDelegationRequest) XXX_Marshal

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

func (*QueryDelegationRequest) XXX_Merge

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

func (*QueryDelegationRequest) XXX_Size

func (m *QueryDelegationRequest) XXX_Size() int

func (*QueryDelegationRequest) XXX_Unmarshal

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

type QueryDelegationResponse

type QueryDelegationResponse struct {
	// DelegationProof stored by celer node.
	Proof                *DelegationProof `protobuf:"bytes,1,opt,name=proof,proto3" json:"proof,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Next tag: 2

func (*QueryDelegationResponse) Descriptor

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

func (*QueryDelegationResponse) GetProof

func (*QueryDelegationResponse) ProtoMessage

func (*QueryDelegationResponse) ProtoMessage()

func (*QueryDelegationResponse) Reset

func (m *QueryDelegationResponse) Reset()

func (*QueryDelegationResponse) String

func (m *QueryDelegationResponse) String() string

func (*QueryDelegationResponse) XXX_DiscardUnknown

func (m *QueryDelegationResponse) XXX_DiscardUnknown()

func (*QueryDelegationResponse) XXX_Marshal

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

func (*QueryDelegationResponse) XXX_Merge

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

func (*QueryDelegationResponse) XXX_Size

func (m *QueryDelegationResponse) XXX_Size() int

func (*QueryDelegationResponse) XXX_Unmarshal

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

type QueryDepositRequest

type QueryDepositRequest struct {
	DepositId            string   `protobuf:"bytes,1,opt,name=deposit_id,json=depositId,proto3" json:"deposit_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next Tag: 2

func (*QueryDepositRequest) Descriptor

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

func (*QueryDepositRequest) GetDepositId

func (m *QueryDepositRequest) GetDepositId() string

func (*QueryDepositRequest) ProtoMessage

func (*QueryDepositRequest) ProtoMessage()

func (*QueryDepositRequest) Reset

func (m *QueryDepositRequest) Reset()

func (*QueryDepositRequest) String

func (m *QueryDepositRequest) String() string

func (*QueryDepositRequest) XXX_DiscardUnknown

func (m *QueryDepositRequest) XXX_DiscardUnknown()

func (*QueryDepositRequest) XXX_Marshal

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

func (*QueryDepositRequest) XXX_Merge

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

func (*QueryDepositRequest) XXX_Size

func (m *QueryDepositRequest) XXX_Size() int

func (*QueryDepositRequest) XXX_Unmarshal

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

type QueryDepositResponse

type QueryDepositResponse struct {
	DepositState         DepositState `protobuf:"varint,1,opt,name=deposit_state,json=depositState,proto3,enum=rpc.DepositState" json:"deposit_state,omitempty"`
	Error                string       `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Next Tag: 3

func (*QueryDepositResponse) Descriptor

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

func (*QueryDepositResponse) GetDepositState

func (m *QueryDepositResponse) GetDepositState() DepositState

func (*QueryDepositResponse) GetError

func (m *QueryDepositResponse) GetError() string

func (*QueryDepositResponse) ProtoMessage

func (*QueryDepositResponse) ProtoMessage()

func (*QueryDepositResponse) Reset

func (m *QueryDepositResponse) Reset()

func (*QueryDepositResponse) String

func (m *QueryDepositResponse) String() string

func (*QueryDepositResponse) XXX_DiscardUnknown

func (m *QueryDepositResponse) XXX_DiscardUnknown()

func (*QueryDepositResponse) XXX_Marshal

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

func (*QueryDepositResponse) XXX_Merge

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

func (*QueryDepositResponse) XXX_Size

func (m *QueryDepositResponse) XXX_Size() int

func (*QueryDepositResponse) XXX_Unmarshal

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

type RegisterClientCallbackFunc

type RegisterClientCallbackFunc func(clientAddr ctype.Addr)

type RegisterStreamRequest

type RegisterStreamRequest struct {
	PeerRpcAddress       string   `protobuf:"bytes,1,opt,name=peer_rpc_address,json=peerRpcAddress,proto3" json:"peer_rpc_address,omitempty"`
	PeerEthAddress       []byte   `protobuf:"bytes,2,opt,name=peer_eth_address,json=peerEthAddress,proto3" json:"peer_eth_address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next Tag: 3

func (*RegisterStreamRequest) Descriptor

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

func (*RegisterStreamRequest) GetPeerEthAddress

func (m *RegisterStreamRequest) GetPeerEthAddress() []byte

func (*RegisterStreamRequest) GetPeerRpcAddress

func (m *RegisterStreamRequest) GetPeerRpcAddress() string

func (*RegisterStreamRequest) ProtoMessage

func (*RegisterStreamRequest) ProtoMessage()

func (*RegisterStreamRequest) Reset

func (m *RegisterStreamRequest) Reset()

func (*RegisterStreamRequest) String

func (m *RegisterStreamRequest) String() string

func (*RegisterStreamRequest) XXX_DiscardUnknown

func (m *RegisterStreamRequest) XXX_DiscardUnknown()

func (*RegisterStreamRequest) XXX_Marshal

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

func (*RegisterStreamRequest) XXX_Merge

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

func (*RegisterStreamRequest) XXX_Size

func (m *RegisterStreamRequest) XXX_Size() int

func (*RegisterStreamRequest) XXX_Unmarshal

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

type RevealSecret

type RevealSecret struct {
	PayId []byte `protobuf:"bytes,1,opt,name=pay_id,json=payId,proto3" json:"pay_id,omitempty"`
	// preimage of the hash
	Secret []byte `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty"`
	// used for cross net pay
	OriginalPayId        []byte   `protobuf:"bytes,3,opt,name=original_pay_id,json=originalPayId,proto3" json:"original_pay_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RevealSecret) Descriptor

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

func (*RevealSecret) GetOriginalPayId

func (m *RevealSecret) GetOriginalPayId() []byte

func (*RevealSecret) GetPayId

func (m *RevealSecret) GetPayId() []byte

func (*RevealSecret) GetSecret

func (m *RevealSecret) GetSecret() []byte

func (*RevealSecret) ProtoMessage

func (*RevealSecret) ProtoMessage()

func (*RevealSecret) Reset

func (m *RevealSecret) Reset()

func (*RevealSecret) String

func (m *RevealSecret) String() string

func (*RevealSecret) XXX_DiscardUnknown

func (m *RevealSecret) XXX_DiscardUnknown()

func (*RevealSecret) XXX_Marshal

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

func (*RevealSecret) XXX_Merge

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

func (*RevealSecret) XXX_Size

func (m *RevealSecret) XXX_Size() int

func (*RevealSecret) XXX_Unmarshal

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

type RevealSecretAck

type RevealSecretAck struct {
	// include pay_id for avoid preimage->pay reverse lookup
	PayId []byte `protobuf:"bytes,1,opt,name=pay_id,json=payId,proto3" json:"pay_id,omitempty"`
	// pay dest sign secret to avoid spoof
	PayDestSecretSig []byte `protobuf:"bytes,2,opt,name=pay_dest_secret_sig,json=payDestSecretSig,proto3" json:"pay_dest_secret_sig,omitempty"`
	// used for cross net pay
	OriginalPayId        []byte   `protobuf:"bytes,3,opt,name=original_pay_id,json=originalPayId,proto3" json:"original_pay_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RevealSecretAck) Descriptor

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

func (*RevealSecretAck) GetOriginalPayId

func (m *RevealSecretAck) GetOriginalPayId() []byte

func (*RevealSecretAck) GetPayDestSecretSig

func (m *RevealSecretAck) GetPayDestSecretSig() []byte

func (*RevealSecretAck) GetPayId

func (m *RevealSecretAck) GetPayId() []byte

func (*RevealSecretAck) ProtoMessage

func (*RevealSecretAck) ProtoMessage()

func (*RevealSecretAck) Reset

func (m *RevealSecretAck) Reset()

func (*RevealSecretAck) String

func (m *RevealSecretAck) String() string

func (*RevealSecretAck) XXX_DiscardUnknown

func (m *RevealSecretAck) XXX_DiscardUnknown()

func (*RevealSecretAck) XXX_Marshal

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

func (*RevealSecretAck) XXX_Merge

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

func (*RevealSecretAck) XXX_Size

func (m *RevealSecretAck) XXX_Size() int

func (*RevealSecretAck) XXX_Unmarshal

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

type RoutingRequest

type RoutingRequest struct {
	// list of routing updates
	Updates []*SignedRoutingUpdate `protobuf:"bytes,1,rep,name=updates,proto3" json:"updates,omitempty"`
	// OSP that sent (propagated) this information.
	Sender               string   `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next tag: 3

func (*RoutingRequest) Descriptor

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

func (*RoutingRequest) GetSender

func (m *RoutingRequest) GetSender() string

func (*RoutingRequest) GetUpdates

func (m *RoutingRequest) GetUpdates() []*SignedRoutingUpdate

func (*RoutingRequest) ProtoMessage

func (*RoutingRequest) ProtoMessage()

func (*RoutingRequest) Reset

func (m *RoutingRequest) Reset()

func (*RoutingRequest) String

func (m *RoutingRequest) String() string

func (*RoutingRequest) XXX_DiscardUnknown

func (m *RoutingRequest) XXX_DiscardUnknown()

func (*RoutingRequest) XXX_Marshal

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

func (*RoutingRequest) XXX_Merge

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

func (*RoutingRequest) XXX_Size

func (m *RoutingRequest) XXX_Size() int

func (*RoutingRequest) XXX_Unmarshal

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

type RoutingUpdate

type RoutingUpdate struct {
	// origin source OSP for this information.
	Origin string `protobuf:"bytes,1,opt,name=origin,proto3" json:"origin,omitempty"`
	// timestamp of this information at the origin.
	Ts uint64 `protobuf:"varint,2,opt,name=ts,proto3" json:"ts,omitempty"`
	// channel information
	Channels []*ChannelRoutingInfo `protobuf:"bytes,3,rep,name=channels,proto3" json:"channels,omitempty"`
	// routing protocol version number
	ProtoVersion         uint64   `protobuf:"varint,4,opt,name=proto_version,json=protoVersion,proto3" json:"proto_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next tag: 5

func (*RoutingUpdate) Descriptor

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

func (*RoutingUpdate) GetChannels

func (m *RoutingUpdate) GetChannels() []*ChannelRoutingInfo

func (*RoutingUpdate) GetOrigin

func (m *RoutingUpdate) GetOrigin() string

func (*RoutingUpdate) GetProtoVersion

func (m *RoutingUpdate) GetProtoVersion() uint64

func (*RoutingUpdate) GetTs

func (m *RoutingUpdate) GetTs() uint64

func (*RoutingUpdate) ProtoMessage

func (*RoutingUpdate) ProtoMessage()

func (*RoutingUpdate) Reset

func (m *RoutingUpdate) Reset()

func (*RoutingUpdate) String

func (m *RoutingUpdate) String() string

func (*RoutingUpdate) XXX_DiscardUnknown

func (m *RoutingUpdate) XXX_DiscardUnknown()

func (*RoutingUpdate) XXX_Marshal

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

func (*RoutingUpdate) XXX_Merge

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

func (*RoutingUpdate) XXX_Size

func (m *RoutingUpdate) XXX_Size() int

func (*RoutingUpdate) XXX_Unmarshal

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

type RpcClient

type RpcClient interface {
	GetPayHistory(ctx context.Context, in *GetPayHistoryRequest, opts ...grpc.CallOption) (*GetPayHistoryResponse, error)
	QueryDelegation(ctx context.Context, in *QueryDelegationRequest, opts ...grpc.CallOption) (*QueryDelegationResponse, error)
	RequestDelegation(ctx context.Context, in *DelegationRequest, opts ...grpc.CallOption) (*DelegationResponse, error)
	CelerOpenChannel(ctx context.Context, in *OpenChannelRequest, opts ...grpc.CallOption) (*OpenChannelResponse, error)
	CelerOpenTcbChannel(ctx context.Context, in *OpenChannelRequest, opts ...grpc.CallOption) (*OpenChannelResponse, error)
	CelerGetPeerStatus(ctx context.Context, in *PeerAddress, opts ...grpc.CallOption) (*PeerStatus, error)
	// unified offchain bidi streaming rpc and msg definition
	CelerStream(ctx context.Context, opts ...grpc.CallOption) (Rpc_CelerStreamClient, error)
	CelerMigrateChannel(ctx context.Context, in *MigrateChannelRequest, opts ...grpc.CallOption) (*MigrateChannelResponse, error)
}

RpcClient is the client API for Rpc service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRpcClient

func NewRpcClient(cc *grpc.ClientConn) RpcClient

type RpcServer

type RpcServer interface {
	GetPayHistory(context.Context, *GetPayHistoryRequest) (*GetPayHistoryResponse, error)
	QueryDelegation(context.Context, *QueryDelegationRequest) (*QueryDelegationResponse, error)
	RequestDelegation(context.Context, *DelegationRequest) (*DelegationResponse, error)
	CelerOpenChannel(context.Context, *OpenChannelRequest) (*OpenChannelResponse, error)
	CelerOpenTcbChannel(context.Context, *OpenChannelRequest) (*OpenChannelResponse, error)
	CelerGetPeerStatus(context.Context, *PeerAddress) (*PeerStatus, error)
	// unified offchain bidi streaming rpc and msg definition
	CelerStream(Rpc_CelerStreamServer) error
	CelerMigrateChannel(context.Context, *MigrateChannelRequest) (*MigrateChannelResponse, error)
}

RpcServer is the server API for Rpc service.

type Rpc_CelerOneServer

type Rpc_CelerOneServer interface {
	Send(*CelerMsg) error
	Recv() (*CelerMsg, error)
}

type Rpc_CelerStreamClient

type Rpc_CelerStreamClient interface {
	Send(*CelerMsg) error
	Recv() (*CelerMsg, error)
	grpc.ClientStream
}

type Rpc_CelerStreamServer

type Rpc_CelerStreamServer interface {
	Send(*CelerMsg) error
	Recv() (*CelerMsg, error)
	grpc.ServerStream
}

type SafeSendCelerStream

type SafeSendCelerStream struct {
	// contains filtered or unexported fields
}

func (*SafeSendCelerStream) SafeSend

func (s *SafeSendCelerStream) SafeSend(msg *CelerMsg) error

type SendTokenRequest

type SendTokenRequest struct {
	DstAddr              string   `protobuf:"bytes,1,opt,name=dst_addr,json=dstAddr,proto3" json:"dst_addr,omitempty"`
	AmtWei               string   `protobuf:"bytes,2,opt,name=amt_wei,json=amtWei,proto3" json:"amt_wei,omitempty"`
	TokenAddr            string   `protobuf:"bytes,3,opt,name=token_addr,json=tokenAddr,proto3" json:"token_addr,omitempty"`
	Note                 *any.Any `protobuf:"bytes,4,opt,name=note,proto3" json:"note,omitempty"`
	DstNetId             uint64   `protobuf:"varint,5,opt,name=dst_net_id,json=dstNetId,proto3" json:"dst_net_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next Tag: 5

func (*SendTokenRequest) Descriptor

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

func (*SendTokenRequest) GetAmtWei

func (m *SendTokenRequest) GetAmtWei() string

func (*SendTokenRequest) GetDstAddr

func (m *SendTokenRequest) GetDstAddr() string

func (*SendTokenRequest) GetDstNetId

func (m *SendTokenRequest) GetDstNetId() uint64

func (*SendTokenRequest) GetNote

func (m *SendTokenRequest) GetNote() *any.Any

func (*SendTokenRequest) GetTokenAddr

func (m *SendTokenRequest) GetTokenAddr() string

func (*SendTokenRequest) ProtoMessage

func (*SendTokenRequest) ProtoMessage()

func (*SendTokenRequest) Reset

func (m *SendTokenRequest) Reset()

func (*SendTokenRequest) String

func (m *SendTokenRequest) String() string

func (*SendTokenRequest) XXX_DiscardUnknown

func (m *SendTokenRequest) XXX_DiscardUnknown()

func (*SendTokenRequest) XXX_Marshal

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

func (*SendTokenRequest) XXX_Merge

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

func (*SendTokenRequest) XXX_Size

func (m *SendTokenRequest) XXX_Size() int

func (*SendTokenRequest) XXX_Unmarshal

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

type SendTokenResponse

type SendTokenResponse struct {
	Status               int32    `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Error                string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	PayId                string   `protobuf:"bytes,3,opt,name=pay_id,json=payId,proto3" json:"pay_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next Tag: 4

func (*SendTokenResponse) Descriptor

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

func (*SendTokenResponse) GetError

func (m *SendTokenResponse) GetError() string

func (*SendTokenResponse) GetPayId

func (m *SendTokenResponse) GetPayId() string

func (*SendTokenResponse) GetStatus

func (m *SendTokenResponse) GetStatus() int32

func (*SendTokenResponse) ProtoMessage

func (*SendTokenResponse) ProtoMessage()

func (*SendTokenResponse) Reset

func (m *SendTokenResponse) Reset()

func (*SendTokenResponse) String

func (m *SendTokenResponse) String() string

func (*SendTokenResponse) XXX_DiscardUnknown

func (m *SendTokenResponse) XXX_DiscardUnknown()

func (*SendTokenResponse) XXX_Marshal

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

func (*SendTokenResponse) XXX_Merge

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

func (*SendTokenResponse) XXX_Size

func (m *SendTokenResponse) XXX_Size() int

func (*SendTokenResponse) XXX_Unmarshal

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

type SettledPayment

type SettledPayment struct {
	SettledPayId []byte              `protobuf:"bytes,1,opt,name=settled_pay_id,json=settledPayId,proto3" json:"settled_pay_id,omitempty"`
	Reason       PaymentSettleReason `protobuf:"varint,2,opt,name=reason,proto3,enum=rpc.PaymentSettleReason" json:"reason,omitempty"`
	Amount       []byte              `protobuf:"bytes,3,opt,name=amount,proto3" json:"amount,omitempty"`
	// used in pay settle proof to track path for failed payments
	Path *PayPath `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"`
	// used for cross net pay
	OriginalPayId        []byte   `protobuf:"bytes,5,opt,name=original_pay_id,json=originalPayId,proto3" json:"original_pay_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next Tag: 5

func (*SettledPayment) Descriptor

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

func (*SettledPayment) GetAmount

func (m *SettledPayment) GetAmount() []byte

func (*SettledPayment) GetOriginalPayId

func (m *SettledPayment) GetOriginalPayId() []byte

func (*SettledPayment) GetPath

func (m *SettledPayment) GetPath() *PayPath

func (*SettledPayment) GetReason

func (m *SettledPayment) GetReason() PaymentSettleReason

func (*SettledPayment) GetSettledPayId

func (m *SettledPayment) GetSettledPayId() []byte

func (*SettledPayment) ProtoMessage

func (*SettledPayment) ProtoMessage()

func (*SettledPayment) Reset

func (m *SettledPayment) Reset()

func (*SettledPayment) String

func (m *SettledPayment) String() string

func (*SettledPayment) XXX_DiscardUnknown

func (m *SettledPayment) XXX_DiscardUnknown()

func (*SettledPayment) XXX_Marshal

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

func (*SettledPayment) XXX_Merge

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

func (*SettledPayment) XXX_Size

func (m *SettledPayment) XXX_Size() int

func (*SettledPayment) XXX_Unmarshal

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

type SignedDuplexState

type SignedDuplexState struct {
	// only expect two messages for duplex
	SimplexStates        []*SignedSimplexState `protobuf:"bytes,1,rep,name=simplex_states,json=simplexStates,proto3" json:"simplex_states,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

Next Tag: 2

func (*SignedDuplexState) Descriptor

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

func (*SignedDuplexState) GetSimplexStates

func (m *SignedDuplexState) GetSimplexStates() []*SignedSimplexState

func (*SignedDuplexState) ProtoMessage

func (*SignedDuplexState) ProtoMessage()

func (*SignedDuplexState) Reset

func (m *SignedDuplexState) Reset()

func (*SignedDuplexState) String

func (m *SignedDuplexState) String() string

func (*SignedDuplexState) XXX_DiscardUnknown

func (m *SignedDuplexState) XXX_DiscardUnknown()

func (*SignedDuplexState) XXX_Marshal

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

func (*SignedDuplexState) XXX_Merge

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

func (*SignedDuplexState) XXX_Size

func (m *SignedDuplexState) XXX_Size() int

func (*SignedDuplexState) XXX_Unmarshal

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

type SignedPayHop

type SignedPayHop struct {
	PayHopBytes          []byte   `protobuf:"bytes,1,opt,name=pay_hop_bytes,json=payHopBytes,proto3" json:"pay_hop_bytes,omitempty"`
	Sig                  []byte   `protobuf:"bytes,2,opt,name=sig,proto3" json:"sig,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next Tag: 3

func (*SignedPayHop) Descriptor

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

func (*SignedPayHop) GetPayHopBytes

func (m *SignedPayHop) GetPayHopBytes() []byte

func (*SignedPayHop) GetSig

func (m *SignedPayHop) GetSig() []byte

func (*SignedPayHop) ProtoMessage

func (*SignedPayHop) ProtoMessage()

func (*SignedPayHop) Reset

func (m *SignedPayHop) Reset()

func (*SignedPayHop) String

func (m *SignedPayHop) String() string

func (*SignedPayHop) XXX_DiscardUnknown

func (m *SignedPayHop) XXX_DiscardUnknown()

func (*SignedPayHop) XXX_Marshal

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

func (*SignedPayHop) XXX_Merge

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

func (*SignedPayHop) XXX_Size

func (m *SignedPayHop) XXX_Size() int

func (*SignedPayHop) XXX_Unmarshal

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

type SignedRoutingUpdate

type SignedRoutingUpdate struct {
	// serialized RoutingUpdate
	Update []byte `protobuf:"bytes,1,opt,name=update,proto3" json:"update,omitempty"`
	// sig of serialized RoutingUpdate by origin
	Sig []byte `protobuf:"bytes,2,opt,name=sig,proto3" json:"sig,omitempty"`
	// time to live: decreasing hop count to stop the broadcast.
	Ttl                  uint64   `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next tag: 4

func (*SignedRoutingUpdate) Descriptor

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

func (*SignedRoutingUpdate) GetSig

func (m *SignedRoutingUpdate) GetSig() []byte

func (*SignedRoutingUpdate) GetTtl

func (m *SignedRoutingUpdate) GetTtl() uint64

func (*SignedRoutingUpdate) GetUpdate

func (m *SignedRoutingUpdate) GetUpdate() []byte

func (*SignedRoutingUpdate) ProtoMessage

func (*SignedRoutingUpdate) ProtoMessage()

func (*SignedRoutingUpdate) Reset

func (m *SignedRoutingUpdate) Reset()

func (*SignedRoutingUpdate) String

func (m *SignedRoutingUpdate) String() string

func (*SignedRoutingUpdate) XXX_DiscardUnknown

func (m *SignedRoutingUpdate) XXX_DiscardUnknown()

func (*SignedRoutingUpdate) XXX_Marshal

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

func (*SignedRoutingUpdate) XXX_Merge

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

func (*SignedRoutingUpdate) XXX_Size

func (m *SignedRoutingUpdate) XXX_Size() int

func (*SignedRoutingUpdate) XXX_Unmarshal

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

type SignedSimplexState

type SignedSimplexState struct {
	// serialized simplexPaymentChannel message
	SimplexState         []byte   `protobuf:"bytes,1,opt,name=simplex_state,json=simplexState,proto3" json:"simplex_state,omitempty"`
	SigOfPeerFrom        []byte   `protobuf:"bytes,2,opt,name=sig_of_peer_from,json=sigOfPeerFrom,proto3" json:"sig_of_peer_from,omitempty"`
	SigOfPeerTo          []byte   `protobuf:"bytes,3,opt,name=sig_of_peer_to,json=sigOfPeerTo,proto3" json:"sig_of_peer_to,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next Tag: 4

func (*SignedSimplexState) Descriptor

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

func (*SignedSimplexState) GetSigOfPeerFrom

func (m *SignedSimplexState) GetSigOfPeerFrom() []byte

func (*SignedSimplexState) GetSigOfPeerTo

func (m *SignedSimplexState) GetSigOfPeerTo() []byte

func (*SignedSimplexState) GetSimplexState

func (m *SignedSimplexState) GetSimplexState() []byte

func (*SignedSimplexState) ProtoMessage

func (*SignedSimplexState) ProtoMessage()

func (*SignedSimplexState) Reset

func (m *SignedSimplexState) Reset()

func (*SignedSimplexState) String

func (m *SignedSimplexState) String() string

func (*SignedSimplexState) XXX_DiscardUnknown

func (m *SignedSimplexState) XXX_DiscardUnknown()

func (*SignedSimplexState) XXX_Marshal

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

func (*SignedSimplexState) XXX_Merge

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

func (*SignedSimplexState) XXX_Size

func (m *SignedSimplexState) XXX_Size() int

func (*SignedSimplexState) XXX_Unmarshal

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

type TokenCidPair

type TokenCidPair struct {
	TokenAddress         string   `protobuf:"bytes,1,opt,name=token_address,json=tokenAddress,proto3" json:"token_address,omitempty"`
	Cid                  string   `protobuf:"bytes,2,opt,name=cid,proto3" json:"cid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TokenCidPair) Descriptor

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

func (*TokenCidPair) GetCid

func (m *TokenCidPair) GetCid() string

func (*TokenCidPair) GetTokenAddress

func (m *TokenCidPair) GetTokenAddress() string

func (*TokenCidPair) ProtoMessage

func (*TokenCidPair) ProtoMessage()

func (*TokenCidPair) Reset

func (m *TokenCidPair) Reset()

func (*TokenCidPair) String

func (m *TokenCidPair) String() string

func (*TokenCidPair) XXX_DiscardUnknown

func (m *TokenCidPair) XXX_DiscardUnknown()

func (*TokenCidPair) XXX_Marshal

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

func (*TokenCidPair) XXX_Merge

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

func (*TokenCidPair) XXX_Size

func (m *TokenCidPair) XXX_Size() int

func (*TokenCidPair) XXX_Unmarshal

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

type UnimplementedAdminServer

type UnimplementedAdminServer struct {
}

UnimplementedAdminServer can be embedded to have forward compatible implementations.

func (*UnimplementedAdminServer) BuildRoutingTable

func (*UnimplementedAdminServer) ClearExpiredPaysWithPeerOsps

func (*UnimplementedAdminServer) ClearExpiredPaysWithPeerOsps(ctx context.Context, req *ClearExpiredPaysRequest) (*empty.Empty, error)

func (*UnimplementedAdminServer) ConfirmOnChainResolvedPaysWithPeerOsps

func (*UnimplementedAdminServer) ConfirmOnChainResolvedPaysWithPeerOsps(ctx context.Context, req *ConfirmOnChainResolvedPaysRequest) (*empty.Empty, error)

func (*UnimplementedAdminServer) CooperativeSettle

func (*UnimplementedAdminServer) CooperativeWithdraw

func (*UnimplementedAdminServer) Deposit

func (*UnimplementedAdminServer) GetPeerOsps

func (*UnimplementedAdminServer) OspOpenChannel

func (*UnimplementedAdminServer) QueryDeposit

func (*UnimplementedAdminServer) RecvBcastRoutingInfo

func (*UnimplementedAdminServer) RecvBcastRoutingInfo(ctx context.Context, req *RoutingRequest) (*empty.Empty, error)

func (*UnimplementedAdminServer) RegisterStream

func (*UnimplementedAdminServer) SendToken

type UnimplementedMultiServerServer

type UnimplementedMultiServerServer struct {
}

UnimplementedMultiServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedMultiServerServer) BcastRoutingInfo

func (*UnimplementedMultiServerServer) FwdMsg

func (*UnimplementedMultiServerServer) PickServer

func (*UnimplementedMultiServerServer) Ping

type UnimplementedRpcServer

type UnimplementedRpcServer struct {
}

UnimplementedRpcServer can be embedded to have forward compatible implementations.

func (*UnimplementedRpcServer) CelerGetPeerStatus

func (*UnimplementedRpcServer) CelerGetPeerStatus(ctx context.Context, req *PeerAddress) (*PeerStatus, error)

func (*UnimplementedRpcServer) CelerMigrateChannel

func (*UnimplementedRpcServer) CelerOpenChannel

func (*UnimplementedRpcServer) CelerOpenTcbChannel

func (*UnimplementedRpcServer) CelerStream

func (*UnimplementedRpcServer) GetPayHistory

func (*UnimplementedRpcServer) QueryDelegation

func (*UnimplementedRpcServer) RequestDelegation

Jump to

Keyboard shortcuts

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