api

Documentation

Index

• Variables
• func MetaFromData(d *metadbpb.Data) *apipb.Meta
• type ClientFunc
• type Router
  • func NewRouter(router pt.Router, client ClientFunc) *Router
  • func (r *Router) GetBalance(ctx context.Context, req *gatepb.GetBalanceRequest) (*gatepb.GetBalanceResponse, error)
  • func (r *Router) GetLastSettings(ctx context.Context, req *gatepb.GetLastSettingsRequest) (*gatepb.GetLastSettingsResponse, error)
  • func (r *Router) GetPrevHash(ctx context.Context, req *gatepb.GetPrevHashRequest) (*gatepb.GetPrevHashResponse, error)
  • func (r *Router) ProcessTransfer(ctx context.Context, req *gatepb.TransferRequest) (*gatepb.TransferResponse, error)
  • func (r *Router) UpdateSettings(ctx context.Context, req *gatepb.SettingsRequest) (*gatepb.SettingsResponse, error)
• type Service
  • func NewService(gate gatepb.ProcessorServiceInterface) *Service
  • func (s *Service) GetBalance(ctx context.Context, req *apipb.GetBalanceRequest) (*apipb.GetBalanceResponse, error)
  • func (s *Service) GetByMetaKey(ctx context.Context, req *apipb.GetByMetaKeyRequest) (*apipb.GetByMetaKeyResponse, error)
  • func (s *Service) GetHistory(ctx context.Context, req *apipb.GetHistoryRequest) (*apipb.GetHistoryResponse, error)
  • func (s *Service) GetLastSettings(ctx context.Context, req *apipb.GetLastSettingsRequest) (*apipb.GetLastSettingsResponse, error)
  • func (s *Service) GetPrevHash(ctx context.Context, req *apipb.GetPrevHashRequest) (*apipb.GetPrevHashResponse, error)
  • func (s *Service) ProcessTransfer(ctx context.Context, req *apipb.TransferRequest) (*apipb.TransferResponse, error)
  • func (s *Service) PutMeta(ctx context.Context, req *apipb.PutMetaRequest) (*apipb.PutMetaResponse, error)
  • func (s *Service) SearchMeta(ctx context.Context, req *apipb.SearchMetaRequest) (*apipb.SearchMetaResponse, error)
  • func (s *Service) SetMetaDBClient(c metadbpb.MetaDBServiceInterface)
  • func (s *Service) SetPlutoDBClient(c plutodbpb.PlutoDBServiceInterface)
  • func (s *Service) UpdateSettings(ctx context.Context, req *apipb.SettingsRequest) (*apipb.SettingsResponse, error)

Variables

var ErrMetaIsNotAvailable = errors.New("metadb is not available")

var (
	TxnsMetaPrefix = []byte("m")
)

Functions

func MetaFromData

func MetaFromData(d *metadbpb.Data) *apipb.Meta

Types

type ClientFunc

type ClientFunc func(baseurl string) gatepb.ProcessorServiceInterface

type Router

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

func NewRouter

func NewRouter(router pt.Router, client ClientFunc) *Router

func (*Router) GetBalance

func (r *Router) GetBalance(ctx context.Context, req *gatepb.GetBalanceRequest) (*gatepb.GetBalanceResponse, error)

func (*Router) GetLastSettings

func (r *Router) GetLastSettings(ctx context.Context, req *gatepb.GetLastSettingsRequest) (*gatepb.GetLastSettingsResponse, error)

func (*Router) GetPrevHash

func (r *Router) GetPrevHash(ctx context.Context, req *gatepb.GetPrevHashRequest) (*gatepb.GetPrevHashResponse, error)

func (*Router) ProcessTransfer

func (r *Router) ProcessTransfer(ctx context.Context, req *gatepb.TransferRequest) (*gatepb.TransferResponse, error)

func (*Router) UpdateSettings

func (r *Router) UpdateSettings(ctx context.Context, req *gatepb.SettingsRequest) (*gatepb.SettingsResponse, error)

type Service

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

func NewService

func NewService(gate gatepb.ProcessorServiceInterface) *Service

func (*Service) GetBalance

func (s *Service) GetBalance(ctx context.Context, req *apipb.GetBalanceRequest) (*apipb.GetBalanceResponse, error)

func (*Service) GetByMetaKey

func (s *Service) GetByMetaKey(ctx context.Context, req *apipb.GetByMetaKeyRequest) (*apipb.GetByMetaKeyResponse, error)

func (*Service) GetHistory

func (s *Service) GetHistory(ctx context.Context, req *apipb.GetHistoryRequest) (*apipb.GetHistoryResponse, error)

func (*Service) GetLastSettings

func (s *Service) GetLastSettings(ctx context.Context, req *apipb.GetLastSettingsRequest) (*apipb.GetLastSettingsResponse, error)

func (*Service) GetPrevHash

func (s *Service) GetPrevHash(ctx context.Context, req *apipb.GetPrevHashRequest) (*apipb.GetPrevHashResponse, error)

func (*Service) ProcessTransfer

func (s *Service) ProcessTransfer(ctx context.Context, req *apipb.TransferRequest) (*apipb.TransferResponse, error)

func (*Service) PutMeta

func (s *Service) PutMeta(ctx context.Context, req *apipb.PutMetaRequest) (*apipb.PutMetaResponse, error)

func (*Service) SearchMeta

func (s *Service) SearchMeta(ctx context.Context, req *apipb.SearchMetaRequest) (*apipb.SearchMetaResponse, error)

func (*Service) SetMetaDBClient

func (s *Service) SetMetaDBClient(c metadbpb.MetaDBServiceInterface)

func (*Service) SetPlutoDBClient

func (s *Service) SetPlutoDBClient(c plutodbpb.PlutoDBServiceInterface)

func (*Service) UpdateSettings

func (s *Service) UpdateSettings(ctx context.Context, req *apipb.SettingsRequest) (*apipb.SettingsResponse, error)