rpc

package
v0.0.0-...-ab58f20 Latest Latest
Warning

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

 Go to latest Published: Feb 13, 2020 License: GPL-3.0 Imports: 20 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 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",
}
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,
}
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: "PAY_VOUCHED",
	1: "PAY_EXPIRED",
	2: "PAY_REJECTED",
	3: "PAY_RESOLVED_ONCHAIN",
	4: "PAY_PAID_MAX",
	5: "PAY_DEST_UNREACHABLE",
}
View Source 
var PaymentSettleReason_value = map[string]int32{
	"PAY_VOUCHED":          0,
	"PAY_EXPIRED":          1,
	"PAY_REJECTED":         2,
	"PAY_RESOLVED_ONCHAIN": 3,
	"PAY_PAID_MAX":         4,
	"PAY_DEST_UNREACHABLE": 5,
}

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 ActivePeerOspsResponse 

type ActivePeerOspsResponse struct {
	// eth addr of peer osps.
	Osps                 []string `protobuf:"bytes,1,rep,name=osps,proto3" json:"osps,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*ActivePeerOspsResponse) Descriptor 

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

func (*ActivePeerOspsResponse) GetOsps 

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

func (*ActivePeerOspsResponse) ProtoMessage 

func (*ActivePeerOspsResponse) ProtoMessage()

func (*ActivePeerOspsResponse) Reset 

func (m *ActivePeerOspsResponse) Reset()

func (*ActivePeerOspsResponse) String 

func (m *ActivePeerOspsResponse) String() string

func (*ActivePeerOspsResponse) XXX_DiscardUnknown 

func (m *ActivePeerOspsResponse) XXX_DiscardUnknown()

func (*ActivePeerOspsResponse) XXX_Marshal 

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

func (*ActivePeerOspsResponse) XXX_Merge 

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

func (*ActivePeerOspsResponse) XXX_Size 

func (m *ActivePeerOspsResponse) XXX_Size() int

func (*ActivePeerOspsResponse) XXX_Unmarshal 

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

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)
	// GetActivePeerOsps returns eth addresses of active peer osps. Keep admin informed about who are connecting to the osp.
	GetActivePeerOsps(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ActivePeerOspsResponse, 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 instruscts the OSP to send token specified in SendTokenRequest.
	SendToken(ctx context.Context, in *SendTokenRequest, opts ...grpc.CallOption) (*SendTokenResponse, 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)
}

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)
	// GetActivePeerOsps returns eth addresses of active peer osps. Keep admin informed about who are connecting to the osp.
	GetActivePeerOsps(context.Context, *empty.Empty) (*ActivePeerOspsResponse, error)
	// OspOpenChannel instructs Osp to open a state channel with a peer described in request.
	OspOpenChannel(context.Context, *OspOpenChannelRequest) (*empty.Empty, error)
	// SendToken instruscts the OSP to send token specified in SendTokenRequest.
	SendToken(context.Context, *SendTokenRequest) (*SendTokenResponse, error)
	// RegisterStream instructs the OSP to connect with other osp specified in RegisterStreamRequest.
	RegisterStream(context.Context, *RegisterStreamRequest) (*empty.Empty, 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"`
	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) 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"`
	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) 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 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_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) 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_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 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"`
	PayDestSig           []byte   `protobuf:"bytes,2,opt,name=pay_dest_sig,json=payDestSig,proto3" json:"pay_dest_sig,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Next Tag: 3

func (*CondPayReceipt) Descriptor 

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

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"`
	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) 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 PSC.

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 (m *ConfirmOnChainResolvedPaysRequest) Reset()

func (*ConfirmOnChainResolvedPaysRequest) String 

func (m *ConfirmOnChainResolvedPaysRequest) String() 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 (m *ConfirmOnChainResolvedPaysRequest) XXX_Merge(src proto.Message)

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(onchainAddr string, stream CelerStream, msgProcessor chan *CelerMsg) context.Context

func (*ConnectionManager) AddConnection 

func (m *ConnectionManager) AddConnection(onchainAddr string, cc *grpc.ClientConn)

func (*ConnectionManager) AddErrorCallback 

func (m *ConnectionManager) AddErrorCallback(onchainAddr string, cb ErrCallbackFunc)

func (*ConnectionManager) CleanupStreams 

func (m *ConnectionManager) CleanupStreams(addr string)

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(onchainAddr string)

func (*ConnectionManager) GetCelerStream 

func (m *ConnectionManager) GetCelerStream(onchainAddr string) *SafeSendCelerStream

func (*ConnectionManager) GetClient 

func (m *ConnectionManager) GetClient(onchainAddr string) (RpcClient, error)

func (*ConnectionManager) GetClientByAddr 

func (m *ConnectionManager) GetClientByAddr(peerAddr ethcommon.Address) (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 (m *CooperativeWithdrawRequest) GetWithdrawInfo() *entity.CooperativeWithdrawInfo

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 (m *CooperativeWithdrawResponse) GetWithdrawInfo() *entity.CooperativeWithdrawInfo

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 ErrCallbackFunc 

type ErrCallbackFunc func(addr string, err error)

type ErrCode 

type ErrCode int32

Next Tag: 8 

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
)

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 of the errored message, needed for non-unary rpc
	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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FwdReply) Descriptor 

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

func (*FwdReply) GetAccepted 

func (m *FwdReply) GetAccepted() bool

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:"-"`
}

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 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 MsgQueueCallbackFunc 

type MsgQueueCallbackFunc func(peer string) 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)
}

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)
}

MultiServerServer is the server API for MultiServer service.

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 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: 6 

const (
	PaymentSettleReason_PAY_VOUCHED          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
)

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 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:"-"`
}

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:"-"`
}

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:"-"`
}

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:"-"`
}

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 RegisterClientCallbackFunc 

type RegisterClientCallbackFunc func(clientAddr string)

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RevealSecret) Descriptor 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RevealSecretAck) Descriptor 

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

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 RpcClient 

type RpcClient interface {
	CelerOpenChannel(ctx context.Context, in *OpenChannelRequest, opts ...grpc.CallOption) (*OpenChannelResponse, error)
	// unified offchain bidi streaming rpc and msg definition
	CelerStream(ctx context.Context, opts ...grpc.CallOption) (Rpc_CelerStreamClient, 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 {
	CelerOpenChannel(context.Context, *OpenChannelRequest) (*OpenChannelResponse, error)
	// unified offchain bidi streaming rpc and msg definition
	CelerStream(Rpc_CelerStreamServer) 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"`
	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) 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: 3

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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Next Tag: 3

func (*SettledPayment) Descriptor 

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

func (*SettledPayment) GetAmount 

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

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 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 UnimplementedAdminServer 

type UnimplementedAdminServer struct {
}

UnimplementedAdminServer can be embedded to have forward compatible implementations.

func (*UnimplementedAdminServer) BuildRoutingTable 

func (*UnimplementedAdminServer) BuildRoutingTable(ctx context.Context, req *BuildRoutingTableRequest) (*empty.Empty, error)

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) GetActivePeerOsps 

func (*UnimplementedAdminServer) GetActivePeerOsps(ctx context.Context, req *empty.Empty) (*ActivePeerOspsResponse, error)

func (*UnimplementedAdminServer) OspOpenChannel 

func (*UnimplementedAdminServer) OspOpenChannel(ctx context.Context, req *OspOpenChannelRequest) (*empty.Empty, error)

func (*UnimplementedAdminServer) RegisterStream 

func (*UnimplementedAdminServer) RegisterStream(ctx context.Context, req *RegisterStreamRequest) (*empty.Empty, error)

func (*UnimplementedAdminServer) SendToken 

func (*UnimplementedAdminServer) SendToken(ctx context.Context, req *SendTokenRequest) (*SendTokenResponse, error)

type UnimplementedMultiServerServer 

type UnimplementedMultiServerServer struct {
}

UnimplementedMultiServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedMultiServerServer) FwdMsg 

func (*UnimplementedMultiServerServer) FwdMsg(ctx context.Context, req *FwdReq) (*FwdReply, error)

func (*UnimplementedMultiServerServer) PickServer 

func (*UnimplementedMultiServerServer) PickServer(ctx context.Context, req *PickReq) (*PickReply, error)

func (*UnimplementedMultiServerServer) Ping 

func (*UnimplementedMultiServerServer) Ping(ctx context.Context, req *PingReq) (*PingReply, error)

type UnimplementedRpcServer 

type UnimplementedRpcServer struct {
}

UnimplementedRpcServer can be embedded to have forward compatible implementations.

func (*UnimplementedRpcServer) CelerOpenChannel 

func (*UnimplementedRpcServer) CelerOpenChannel(ctx context.Context, req *OpenChannelRequest) (*OpenChannelResponse, error)

func (*UnimplementedRpcServer) CelerStream 

func (*UnimplementedRpcServer) CelerStream(srv Rpc_CelerStreamServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.