plugins

May 11, 2022

Changes in this version

type Client

+ GetOffChainData func(request *pb.GetDataRequest) (*pb.GetDataResponse, error)

+ GetOffChainDataReq func() chan *pb.GetDataRequest

+ SubmitOffChainData func(response *pb.GetDataResponse) error

type GRPCClient

+ func (g *GRPCClient) GetOffChainData(request *pb.GetDataRequest) (*pb.GetDataResponse, error)

+ func (g *GRPCClient) GetOffChainDataReq() chan *pb.GetDataRequest

+ func (g *GRPCClient) SubmitOffChainData(response *pb.GetDataResponse) error

type GRPCServer

+ func (s *GRPCServer) GetOffChainData(ctx context.Context, req *pb.GetDataRequest) (*pb.GetDataResponse, error)

+ func (s *GRPCServer) GetOffChainDataReq(_ *pb.Empty, conn pb.AppchainPlugin_GetOffChainDataReqServer) error

+ func (s *GRPCServer) SubmitOffChainData(_ context.Context, res *pb.GetDataResponse) (*pb.Empty, error)

Apr 13, 2022

Changes in this version

type Client

+ GetDirectTransactionMeta func(string) (uint64, uint64, uint64, error)

type GRPCClient

+ func (g *GRPCClient) GetDirectTransactionMeta(id string) (uint64, uint64, uint64, error)

type GRPCServer

+ func (s *GRPCServer) GetDirectTransactionMeta(ctx context.Context, request *pb.DirectTransactionMetaRequest) (*pb.DirectTransactionMetaResponse, error)

Apr 2, 2022

Changes in this version

type Client

+ GetAppchainInfo func(chainID string) (string, []byte, string, error)

+ GetIBTPCh func() chan *pb.IBTP

+ GetUpdateMeta func() chan *pb.UpdateMeta

type GRPCClient

+ func (g *GRPCClient) GetAppchainInfo(chainID string) (string, []byte, string, error)

+ func (g *GRPCClient) GetIBTPCh() chan *pb.IBTP

+ func (g *GRPCClient) GetUpdateMeta() chan *pb.UpdateMeta

type GRPCServer

+ func (s *GRPCServer) GetAppchainInfo(ctx context.Context, request *pb.ChainInfoRequest) (*pb.ChainInfoResponse, error)

+ func (s *GRPCServer) GetIBTPCh(_ *pb.Empty, conn pb.AppchainPlugin_GetIBTPChServer) error

Sep 29, 2021

Changes in this version

type Client

+ GetReceiptMessage func(servicePair string, idx uint64) (*pb.IBTP, error)

+ SubmitReceipt func(ibtp *pb.IBTP) (*pb.SubmitIBTPResponse, error)

type GRPCClient

+ func (g *GRPCClient) GetReceiptMessage(servicePair string, idx uint64) (*pb.IBTP, error)

+ func (g *GRPCClient) SubmitReceipt(ibtp *pb.IBTP) (*pb.SubmitIBTPResponse, error)

type GRPCServer

+ func (s *GRPCServer) GetReceiptMessage(_ context.Context, req *pb.GetMessageRequest) (*pb.IBTP, error)

+ func (s *GRPCServer) SubmitReceipt(ctx context.Context, ibtp *pb.IBTP) (*pb.SubmitIBTPResponse, error)

Aug 20, 2021

Changes in this version

type Client

+ GetChainID func() (string, string)

+ GetDstRollbackMeta func() (map[string]uint64, error)

+ GetServices func() []string

+ GetSrcRollbackMeta func() (map[string]uint64, error)

type GRPCClient

+ func (g *GRPCClient) GetChainID() (string, string)

+ func (g *GRPCClient) GetDstRollbackMeta() (map[string]uint64, error)

+ func (g *GRPCClient) GetServices() []string

+ func (g *GRPCClient) GetSrcRollbackMeta() (map[string]uint64, error)

type GRPCServer

+ func (s *GRPCServer) GetChainID(ctx context.Context, empty *pb.Empty) (*pb.ChainIDResponse, error)

+ func (s *GRPCServer) GetDstRollbackMeta(ctx context.Context, empty *pb.Empty) (*pb.GetMetaResponse, error)

+ func (s *GRPCServer) GetServices(ctx context.Context, empty *pb.Empty) (*pb.ServicesResponse, error)

+ func (s *GRPCServer) GetSrcRollbackMeta(ctx context.Context, empty *pb.Empty) (*pb.GetMetaResponse, error)

Sep 1, 2021

Changes in this version

type GRPCServer

+ func (s *GRPCServer) GetLockEvent(empty *pb.Empty, server pb.AppchainPlugin_GetLockEventServer) error

+ func (s *GRPCServer) GetUpdateMeta(empty *pb.Empty, server pb.AppchainPlugin_GetUpdateMetaServer) error

+ func (s *GRPCServer) QueryAppchainIndex(ctx context.Context, empty *pb.Empty) (*pb.QueryAppchainIndexResponse, error)

+ func (s *GRPCServer) QueryFilterLockStart(ctx context.Context, request *pb.QueryFilterLockStartRequest) (*pb.QueryFilterLockStartResponse, error)

+ func (s *GRPCServer) QueryLockEventByIndex(ctx context.Context, request *pb.QueryLockEventByIndexRequest) (*pb.LockEvent, error)

+ func (s *GRPCServer) QueryRelayIndex(ctx context.Context, empty *pb.Empty) (*pb.QueryRelayIndexResponse, error)

+ func (s *GRPCServer) UnEscrow(ctx context.Context, lock *pb.UnLock) (*pb.Empty, error)

May 29, 2021

Changes in this version

type Client

+ IncreaseInMeta func(ibtp *pb.IBTP) (*pb.IBTP, error)

+ RollbackIBTP func(ibtp *pb.IBTP, isSrcChain bool) (*pb.RollbackIBTPResponse, error)

type GRPCClient

+ func (g *GRPCClient) IncreaseInMeta(original *pb.IBTP) (*pb.IBTP, error)

+ func (g *GRPCClient) RollbackIBTP(ibtp *pb.IBTP, srcChain bool) (*pb.RollbackIBTPResponse, error)

type GRPCServer

+ func (s *GRPCServer) IncreaseInMeta(_ context.Context, in *pb.IBTP) (*pb.IBTP, error)

+ func (s *GRPCServer) RollbackIBTP(_ context.Context, req *pb.RollbackIBTPRequest) (*pb.RollbackIBTPResponse, error)

Mar 26, 2021

Changes in this version

type Client

+ GetReceipt func(ibtp *pb.IBTP) (*pb.IBTP, error)

type GRPCClient

+ func (g *GRPCClient) GetReceipt(ibtp *pb.IBTP) (*pb.IBTP, error)

type GRPCServer

+ func (s *GRPCServer) GetReceipt(_ context.Context, ibtp *pb.IBTP) (*pb.IBTP, error)

Jan 28, 2021

Changes in this version

+ var Handshake = plugin.HandshakeConfig

+ var PluginMap = map[string]plugin.Plugin

+ var PluginName = "appchain-plugin"

+ type AppchainGRPCPlugin struct

+ Impl Client

+ func (p *AppchainGRPCPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

+ func (p *AppchainGRPCPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

+ type Client interface

+ CommitCallback func(ibtp *pb.IBTP) error

+ GetCallbackMeta func() (map[string]uint64, error)

+ GetIBTP func() chan *pb.IBTP

+ GetInMessage func(from string, idx uint64) ([][]byte, error)

+ GetInMeta func() (map[string]uint64, error)

+ GetOutMessage func(to string, idx uint64) (*pb.IBTP, error)

+ GetOutMeta func() (map[string]uint64, error)

+ Initialize func(configPath string, pierID string, extra []byte) error

+ Name func() string

+ Start func() error

+ Stop func() error

+ SubmitIBTP func(*pb.IBTP) (*pb.SubmitIBTPResponse, error)

+ Type func() string

+ type GRPCClient struct

+ func (g *GRPCClient) CommitCallback(_ *pb.IBTP) error

+ func (g *GRPCClient) GetCallbackMeta() (map[string]uint64, error)

+ func (g *GRPCClient) GetIBTP() chan *pb.IBTP

+ func (g *GRPCClient) GetInMessage(from string, idx uint64) ([][]byte, error)

+ func (g *GRPCClient) GetInMeta() (map[string]uint64, error)

+ func (g *GRPCClient) GetOutMessage(to string, idx uint64) (*pb.IBTP, error)

+ func (g *GRPCClient) GetOutMeta() (map[string]uint64, error)

+ func (g *GRPCClient) Initialize(configPath string, pierID string, extra []byte) error

+ func (g *GRPCClient) Name() string

+ func (g *GRPCClient) Start() error

+ func (g *GRPCClient) Stop() error

+ func (g *GRPCClient) SubmitIBTP(ibtp *pb.IBTP) (*pb.SubmitIBTPResponse, error)

+ func (g *GRPCClient) Type() string

+ type GRPCServer struct

+ Impl Client

+ func (s *GRPCServer) CommitCallback(_ context.Context, _ *pb.IBTP) (*pb.Empty, error)

+ func (s *GRPCServer) GetCallbackMeta(context.Context, *pb.Empty) (*pb.GetMetaResponse, error)

+ func (s *GRPCServer) GetIBTP(_ *pb.Empty, conn pb.AppchainPlugin_GetIBTPServer) error

+ func (s *GRPCServer) GetInMessage(_ context.Context, req *pb.GetInMessageRequest) (*pb.GetInMessageResponse, error)

+ func (s *GRPCServer) GetInMeta(context.Context, *pb.Empty) (*pb.GetMetaResponse, error)

+ func (s *GRPCServer) GetOutMessage(_ context.Context, req *pb.GetOutMessageRequest) (*pb.IBTP, error)

+ func (s *GRPCServer) GetOutMeta(context.Context, *pb.Empty) (*pb.GetMetaResponse, error)

+ func (s *GRPCServer) Initialize(_ context.Context, req *pb.InitializeRequest) (*pb.Empty, error)

+ func (s *GRPCServer) Name(context.Context, *pb.Empty) (*pb.NameResponse, error)

+ func (s *GRPCServer) Start(context.Context, *pb.Empty) (*pb.Empty, error)

+ func (s *GRPCServer) Stop(context.Context, *pb.Empty) (*pb.Empty, error)

+ func (s *GRPCServer) SubmitIBTP(_ context.Context, ibtp *pb.IBTP) (*pb.SubmitIBTPResponse, error)

+ func (s *GRPCServer) Type(context.Context, *pb.Empty) (*pb.TypeResponse, error)

Aug 3, 2020

Changes in this version

+ func CreateClient(id string, config *repo.Config, extra []byte) (client.Client, error)