Versions in this module Expand all Collapse all v0 v0.1.0 Feb 28, 2019 Changes in this version + var DBStatusCode_name = map[int32]string + var DBStatusCode_value = map[string]int32 + func RegisterPlutoDBServiceHandlers(s *tcprpc.Server, prefix string, srv PlutoDBServiceInterface) + type DBStatusCode int32 + const DBStatusCode_INVALID_TOKEN + const DBStatusCode_OK + const DBStatusCode_OTHER_ERROR + func (DBStatusCode) EnumDescriptor() ([]byte, []int) + func (x DBStatusCode) String() string + type FetchRequest struct + Account uint64 + Limit uint32 + func (*FetchRequest) Descriptor() ([]byte, []int) + func (*FetchRequest) ProtoMessage() + func (m *FetchRequest) GetAccount() uint64 + func (m *FetchRequest) GetLimit() uint32 + func (m *FetchRequest) Reset() + func (m *FetchRequest) String() string + type FetchResponse struct + Settings *chain.Settings + Status *Status + Txns []*chain.Txn + func (*FetchResponse) Descriptor() ([]byte, []int) + func (*FetchResponse) ProtoMessage() + func (m *FetchResponse) GetSettings() *chain.Settings + func (m *FetchResponse) GetStatus() *Status + func (m *FetchResponse) GetTxns() []*chain.Txn + func (m *FetchResponse) Reset() + func (m *FetchResponse) String() string + type GetHistoryRequest struct + Account uint64 + Limit uint32 + Token string + func (*GetHistoryRequest) Descriptor() ([]byte, []int) + func (*GetHistoryRequest) ProtoMessage() + func (m *GetHistoryRequest) GetAccount() uint64 + func (m *GetHistoryRequest) GetLimit() uint32 + func (m *GetHistoryRequest) GetToken() string + func (m *GetHistoryRequest) Reset() + func (m *GetHistoryRequest) String() string + type GetHistoryResponse struct + Status *Status + Token string + Txns []*chain.Txn + func (*GetHistoryResponse) Descriptor() ([]byte, []int) + func (*GetHistoryResponse) ProtoMessage() + func (m *GetHistoryResponse) GetStatus() *Status + func (m *GetHistoryResponse) GetToken() string + func (m *GetHistoryResponse) GetTxns() []*chain.Txn + func (m *GetHistoryResponse) Reset() + func (m *GetHistoryResponse) String() string + type GetTxnMultiRequest struct + IDs []*chain.TxnID + func (*GetTxnMultiRequest) Descriptor() ([]byte, []int) + func (*GetTxnMultiRequest) ProtoMessage() + func (m *GetTxnMultiRequest) GetIDs() []*chain.TxnID + func (m *GetTxnMultiRequest) Reset() + func (m *GetTxnMultiRequest) String() string + type GetTxnMultiResponse struct + Status *Status + Txns []*chain.Txn + func (*GetTxnMultiResponse) Descriptor() ([]byte, []int) + func (*GetTxnMultiResponse) ProtoMessage() + func (m *GetTxnMultiResponse) GetStatus() *Status + func (m *GetTxnMultiResponse) GetTxns() []*chain.Txn + func (m *GetTxnMultiResponse) Reset() + func (m *GetTxnMultiResponse) String() string + type PlutoDBServiceInterface interface + Fetch func(context.Context, *FetchRequest) (*FetchResponse, error) + GetHistory func(context.Context, *GetHistoryRequest) (*GetHistoryResponse, error) + GetTxnMulti func(context.Context, *GetTxnMultiRequest) (*GetTxnMultiResponse, error) + type Status struct + Code DBStatusCode + Details []*google_protobuf.Any + Message string + func (*Status) Descriptor() ([]byte, []int) + func (*Status) ProtoMessage() + func (m *Status) GetCode() DBStatusCode + func (m *Status) GetDetails() []*google_protobuf.Any + func (m *Status) GetMessage() string + func (m *Status) Reset() + func (m *Status) String() string + type TCPRPCPlutoDBServiceClient struct + func NewTCPRPCPlutoDBServiceClient(cl *tcprpc.Client, pref string) TCPRPCPlutoDBServiceClient + func (cl TCPRPCPlutoDBServiceClient) Fetch(ctx context.Context, args *FetchRequest) (*FetchResponse, error) + func (cl TCPRPCPlutoDBServiceClient) GetHistory(ctx context.Context, args *GetHistoryRequest) (*GetHistoryResponse, error) + func (cl TCPRPCPlutoDBServiceClient) GetTxnMulti(ctx context.Context, args *GetTxnMultiRequest) (*GetTxnMultiResponse, error)