1768 lines
58 KiB
Go
1768 lines
58 KiB
Go
// Code generated by protoc-gen-go. DO NOT EDIT.
|
|
// versions:
|
|
// protoc-gen-go v1.36.11
|
|
// protoc (unknown)
|
|
// source: ledger/v1/msg.proto
|
|
|
|
package ledgerv1
|
|
|
|
import (
|
|
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
|
|
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
|
|
timestamppb "google.golang.org/protobuf/types/known/timestamppb"
|
|
reflect "reflect"
|
|
sync "sync"
|
|
unsafe "unsafe"
|
|
)
|
|
|
|
const (
|
|
// Verify that this generated code is sufficiently up-to-date.
|
|
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
|
|
// Verify that runtime/protoimpl is sufficiently up-to-date.
|
|
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
|
|
)
|
|
|
|
type AccountClass int32
|
|
|
|
const (
|
|
AccountClass_ACCOUNT_CLASS_UNSPECIFIED AccountClass = 0
|
|
AccountClass_ACCOUNT_CLASS_USER_AVAILABLE AccountClass = 1
|
|
AccountClass_ACCOUNT_CLASS_USER_FROZEN AccountClass = 2
|
|
AccountClass_ACCOUNT_CLASS_EXTERNAL_BLOCKCHAIN AccountClass = 3
|
|
AccountClass_ACCOUNT_CLASS_TREASURY AccountClass = 4
|
|
AccountClass_ACCOUNT_CLASS_MARKET_CLEARING AccountClass = 5
|
|
AccountClass_ACCOUNT_CLASS_IPG_CLEARING AccountClass = 6
|
|
AccountClass_ACCOUNT_CLASS_COMMISSION_REVENUE AccountClass = 7
|
|
)
|
|
|
|
// Enum value maps for AccountClass.
|
|
var (
|
|
AccountClass_name = map[int32]string{
|
|
0: "ACCOUNT_CLASS_UNSPECIFIED",
|
|
1: "ACCOUNT_CLASS_USER_AVAILABLE",
|
|
2: "ACCOUNT_CLASS_USER_FROZEN",
|
|
3: "ACCOUNT_CLASS_EXTERNAL_BLOCKCHAIN",
|
|
4: "ACCOUNT_CLASS_TREASURY",
|
|
5: "ACCOUNT_CLASS_MARKET_CLEARING",
|
|
6: "ACCOUNT_CLASS_IPG_CLEARING",
|
|
7: "ACCOUNT_CLASS_COMMISSION_REVENUE",
|
|
}
|
|
AccountClass_value = map[string]int32{
|
|
"ACCOUNT_CLASS_UNSPECIFIED": 0,
|
|
"ACCOUNT_CLASS_USER_AVAILABLE": 1,
|
|
"ACCOUNT_CLASS_USER_FROZEN": 2,
|
|
"ACCOUNT_CLASS_EXTERNAL_BLOCKCHAIN": 3,
|
|
"ACCOUNT_CLASS_TREASURY": 4,
|
|
"ACCOUNT_CLASS_MARKET_CLEARING": 5,
|
|
"ACCOUNT_CLASS_IPG_CLEARING": 6,
|
|
"ACCOUNT_CLASS_COMMISSION_REVENUE": 7,
|
|
}
|
|
)
|
|
|
|
func (x AccountClass) Enum() *AccountClass {
|
|
p := new(AccountClass)
|
|
*p = x
|
|
return p
|
|
}
|
|
|
|
func (x AccountClass) String() string {
|
|
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
|
|
}
|
|
|
|
func (AccountClass) Descriptor() protoreflect.EnumDescriptor {
|
|
return file_ledger_v1_msg_proto_enumTypes[0].Descriptor()
|
|
}
|
|
|
|
func (AccountClass) Type() protoreflect.EnumType {
|
|
return &file_ledger_v1_msg_proto_enumTypes[0]
|
|
}
|
|
|
|
func (x AccountClass) Number() protoreflect.EnumNumber {
|
|
return protoreflect.EnumNumber(x)
|
|
}
|
|
|
|
// Deprecated: Use AccountClass.Descriptor instead.
|
|
func (AccountClass) EnumDescriptor() ([]byte, []int) {
|
|
return file_ledger_v1_msg_proto_rawDescGZIP(), []int{0}
|
|
}
|
|
|
|
type TransactionState int32
|
|
|
|
const (
|
|
TransactionState_TRANSACTION_STATE_UNSPECIFIED TransactionState = 0
|
|
TransactionState_TRANSACTION_STATE_CREATED TransactionState = 1
|
|
TransactionState_TRANSACTION_STATE_PENDING_TRANSACTION TransactionState = 2
|
|
TransactionState_TRANSACTION_STATE_PENDING_ADMIN TransactionState = 3
|
|
TransactionState_TRANSACTION_STATE_SUCCESSFUL TransactionState = 4
|
|
TransactionState_TRANSACTION_STATE_FAILED TransactionState = 5
|
|
TransactionState_TRANSACTION_STATE_SUSPENDED TransactionState = 6
|
|
)
|
|
|
|
// Enum value maps for TransactionState.
|
|
var (
|
|
TransactionState_name = map[int32]string{
|
|
0: "TRANSACTION_STATE_UNSPECIFIED",
|
|
1: "TRANSACTION_STATE_CREATED",
|
|
2: "TRANSACTION_STATE_PENDING_TRANSACTION",
|
|
3: "TRANSACTION_STATE_PENDING_ADMIN",
|
|
4: "TRANSACTION_STATE_SUCCESSFUL",
|
|
5: "TRANSACTION_STATE_FAILED",
|
|
6: "TRANSACTION_STATE_SUSPENDED",
|
|
}
|
|
TransactionState_value = map[string]int32{
|
|
"TRANSACTION_STATE_UNSPECIFIED": 0,
|
|
"TRANSACTION_STATE_CREATED": 1,
|
|
"TRANSACTION_STATE_PENDING_TRANSACTION": 2,
|
|
"TRANSACTION_STATE_PENDING_ADMIN": 3,
|
|
"TRANSACTION_STATE_SUCCESSFUL": 4,
|
|
"TRANSACTION_STATE_FAILED": 5,
|
|
"TRANSACTION_STATE_SUSPENDED": 6,
|
|
}
|
|
)
|
|
|
|
func (x TransactionState) Enum() *TransactionState {
|
|
p := new(TransactionState)
|
|
*p = x
|
|
return p
|
|
}
|
|
|
|
func (x TransactionState) String() string {
|
|
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
|
|
}
|
|
|
|
func (TransactionState) Descriptor() protoreflect.EnumDescriptor {
|
|
return file_ledger_v1_msg_proto_enumTypes[1].Descriptor()
|
|
}
|
|
|
|
func (TransactionState) Type() protoreflect.EnumType {
|
|
return &file_ledger_v1_msg_proto_enumTypes[1]
|
|
}
|
|
|
|
func (x TransactionState) Number() protoreflect.EnumNumber {
|
|
return protoreflect.EnumNumber(x)
|
|
}
|
|
|
|
// Deprecated: Use TransactionState.Descriptor instead.
|
|
func (TransactionState) EnumDescriptor() ([]byte, []int) {
|
|
return file_ledger_v1_msg_proto_rawDescGZIP(), []int{1}
|
|
}
|
|
|
|
type AccountReference struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
AccountClass AccountClass `protobuf:"varint,1,opt,name=account_class,json=accountClass,proto3,enum=ledger.v1.AccountClass" json:"account_class,omitempty"`
|
|
OwnerType string `protobuf:"bytes,2,opt,name=owner_type,json=ownerType,proto3" json:"owner_type,omitempty"`
|
|
OwnerId string `protobuf:"bytes,3,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"`
|
|
AssetId int64 `protobuf:"varint,4,opt,name=asset_id,json=assetId,proto3" json:"asset_id,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *AccountReference) Reset() {
|
|
*x = AccountReference{}
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[0]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *AccountReference) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*AccountReference) ProtoMessage() {}
|
|
|
|
func (x *AccountReference) ProtoReflect() protoreflect.Message {
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[0]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use AccountReference.ProtoReflect.Descriptor instead.
|
|
func (*AccountReference) Descriptor() ([]byte, []int) {
|
|
return file_ledger_v1_msg_proto_rawDescGZIP(), []int{0}
|
|
}
|
|
|
|
func (x *AccountReference) GetAccountClass() AccountClass {
|
|
if x != nil {
|
|
return x.AccountClass
|
|
}
|
|
return AccountClass_ACCOUNT_CLASS_UNSPECIFIED
|
|
}
|
|
|
|
func (x *AccountReference) GetOwnerType() string {
|
|
if x != nil {
|
|
return x.OwnerType
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *AccountReference) GetOwnerId() string {
|
|
if x != nil {
|
|
return x.OwnerId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *AccountReference) GetAssetId() int64 {
|
|
if x != nil {
|
|
return x.AssetId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
type JournalEntry struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
LineNumber uint32 `protobuf:"varint,1,opt,name=line_number,json=lineNumber,proto3" json:"line_number,omitempty"`
|
|
Account *AccountReference `protobuf:"bytes,2,opt,name=account,proto3" json:"account,omitempty"`
|
|
// Canonical base-10 decimal. Positive is credit and negative is debit.
|
|
Amount string `protobuf:"bytes,3,opt,name=amount,proto3" json:"amount,omitempty"`
|
|
Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *JournalEntry) Reset() {
|
|
*x = JournalEntry{}
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[1]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *JournalEntry) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*JournalEntry) ProtoMessage() {}
|
|
|
|
func (x *JournalEntry) ProtoReflect() protoreflect.Message {
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[1]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use JournalEntry.ProtoReflect.Descriptor instead.
|
|
func (*JournalEntry) Descriptor() ([]byte, []int) {
|
|
return file_ledger_v1_msg_proto_rawDescGZIP(), []int{1}
|
|
}
|
|
|
|
func (x *JournalEntry) GetLineNumber() uint32 {
|
|
if x != nil {
|
|
return x.LineNumber
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *JournalEntry) GetAccount() *AccountReference {
|
|
if x != nil {
|
|
return x.Account
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *JournalEntry) GetAmount() string {
|
|
if x != nil {
|
|
return x.Amount
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *JournalEntry) GetDescription() string {
|
|
if x != nil {
|
|
return x.Description
|
|
}
|
|
return ""
|
|
}
|
|
|
|
type BlockchainReference struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Network string `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`
|
|
TransactionHash string `protobuf:"bytes,2,opt,name=transaction_hash,json=transactionHash,proto3" json:"transaction_hash,omitempty"`
|
|
LedgerSequence string `protobuf:"bytes,3,opt,name=ledger_sequence,json=ledgerSequence,proto3" json:"ledger_sequence,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *BlockchainReference) Reset() {
|
|
*x = BlockchainReference{}
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[2]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *BlockchainReference) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*BlockchainReference) ProtoMessage() {}
|
|
|
|
func (x *BlockchainReference) ProtoReflect() protoreflect.Message {
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[2]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use BlockchainReference.ProtoReflect.Descriptor instead.
|
|
func (*BlockchainReference) Descriptor() ([]byte, []int) {
|
|
return file_ledger_v1_msg_proto_rawDescGZIP(), []int{2}
|
|
}
|
|
|
|
func (x *BlockchainReference) GetNetwork() string {
|
|
if x != nil {
|
|
return x.Network
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *BlockchainReference) GetTransactionHash() string {
|
|
if x != nil {
|
|
return x.TransactionHash
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *BlockchainReference) GetLedgerSequence() string {
|
|
if x != nil {
|
|
return x.LedgerSequence
|
|
}
|
|
return ""
|
|
}
|
|
|
|
type Journal struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
JournalId string `protobuf:"bytes,1,opt,name=journal_id,json=journalId,proto3" json:"journal_id,omitempty"`
|
|
SourceService string `protobuf:"bytes,2,opt,name=source_service,json=sourceService,proto3" json:"source_service,omitempty"`
|
|
IdempotencyKey string `protobuf:"bytes,3,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
|
|
SourceTransactionId string `protobuf:"bytes,4,opt,name=source_transaction_id,json=sourceTransactionId,proto3" json:"source_transaction_id,omitempty"`
|
|
TrackingCode string `protobuf:"bytes,5,opt,name=tracking_code,json=trackingCode,proto3" json:"tracking_code,omitempty"`
|
|
EffectKind string `protobuf:"bytes,6,opt,name=effect_kind,json=effectKind,proto3" json:"effect_kind,omitempty"`
|
|
EventVersion uint32 `protobuf:"varint,7,opt,name=event_version,json=eventVersion,proto3" json:"event_version,omitempty"`
|
|
Entries []*JournalEntry `protobuf:"bytes,8,rep,name=entries,proto3" json:"entries,omitempty"`
|
|
ReversalOfJournalId *string `protobuf:"bytes,9,opt,name=reversal_of_journal_id,json=reversalOfJournalId,proto3,oneof" json:"reversal_of_journal_id,omitempty"`
|
|
OccurredAt *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
|
|
RecordedAt *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=recorded_at,json=recordedAt,proto3" json:"recorded_at,omitempty"`
|
|
CorrelationId string `protobuf:"bytes,12,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
|
|
ActorId string `protobuf:"bytes,13,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
|
|
Blockchain *BlockchainReference `protobuf:"bytes,14,opt,name=blockchain,proto3" json:"blockchain,omitempty"`
|
|
Metadata map[string]string `protobuf:"bytes,15,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
|
|
PayloadHash string `protobuf:"bytes,16,opt,name=payload_hash,json=payloadHash,proto3" json:"payload_hash,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *Journal) Reset() {
|
|
*x = Journal{}
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[3]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *Journal) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*Journal) ProtoMessage() {}
|
|
|
|
func (x *Journal) ProtoReflect() protoreflect.Message {
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[3]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use Journal.ProtoReflect.Descriptor instead.
|
|
func (*Journal) Descriptor() ([]byte, []int) {
|
|
return file_ledger_v1_msg_proto_rawDescGZIP(), []int{3}
|
|
}
|
|
|
|
func (x *Journal) GetJournalId() string {
|
|
if x != nil {
|
|
return x.JournalId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *Journal) GetSourceService() string {
|
|
if x != nil {
|
|
return x.SourceService
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *Journal) GetIdempotencyKey() string {
|
|
if x != nil {
|
|
return x.IdempotencyKey
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *Journal) GetSourceTransactionId() string {
|
|
if x != nil {
|
|
return x.SourceTransactionId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *Journal) GetTrackingCode() string {
|
|
if x != nil {
|
|
return x.TrackingCode
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *Journal) GetEffectKind() string {
|
|
if x != nil {
|
|
return x.EffectKind
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *Journal) GetEventVersion() uint32 {
|
|
if x != nil {
|
|
return x.EventVersion
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *Journal) GetEntries() []*JournalEntry {
|
|
if x != nil {
|
|
return x.Entries
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Journal) GetReversalOfJournalId() string {
|
|
if x != nil && x.ReversalOfJournalId != nil {
|
|
return *x.ReversalOfJournalId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *Journal) GetOccurredAt() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.OccurredAt
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Journal) GetRecordedAt() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.RecordedAt
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Journal) GetCorrelationId() string {
|
|
if x != nil {
|
|
return x.CorrelationId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *Journal) GetActorId() string {
|
|
if x != nil {
|
|
return x.ActorId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *Journal) GetBlockchain() *BlockchainReference {
|
|
if x != nil {
|
|
return x.Blockchain
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Journal) GetMetadata() map[string]string {
|
|
if x != nil {
|
|
return x.Metadata
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Journal) GetPayloadHash() string {
|
|
if x != nil {
|
|
return x.PayloadHash
|
|
}
|
|
return ""
|
|
}
|
|
|
|
type AppendJournalRequest struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
SourceService string `protobuf:"bytes,1,opt,name=source_service,json=sourceService,proto3" json:"source_service,omitempty"`
|
|
IdempotencyKey string `protobuf:"bytes,2,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
|
|
SourceTransactionId string `protobuf:"bytes,3,opt,name=source_transaction_id,json=sourceTransactionId,proto3" json:"source_transaction_id,omitempty"`
|
|
TrackingCode string `protobuf:"bytes,4,opt,name=tracking_code,json=trackingCode,proto3" json:"tracking_code,omitempty"`
|
|
EffectKind string `protobuf:"bytes,5,opt,name=effect_kind,json=effectKind,proto3" json:"effect_kind,omitempty"`
|
|
EventVersion uint32 `protobuf:"varint,6,opt,name=event_version,json=eventVersion,proto3" json:"event_version,omitempty"`
|
|
Entries []*JournalEntry `protobuf:"bytes,7,rep,name=entries,proto3" json:"entries,omitempty"`
|
|
ReversalOfJournalId *string `protobuf:"bytes,8,opt,name=reversal_of_journal_id,json=reversalOfJournalId,proto3,oneof" json:"reversal_of_journal_id,omitempty"`
|
|
OccurredAt *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
|
|
CorrelationId string `protobuf:"bytes,10,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
|
|
ActorId string `protobuf:"bytes,11,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
|
|
Blockchain *BlockchainReference `protobuf:"bytes,12,opt,name=blockchain,proto3" json:"blockchain,omitempty"`
|
|
Metadata map[string]string `protobuf:"bytes,13,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *AppendJournalRequest) Reset() {
|
|
*x = AppendJournalRequest{}
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[4]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *AppendJournalRequest) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*AppendJournalRequest) ProtoMessage() {}
|
|
|
|
func (x *AppendJournalRequest) ProtoReflect() protoreflect.Message {
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[4]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use AppendJournalRequest.ProtoReflect.Descriptor instead.
|
|
func (*AppendJournalRequest) Descriptor() ([]byte, []int) {
|
|
return file_ledger_v1_msg_proto_rawDescGZIP(), []int{4}
|
|
}
|
|
|
|
func (x *AppendJournalRequest) GetSourceService() string {
|
|
if x != nil {
|
|
return x.SourceService
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *AppendJournalRequest) GetIdempotencyKey() string {
|
|
if x != nil {
|
|
return x.IdempotencyKey
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *AppendJournalRequest) GetSourceTransactionId() string {
|
|
if x != nil {
|
|
return x.SourceTransactionId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *AppendJournalRequest) GetTrackingCode() string {
|
|
if x != nil {
|
|
return x.TrackingCode
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *AppendJournalRequest) GetEffectKind() string {
|
|
if x != nil {
|
|
return x.EffectKind
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *AppendJournalRequest) GetEventVersion() uint32 {
|
|
if x != nil {
|
|
return x.EventVersion
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *AppendJournalRequest) GetEntries() []*JournalEntry {
|
|
if x != nil {
|
|
return x.Entries
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *AppendJournalRequest) GetReversalOfJournalId() string {
|
|
if x != nil && x.ReversalOfJournalId != nil {
|
|
return *x.ReversalOfJournalId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *AppendJournalRequest) GetOccurredAt() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.OccurredAt
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *AppendJournalRequest) GetCorrelationId() string {
|
|
if x != nil {
|
|
return x.CorrelationId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *AppendJournalRequest) GetActorId() string {
|
|
if x != nil {
|
|
return x.ActorId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *AppendJournalRequest) GetBlockchain() *BlockchainReference {
|
|
if x != nil {
|
|
return x.Blockchain
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *AppendJournalRequest) GetMetadata() map[string]string {
|
|
if x != nil {
|
|
return x.Metadata
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type AppendJournalResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Journal *Journal `protobuf:"bytes,1,opt,name=journal,proto3" json:"journal,omitempty"`
|
|
AlreadyExisted bool `protobuf:"varint,2,opt,name=already_existed,json=alreadyExisted,proto3" json:"already_existed,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *AppendJournalResponse) Reset() {
|
|
*x = AppendJournalResponse{}
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[5]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *AppendJournalResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*AppendJournalResponse) ProtoMessage() {}
|
|
|
|
func (x *AppendJournalResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[5]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use AppendJournalResponse.ProtoReflect.Descriptor instead.
|
|
func (*AppendJournalResponse) Descriptor() ([]byte, []int) {
|
|
return file_ledger_v1_msg_proto_rawDescGZIP(), []int{5}
|
|
}
|
|
|
|
func (x *AppendJournalResponse) GetJournal() *Journal {
|
|
if x != nil {
|
|
return x.Journal
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *AppendJournalResponse) GetAlreadyExisted() bool {
|
|
if x != nil {
|
|
return x.AlreadyExisted
|
|
}
|
|
return false
|
|
}
|
|
|
|
type AppendTransactionEventRequest struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
SourceService string `protobuf:"bytes,1,opt,name=source_service,json=sourceService,proto3" json:"source_service,omitempty"`
|
|
IdempotencyKey string `protobuf:"bytes,2,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
|
|
SourceTransactionId string `protobuf:"bytes,3,opt,name=source_transaction_id,json=sourceTransactionId,proto3" json:"source_transaction_id,omitempty"`
|
|
TrackingCode string `protobuf:"bytes,4,opt,name=tracking_code,json=trackingCode,proto3" json:"tracking_code,omitempty"`
|
|
EventVersion uint32 `protobuf:"varint,5,opt,name=event_version,json=eventVersion,proto3" json:"event_version,omitempty"`
|
|
State TransactionState `protobuf:"varint,6,opt,name=state,proto3,enum=ledger.v1.TransactionState" json:"state,omitempty"`
|
|
ErrorCode string `protobuf:"bytes,7,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
|
|
ErrorMessage string `protobuf:"bytes,8,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
|
|
OccurredAt *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
|
|
CorrelationId string `protobuf:"bytes,10,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
|
|
ActorId string `protobuf:"bytes,11,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
|
|
Blockchain *BlockchainReference `protobuf:"bytes,12,opt,name=blockchain,proto3" json:"blockchain,omitempty"`
|
|
Metadata map[string]string `protobuf:"bytes,13,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *AppendTransactionEventRequest) Reset() {
|
|
*x = AppendTransactionEventRequest{}
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[6]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *AppendTransactionEventRequest) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*AppendTransactionEventRequest) ProtoMessage() {}
|
|
|
|
func (x *AppendTransactionEventRequest) ProtoReflect() protoreflect.Message {
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[6]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use AppendTransactionEventRequest.ProtoReflect.Descriptor instead.
|
|
func (*AppendTransactionEventRequest) Descriptor() ([]byte, []int) {
|
|
return file_ledger_v1_msg_proto_rawDescGZIP(), []int{6}
|
|
}
|
|
|
|
func (x *AppendTransactionEventRequest) GetSourceService() string {
|
|
if x != nil {
|
|
return x.SourceService
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *AppendTransactionEventRequest) GetIdempotencyKey() string {
|
|
if x != nil {
|
|
return x.IdempotencyKey
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *AppendTransactionEventRequest) GetSourceTransactionId() string {
|
|
if x != nil {
|
|
return x.SourceTransactionId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *AppendTransactionEventRequest) GetTrackingCode() string {
|
|
if x != nil {
|
|
return x.TrackingCode
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *AppendTransactionEventRequest) GetEventVersion() uint32 {
|
|
if x != nil {
|
|
return x.EventVersion
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *AppendTransactionEventRequest) GetState() TransactionState {
|
|
if x != nil {
|
|
return x.State
|
|
}
|
|
return TransactionState_TRANSACTION_STATE_UNSPECIFIED
|
|
}
|
|
|
|
func (x *AppendTransactionEventRequest) GetErrorCode() string {
|
|
if x != nil {
|
|
return x.ErrorCode
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *AppendTransactionEventRequest) GetErrorMessage() string {
|
|
if x != nil {
|
|
return x.ErrorMessage
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *AppendTransactionEventRequest) GetOccurredAt() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.OccurredAt
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *AppendTransactionEventRequest) GetCorrelationId() string {
|
|
if x != nil {
|
|
return x.CorrelationId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *AppendTransactionEventRequest) GetActorId() string {
|
|
if x != nil {
|
|
return x.ActorId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *AppendTransactionEventRequest) GetBlockchain() *BlockchainReference {
|
|
if x != nil {
|
|
return x.Blockchain
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *AppendTransactionEventRequest) GetMetadata() map[string]string {
|
|
if x != nil {
|
|
return x.Metadata
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type TransactionEvent struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
EventId string `protobuf:"bytes,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
|
|
Event *AppendTransactionEventRequest `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
|
|
RecordedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=recorded_at,json=recordedAt,proto3" json:"recorded_at,omitempty"`
|
|
PayloadHash string `protobuf:"bytes,4,opt,name=payload_hash,json=payloadHash,proto3" json:"payload_hash,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *TransactionEvent) Reset() {
|
|
*x = TransactionEvent{}
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[7]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *TransactionEvent) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*TransactionEvent) ProtoMessage() {}
|
|
|
|
func (x *TransactionEvent) ProtoReflect() protoreflect.Message {
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[7]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use TransactionEvent.ProtoReflect.Descriptor instead.
|
|
func (*TransactionEvent) Descriptor() ([]byte, []int) {
|
|
return file_ledger_v1_msg_proto_rawDescGZIP(), []int{7}
|
|
}
|
|
|
|
func (x *TransactionEvent) GetEventId() string {
|
|
if x != nil {
|
|
return x.EventId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *TransactionEvent) GetEvent() *AppendTransactionEventRequest {
|
|
if x != nil {
|
|
return x.Event
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *TransactionEvent) GetRecordedAt() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.RecordedAt
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *TransactionEvent) GetPayloadHash() string {
|
|
if x != nil {
|
|
return x.PayloadHash
|
|
}
|
|
return ""
|
|
}
|
|
|
|
type AppendTransactionEventResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Event *TransactionEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
|
|
AlreadyExisted bool `protobuf:"varint,2,opt,name=already_existed,json=alreadyExisted,proto3" json:"already_existed,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *AppendTransactionEventResponse) Reset() {
|
|
*x = AppendTransactionEventResponse{}
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[8]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *AppendTransactionEventResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*AppendTransactionEventResponse) ProtoMessage() {}
|
|
|
|
func (x *AppendTransactionEventResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[8]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use AppendTransactionEventResponse.ProtoReflect.Descriptor instead.
|
|
func (*AppendTransactionEventResponse) Descriptor() ([]byte, []int) {
|
|
return file_ledger_v1_msg_proto_rawDescGZIP(), []int{8}
|
|
}
|
|
|
|
func (x *AppendTransactionEventResponse) GetEvent() *TransactionEvent {
|
|
if x != nil {
|
|
return x.Event
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *AppendTransactionEventResponse) GetAlreadyExisted() bool {
|
|
if x != nil {
|
|
return x.AlreadyExisted
|
|
}
|
|
return false
|
|
}
|
|
|
|
type GetJournalRequest struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// Types that are valid to be assigned to Lookup:
|
|
//
|
|
// *GetJournalRequest_JournalId
|
|
// *GetJournalRequest_IdempotencyKey
|
|
Lookup isGetJournalRequest_Lookup `protobuf_oneof:"lookup"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *GetJournalRequest) Reset() {
|
|
*x = GetJournalRequest{}
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[9]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *GetJournalRequest) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*GetJournalRequest) ProtoMessage() {}
|
|
|
|
func (x *GetJournalRequest) ProtoReflect() protoreflect.Message {
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[9]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use GetJournalRequest.ProtoReflect.Descriptor instead.
|
|
func (*GetJournalRequest) Descriptor() ([]byte, []int) {
|
|
return file_ledger_v1_msg_proto_rawDescGZIP(), []int{9}
|
|
}
|
|
|
|
func (x *GetJournalRequest) GetLookup() isGetJournalRequest_Lookup {
|
|
if x != nil {
|
|
return x.Lookup
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *GetJournalRequest) GetJournalId() string {
|
|
if x != nil {
|
|
if x, ok := x.Lookup.(*GetJournalRequest_JournalId); ok {
|
|
return x.JournalId
|
|
}
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *GetJournalRequest) GetIdempotencyKey() string {
|
|
if x != nil {
|
|
if x, ok := x.Lookup.(*GetJournalRequest_IdempotencyKey); ok {
|
|
return x.IdempotencyKey
|
|
}
|
|
}
|
|
return ""
|
|
}
|
|
|
|
type isGetJournalRequest_Lookup interface {
|
|
isGetJournalRequest_Lookup()
|
|
}
|
|
|
|
type GetJournalRequest_JournalId struct {
|
|
JournalId string `protobuf:"bytes,1,opt,name=journal_id,json=journalId,proto3,oneof"`
|
|
}
|
|
|
|
type GetJournalRequest_IdempotencyKey struct {
|
|
IdempotencyKey string `protobuf:"bytes,2,opt,name=idempotency_key,json=idempotencyKey,proto3,oneof"`
|
|
}
|
|
|
|
func (*GetJournalRequest_JournalId) isGetJournalRequest_Lookup() {}
|
|
|
|
func (*GetJournalRequest_IdempotencyKey) isGetJournalRequest_Lookup() {}
|
|
|
|
type ListEntriesRequest struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Account *AccountReference `protobuf:"bytes,1,opt,name=account,proto3,oneof" json:"account,omitempty"`
|
|
AssetId *int64 `protobuf:"varint,2,opt,name=asset_id,json=assetId,proto3,oneof" json:"asset_id,omitempty"`
|
|
RecordedFrom *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=recorded_from,json=recordedFrom,proto3" json:"recorded_from,omitempty"`
|
|
RecordedTo *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=recorded_to,json=recordedTo,proto3" json:"recorded_to,omitempty"`
|
|
PageSize uint32 `protobuf:"varint,5,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
|
|
PageToken string `protobuf:"bytes,6,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *ListEntriesRequest) Reset() {
|
|
*x = ListEntriesRequest{}
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[10]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *ListEntriesRequest) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*ListEntriesRequest) ProtoMessage() {}
|
|
|
|
func (x *ListEntriesRequest) ProtoReflect() protoreflect.Message {
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[10]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use ListEntriesRequest.ProtoReflect.Descriptor instead.
|
|
func (*ListEntriesRequest) Descriptor() ([]byte, []int) {
|
|
return file_ledger_v1_msg_proto_rawDescGZIP(), []int{10}
|
|
}
|
|
|
|
func (x *ListEntriesRequest) GetAccount() *AccountReference {
|
|
if x != nil {
|
|
return x.Account
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ListEntriesRequest) GetAssetId() int64 {
|
|
if x != nil && x.AssetId != nil {
|
|
return *x.AssetId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *ListEntriesRequest) GetRecordedFrom() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.RecordedFrom
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ListEntriesRequest) GetRecordedTo() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.RecordedTo
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ListEntriesRequest) GetPageSize() uint32 {
|
|
if x != nil {
|
|
return x.PageSize
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *ListEntriesRequest) GetPageToken() string {
|
|
if x != nil {
|
|
return x.PageToken
|
|
}
|
|
return ""
|
|
}
|
|
|
|
type ListEntriesResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Journals []*Journal `protobuf:"bytes,1,rep,name=journals,proto3" json:"journals,omitempty"`
|
|
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *ListEntriesResponse) Reset() {
|
|
*x = ListEntriesResponse{}
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[11]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *ListEntriesResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*ListEntriesResponse) ProtoMessage() {}
|
|
|
|
func (x *ListEntriesResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[11]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use ListEntriesResponse.ProtoReflect.Descriptor instead.
|
|
func (*ListEntriesResponse) Descriptor() ([]byte, []int) {
|
|
return file_ledger_v1_msg_proto_rawDescGZIP(), []int{11}
|
|
}
|
|
|
|
func (x *ListEntriesResponse) GetJournals() []*Journal {
|
|
if x != nil {
|
|
return x.Journals
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ListEntriesResponse) GetNextPageToken() string {
|
|
if x != nil {
|
|
return x.NextPageToken
|
|
}
|
|
return ""
|
|
}
|
|
|
|
type GetBalanceRequest struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Account *AccountReference `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
|
|
AsOf *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=as_of,json=asOf,proto3" json:"as_of,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *GetBalanceRequest) Reset() {
|
|
*x = GetBalanceRequest{}
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[12]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *GetBalanceRequest) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*GetBalanceRequest) ProtoMessage() {}
|
|
|
|
func (x *GetBalanceRequest) ProtoReflect() protoreflect.Message {
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[12]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use GetBalanceRequest.ProtoReflect.Descriptor instead.
|
|
func (*GetBalanceRequest) Descriptor() ([]byte, []int) {
|
|
return file_ledger_v1_msg_proto_rawDescGZIP(), []int{12}
|
|
}
|
|
|
|
func (x *GetBalanceRequest) GetAccount() *AccountReference {
|
|
if x != nil {
|
|
return x.Account
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *GetBalanceRequest) GetAsOf() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.AsOf
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type GetBalanceResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Account *AccountReference `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
|
|
// Canonical base-10 decimal reconstructed from immutable entries.
|
|
Balance string `protobuf:"bytes,2,opt,name=balance,proto3" json:"balance,omitempty"`
|
|
AsOf *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=as_of,json=asOf,proto3" json:"as_of,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *GetBalanceResponse) Reset() {
|
|
*x = GetBalanceResponse{}
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[13]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *GetBalanceResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*GetBalanceResponse) ProtoMessage() {}
|
|
|
|
func (x *GetBalanceResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[13]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use GetBalanceResponse.ProtoReflect.Descriptor instead.
|
|
func (*GetBalanceResponse) Descriptor() ([]byte, []int) {
|
|
return file_ledger_v1_msg_proto_rawDescGZIP(), []int{13}
|
|
}
|
|
|
|
func (x *GetBalanceResponse) GetAccount() *AccountReference {
|
|
if x != nil {
|
|
return x.Account
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *GetBalanceResponse) GetBalance() string {
|
|
if x != nil {
|
|
return x.Balance
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *GetBalanceResponse) GetAsOf() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.AsOf
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type ReplayJournalsRequest struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// Each item is independently atomic and uses normal append idempotency.
|
|
Journals []*AppendJournalRequest `protobuf:"bytes,1,rep,name=journals,proto3" json:"journals,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *ReplayJournalsRequest) Reset() {
|
|
*x = ReplayJournalsRequest{}
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[14]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *ReplayJournalsRequest) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*ReplayJournalsRequest) ProtoMessage() {}
|
|
|
|
func (x *ReplayJournalsRequest) ProtoReflect() protoreflect.Message {
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[14]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use ReplayJournalsRequest.ProtoReflect.Descriptor instead.
|
|
func (*ReplayJournalsRequest) Descriptor() ([]byte, []int) {
|
|
return file_ledger_v1_msg_proto_rawDescGZIP(), []int{14}
|
|
}
|
|
|
|
func (x *ReplayJournalsRequest) GetJournals() []*AppendJournalRequest {
|
|
if x != nil {
|
|
return x.Journals
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type ReplayJournalResult struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
IdempotencyKey string `protobuf:"bytes,1,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
|
|
Journal *Journal `protobuf:"bytes,2,opt,name=journal,proto3" json:"journal,omitempty"`
|
|
AlreadyExisted bool `protobuf:"varint,3,opt,name=already_existed,json=alreadyExisted,proto3" json:"already_existed,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *ReplayJournalResult) Reset() {
|
|
*x = ReplayJournalResult{}
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[15]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *ReplayJournalResult) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*ReplayJournalResult) ProtoMessage() {}
|
|
|
|
func (x *ReplayJournalResult) ProtoReflect() protoreflect.Message {
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[15]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use ReplayJournalResult.ProtoReflect.Descriptor instead.
|
|
func (*ReplayJournalResult) Descriptor() ([]byte, []int) {
|
|
return file_ledger_v1_msg_proto_rawDescGZIP(), []int{15}
|
|
}
|
|
|
|
func (x *ReplayJournalResult) GetIdempotencyKey() string {
|
|
if x != nil {
|
|
return x.IdempotencyKey
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *ReplayJournalResult) GetJournal() *Journal {
|
|
if x != nil {
|
|
return x.Journal
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ReplayJournalResult) GetAlreadyExisted() bool {
|
|
if x != nil {
|
|
return x.AlreadyExisted
|
|
}
|
|
return false
|
|
}
|
|
|
|
type ReplayJournalsResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Results []*ReplayJournalResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *ReplayJournalsResponse) Reset() {
|
|
*x = ReplayJournalsResponse{}
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[16]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *ReplayJournalsResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*ReplayJournalsResponse) ProtoMessage() {}
|
|
|
|
func (x *ReplayJournalsResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[16]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use ReplayJournalsResponse.ProtoReflect.Descriptor instead.
|
|
func (*ReplayJournalsResponse) Descriptor() ([]byte, []int) {
|
|
return file_ledger_v1_msg_proto_rawDescGZIP(), []int{16}
|
|
}
|
|
|
|
func (x *ReplayJournalsResponse) GetResults() []*ReplayJournalResult {
|
|
if x != nil {
|
|
return x.Results
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type HealthResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Serving bool `protobuf:"varint,1,opt,name=serving,proto3" json:"serving,omitempty"`
|
|
DatabaseReady bool `protobuf:"varint,2,opt,name=database_ready,json=databaseReady,proto3" json:"database_ready,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *HealthResponse) Reset() {
|
|
*x = HealthResponse{}
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[17]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *HealthResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*HealthResponse) ProtoMessage() {}
|
|
|
|
func (x *HealthResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_ledger_v1_msg_proto_msgTypes[17]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use HealthResponse.ProtoReflect.Descriptor instead.
|
|
func (*HealthResponse) Descriptor() ([]byte, []int) {
|
|
return file_ledger_v1_msg_proto_rawDescGZIP(), []int{17}
|
|
}
|
|
|
|
func (x *HealthResponse) GetServing() bool {
|
|
if x != nil {
|
|
return x.Serving
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *HealthResponse) GetDatabaseReady() bool {
|
|
if x != nil {
|
|
return x.DatabaseReady
|
|
}
|
|
return false
|
|
}
|
|
|
|
var File_ledger_v1_msg_proto protoreflect.FileDescriptor
|
|
|
|
const file_ledger_v1_msg_proto_rawDesc = "" +
|
|
"\n" +
|
|
"\x13ledger/v1/msg.proto\x12\tledger.v1\x1a\x1fgoogle/protobuf/timestamp.proto\"\xa5\x01\n" +
|
|
"\x10AccountReference\x12<\n" +
|
|
"\raccount_class\x18\x01 \x01(\x0e2\x17.ledger.v1.AccountClassR\faccountClass\x12\x1d\n" +
|
|
"\n" +
|
|
"owner_type\x18\x02 \x01(\tR\townerType\x12\x19\n" +
|
|
"\bowner_id\x18\x03 \x01(\tR\aownerId\x12\x19\n" +
|
|
"\basset_id\x18\x04 \x01(\x03R\aassetId\"\xa0\x01\n" +
|
|
"\fJournalEntry\x12\x1f\n" +
|
|
"\vline_number\x18\x01 \x01(\rR\n" +
|
|
"lineNumber\x125\n" +
|
|
"\aaccount\x18\x02 \x01(\v2\x1b.ledger.v1.AccountReferenceR\aaccount\x12\x16\n" +
|
|
"\x06amount\x18\x03 \x01(\tR\x06amount\x12 \n" +
|
|
"\vdescription\x18\x04 \x01(\tR\vdescription\"\x83\x01\n" +
|
|
"\x13BlockchainReference\x12\x18\n" +
|
|
"\anetwork\x18\x01 \x01(\tR\anetwork\x12)\n" +
|
|
"\x10transaction_hash\x18\x02 \x01(\tR\x0ftransactionHash\x12'\n" +
|
|
"\x0fledger_sequence\x18\x03 \x01(\tR\x0eledgerSequence\"\xb9\x06\n" +
|
|
"\aJournal\x12\x1d\n" +
|
|
"\n" +
|
|
"journal_id\x18\x01 \x01(\tR\tjournalId\x12%\n" +
|
|
"\x0esource_service\x18\x02 \x01(\tR\rsourceService\x12'\n" +
|
|
"\x0fidempotency_key\x18\x03 \x01(\tR\x0eidempotencyKey\x122\n" +
|
|
"\x15source_transaction_id\x18\x04 \x01(\tR\x13sourceTransactionId\x12#\n" +
|
|
"\rtracking_code\x18\x05 \x01(\tR\ftrackingCode\x12\x1f\n" +
|
|
"\veffect_kind\x18\x06 \x01(\tR\n" +
|
|
"effectKind\x12#\n" +
|
|
"\revent_version\x18\a \x01(\rR\feventVersion\x121\n" +
|
|
"\aentries\x18\b \x03(\v2\x17.ledger.v1.JournalEntryR\aentries\x128\n" +
|
|
"\x16reversal_of_journal_id\x18\t \x01(\tH\x00R\x13reversalOfJournalId\x88\x01\x01\x12;\n" +
|
|
"\voccurred_at\x18\n" +
|
|
" \x01(\v2\x1a.google.protobuf.TimestampR\n" +
|
|
"occurredAt\x12;\n" +
|
|
"\vrecorded_at\x18\v \x01(\v2\x1a.google.protobuf.TimestampR\n" +
|
|
"recordedAt\x12%\n" +
|
|
"\x0ecorrelation_id\x18\f \x01(\tR\rcorrelationId\x12\x19\n" +
|
|
"\bactor_id\x18\r \x01(\tR\aactorId\x12>\n" +
|
|
"\n" +
|
|
"blockchain\x18\x0e \x01(\v2\x1e.ledger.v1.BlockchainReferenceR\n" +
|
|
"blockchain\x12<\n" +
|
|
"\bmetadata\x18\x0f \x03(\v2 .ledger.v1.Journal.MetadataEntryR\bmetadata\x12!\n" +
|
|
"\fpayload_hash\x18\x10 \x01(\tR\vpayloadHash\x1a;\n" +
|
|
"\rMetadataEntry\x12\x10\n" +
|
|
"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
|
|
"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01B\x19\n" +
|
|
"\x17_reversal_of_journal_id\"\xd4\x05\n" +
|
|
"\x14AppendJournalRequest\x12%\n" +
|
|
"\x0esource_service\x18\x01 \x01(\tR\rsourceService\x12'\n" +
|
|
"\x0fidempotency_key\x18\x02 \x01(\tR\x0eidempotencyKey\x122\n" +
|
|
"\x15source_transaction_id\x18\x03 \x01(\tR\x13sourceTransactionId\x12#\n" +
|
|
"\rtracking_code\x18\x04 \x01(\tR\ftrackingCode\x12\x1f\n" +
|
|
"\veffect_kind\x18\x05 \x01(\tR\n" +
|
|
"effectKind\x12#\n" +
|
|
"\revent_version\x18\x06 \x01(\rR\feventVersion\x121\n" +
|
|
"\aentries\x18\a \x03(\v2\x17.ledger.v1.JournalEntryR\aentries\x128\n" +
|
|
"\x16reversal_of_journal_id\x18\b \x01(\tH\x00R\x13reversalOfJournalId\x88\x01\x01\x12;\n" +
|
|
"\voccurred_at\x18\t \x01(\v2\x1a.google.protobuf.TimestampR\n" +
|
|
"occurredAt\x12%\n" +
|
|
"\x0ecorrelation_id\x18\n" +
|
|
" \x01(\tR\rcorrelationId\x12\x19\n" +
|
|
"\bactor_id\x18\v \x01(\tR\aactorId\x12>\n" +
|
|
"\n" +
|
|
"blockchain\x18\f \x01(\v2\x1e.ledger.v1.BlockchainReferenceR\n" +
|
|
"blockchain\x12I\n" +
|
|
"\bmetadata\x18\r \x03(\v2-.ledger.v1.AppendJournalRequest.MetadataEntryR\bmetadata\x1a;\n" +
|
|
"\rMetadataEntry\x12\x10\n" +
|
|
"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
|
|
"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01B\x19\n" +
|
|
"\x17_reversal_of_journal_id\"n\n" +
|
|
"\x15AppendJournalResponse\x12,\n" +
|
|
"\ajournal\x18\x01 \x01(\v2\x12.ledger.v1.JournalR\ajournal\x12'\n" +
|
|
"\x0falready_existed\x18\x02 \x01(\bR\x0ealreadyExisted\"\xb4\x05\n" +
|
|
"\x1dAppendTransactionEventRequest\x12%\n" +
|
|
"\x0esource_service\x18\x01 \x01(\tR\rsourceService\x12'\n" +
|
|
"\x0fidempotency_key\x18\x02 \x01(\tR\x0eidempotencyKey\x122\n" +
|
|
"\x15source_transaction_id\x18\x03 \x01(\tR\x13sourceTransactionId\x12#\n" +
|
|
"\rtracking_code\x18\x04 \x01(\tR\ftrackingCode\x12#\n" +
|
|
"\revent_version\x18\x05 \x01(\rR\feventVersion\x121\n" +
|
|
"\x05state\x18\x06 \x01(\x0e2\x1b.ledger.v1.TransactionStateR\x05state\x12\x1d\n" +
|
|
"\n" +
|
|
"error_code\x18\a \x01(\tR\terrorCode\x12#\n" +
|
|
"\rerror_message\x18\b \x01(\tR\ferrorMessage\x12;\n" +
|
|
"\voccurred_at\x18\t \x01(\v2\x1a.google.protobuf.TimestampR\n" +
|
|
"occurredAt\x12%\n" +
|
|
"\x0ecorrelation_id\x18\n" +
|
|
" \x01(\tR\rcorrelationId\x12\x19\n" +
|
|
"\bactor_id\x18\v \x01(\tR\aactorId\x12>\n" +
|
|
"\n" +
|
|
"blockchain\x18\f \x01(\v2\x1e.ledger.v1.BlockchainReferenceR\n" +
|
|
"blockchain\x12R\n" +
|
|
"\bmetadata\x18\r \x03(\v26.ledger.v1.AppendTransactionEventRequest.MetadataEntryR\bmetadata\x1a;\n" +
|
|
"\rMetadataEntry\x12\x10\n" +
|
|
"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
|
|
"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\"\xcd\x01\n" +
|
|
"\x10TransactionEvent\x12\x19\n" +
|
|
"\bevent_id\x18\x01 \x01(\tR\aeventId\x12>\n" +
|
|
"\x05event\x18\x02 \x01(\v2(.ledger.v1.AppendTransactionEventRequestR\x05event\x12;\n" +
|
|
"\vrecorded_at\x18\x03 \x01(\v2\x1a.google.protobuf.TimestampR\n" +
|
|
"recordedAt\x12!\n" +
|
|
"\fpayload_hash\x18\x04 \x01(\tR\vpayloadHash\"|\n" +
|
|
"\x1eAppendTransactionEventResponse\x121\n" +
|
|
"\x05event\x18\x01 \x01(\v2\x1b.ledger.v1.TransactionEventR\x05event\x12'\n" +
|
|
"\x0falready_existed\x18\x02 \x01(\bR\x0ealreadyExisted\"i\n" +
|
|
"\x11GetJournalRequest\x12\x1f\n" +
|
|
"\n" +
|
|
"journal_id\x18\x01 \x01(\tH\x00R\tjournalId\x12)\n" +
|
|
"\x0fidempotency_key\x18\x02 \x01(\tH\x00R\x0eidempotencyKeyB\b\n" +
|
|
"\x06lookup\"\xc3\x02\n" +
|
|
"\x12ListEntriesRequest\x12:\n" +
|
|
"\aaccount\x18\x01 \x01(\v2\x1b.ledger.v1.AccountReferenceH\x00R\aaccount\x88\x01\x01\x12\x1e\n" +
|
|
"\basset_id\x18\x02 \x01(\x03H\x01R\aassetId\x88\x01\x01\x12?\n" +
|
|
"\rrecorded_from\x18\x03 \x01(\v2\x1a.google.protobuf.TimestampR\frecordedFrom\x12;\n" +
|
|
"\vrecorded_to\x18\x04 \x01(\v2\x1a.google.protobuf.TimestampR\n" +
|
|
"recordedTo\x12\x1b\n" +
|
|
"\tpage_size\x18\x05 \x01(\rR\bpageSize\x12\x1d\n" +
|
|
"\n" +
|
|
"page_token\x18\x06 \x01(\tR\tpageTokenB\n" +
|
|
"\n" +
|
|
"\b_accountB\v\n" +
|
|
"\t_asset_id\"m\n" +
|
|
"\x13ListEntriesResponse\x12.\n" +
|
|
"\bjournals\x18\x01 \x03(\v2\x12.ledger.v1.JournalR\bjournals\x12&\n" +
|
|
"\x0fnext_page_token\x18\x02 \x01(\tR\rnextPageToken\"{\n" +
|
|
"\x11GetBalanceRequest\x125\n" +
|
|
"\aaccount\x18\x01 \x01(\v2\x1b.ledger.v1.AccountReferenceR\aaccount\x12/\n" +
|
|
"\x05as_of\x18\x02 \x01(\v2\x1a.google.protobuf.TimestampR\x04asOf\"\x96\x01\n" +
|
|
"\x12GetBalanceResponse\x125\n" +
|
|
"\aaccount\x18\x01 \x01(\v2\x1b.ledger.v1.AccountReferenceR\aaccount\x12\x18\n" +
|
|
"\abalance\x18\x02 \x01(\tR\abalance\x12/\n" +
|
|
"\x05as_of\x18\x03 \x01(\v2\x1a.google.protobuf.TimestampR\x04asOf\"T\n" +
|
|
"\x15ReplayJournalsRequest\x12;\n" +
|
|
"\bjournals\x18\x01 \x03(\v2\x1f.ledger.v1.AppendJournalRequestR\bjournals\"\x95\x01\n" +
|
|
"\x13ReplayJournalResult\x12'\n" +
|
|
"\x0fidempotency_key\x18\x01 \x01(\tR\x0eidempotencyKey\x12,\n" +
|
|
"\ajournal\x18\x02 \x01(\v2\x12.ledger.v1.JournalR\ajournal\x12'\n" +
|
|
"\x0falready_existed\x18\x03 \x01(\bR\x0ealreadyExisted\"R\n" +
|
|
"\x16ReplayJournalsResponse\x128\n" +
|
|
"\aresults\x18\x01 \x03(\v2\x1e.ledger.v1.ReplayJournalResultR\aresults\"Q\n" +
|
|
"\x0eHealthResponse\x12\x18\n" +
|
|
"\aserving\x18\x01 \x01(\bR\aserving\x12%\n" +
|
|
"\x0edatabase_ready\x18\x02 \x01(\bR\rdatabaseReady*\x9a\x02\n" +
|
|
"\fAccountClass\x12\x1d\n" +
|
|
"\x19ACCOUNT_CLASS_UNSPECIFIED\x10\x00\x12 \n" +
|
|
"\x1cACCOUNT_CLASS_USER_AVAILABLE\x10\x01\x12\x1d\n" +
|
|
"\x19ACCOUNT_CLASS_USER_FROZEN\x10\x02\x12%\n" +
|
|
"!ACCOUNT_CLASS_EXTERNAL_BLOCKCHAIN\x10\x03\x12\x1a\n" +
|
|
"\x16ACCOUNT_CLASS_TREASURY\x10\x04\x12!\n" +
|
|
"\x1dACCOUNT_CLASS_MARKET_CLEARING\x10\x05\x12\x1e\n" +
|
|
"\x1aACCOUNT_CLASS_IPG_CLEARING\x10\x06\x12$\n" +
|
|
" ACCOUNT_CLASS_COMMISSION_REVENUE\x10\a*\x85\x02\n" +
|
|
"\x10TransactionState\x12!\n" +
|
|
"\x1dTRANSACTION_STATE_UNSPECIFIED\x10\x00\x12\x1d\n" +
|
|
"\x19TRANSACTION_STATE_CREATED\x10\x01\x12)\n" +
|
|
"%TRANSACTION_STATE_PENDING_TRANSACTION\x10\x02\x12#\n" +
|
|
"\x1fTRANSACTION_STATE_PENDING_ADMIN\x10\x03\x12 \n" +
|
|
"\x1cTRANSACTION_STATE_SUCCESSFUL\x10\x04\x12\x1c\n" +
|
|
"\x18TRANSACTION_STATE_FAILED\x10\x05\x12\x1f\n" +
|
|
"\x1bTRANSACTION_STATE_SUSPENDED\x10\x06By\n" +
|
|
"\rcom.ledger.v1B\bMsgProtoP\x01Z\x19gl/gen/ledger/v1;ledgerv1\xa2\x02\x03LXX\xaa\x02\tLedger.V1\xca\x02\tLedger\\V1\xe2\x02\x15Ledger\\V1\\GPBMetadata\xea\x02\n" +
|
|
"Ledger::V1b\x06proto3"
|
|
|
|
var (
|
|
file_ledger_v1_msg_proto_rawDescOnce sync.Once
|
|
file_ledger_v1_msg_proto_rawDescData []byte
|
|
)
|
|
|
|
func file_ledger_v1_msg_proto_rawDescGZIP() []byte {
|
|
file_ledger_v1_msg_proto_rawDescOnce.Do(func() {
|
|
file_ledger_v1_msg_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_ledger_v1_msg_proto_rawDesc), len(file_ledger_v1_msg_proto_rawDesc)))
|
|
})
|
|
return file_ledger_v1_msg_proto_rawDescData
|
|
}
|
|
|
|
var file_ledger_v1_msg_proto_enumTypes = make([]protoimpl.EnumInfo, 2)
|
|
var file_ledger_v1_msg_proto_msgTypes = make([]protoimpl.MessageInfo, 21)
|
|
var file_ledger_v1_msg_proto_goTypes = []any{
|
|
(AccountClass)(0), // 0: ledger.v1.AccountClass
|
|
(TransactionState)(0), // 1: ledger.v1.TransactionState
|
|
(*AccountReference)(nil), // 2: ledger.v1.AccountReference
|
|
(*JournalEntry)(nil), // 3: ledger.v1.JournalEntry
|
|
(*BlockchainReference)(nil), // 4: ledger.v1.BlockchainReference
|
|
(*Journal)(nil), // 5: ledger.v1.Journal
|
|
(*AppendJournalRequest)(nil), // 6: ledger.v1.AppendJournalRequest
|
|
(*AppendJournalResponse)(nil), // 7: ledger.v1.AppendJournalResponse
|
|
(*AppendTransactionEventRequest)(nil), // 8: ledger.v1.AppendTransactionEventRequest
|
|
(*TransactionEvent)(nil), // 9: ledger.v1.TransactionEvent
|
|
(*AppendTransactionEventResponse)(nil), // 10: ledger.v1.AppendTransactionEventResponse
|
|
(*GetJournalRequest)(nil), // 11: ledger.v1.GetJournalRequest
|
|
(*ListEntriesRequest)(nil), // 12: ledger.v1.ListEntriesRequest
|
|
(*ListEntriesResponse)(nil), // 13: ledger.v1.ListEntriesResponse
|
|
(*GetBalanceRequest)(nil), // 14: ledger.v1.GetBalanceRequest
|
|
(*GetBalanceResponse)(nil), // 15: ledger.v1.GetBalanceResponse
|
|
(*ReplayJournalsRequest)(nil), // 16: ledger.v1.ReplayJournalsRequest
|
|
(*ReplayJournalResult)(nil), // 17: ledger.v1.ReplayJournalResult
|
|
(*ReplayJournalsResponse)(nil), // 18: ledger.v1.ReplayJournalsResponse
|
|
(*HealthResponse)(nil), // 19: ledger.v1.HealthResponse
|
|
nil, // 20: ledger.v1.Journal.MetadataEntry
|
|
nil, // 21: ledger.v1.AppendJournalRequest.MetadataEntry
|
|
nil, // 22: ledger.v1.AppendTransactionEventRequest.MetadataEntry
|
|
(*timestamppb.Timestamp)(nil), // 23: google.protobuf.Timestamp
|
|
}
|
|
var file_ledger_v1_msg_proto_depIdxs = []int32{
|
|
0, // 0: ledger.v1.AccountReference.account_class:type_name -> ledger.v1.AccountClass
|
|
2, // 1: ledger.v1.JournalEntry.account:type_name -> ledger.v1.AccountReference
|
|
3, // 2: ledger.v1.Journal.entries:type_name -> ledger.v1.JournalEntry
|
|
23, // 3: ledger.v1.Journal.occurred_at:type_name -> google.protobuf.Timestamp
|
|
23, // 4: ledger.v1.Journal.recorded_at:type_name -> google.protobuf.Timestamp
|
|
4, // 5: ledger.v1.Journal.blockchain:type_name -> ledger.v1.BlockchainReference
|
|
20, // 6: ledger.v1.Journal.metadata:type_name -> ledger.v1.Journal.MetadataEntry
|
|
3, // 7: ledger.v1.AppendJournalRequest.entries:type_name -> ledger.v1.JournalEntry
|
|
23, // 8: ledger.v1.AppendJournalRequest.occurred_at:type_name -> google.protobuf.Timestamp
|
|
4, // 9: ledger.v1.AppendJournalRequest.blockchain:type_name -> ledger.v1.BlockchainReference
|
|
21, // 10: ledger.v1.AppendJournalRequest.metadata:type_name -> ledger.v1.AppendJournalRequest.MetadataEntry
|
|
5, // 11: ledger.v1.AppendJournalResponse.journal:type_name -> ledger.v1.Journal
|
|
1, // 12: ledger.v1.AppendTransactionEventRequest.state:type_name -> ledger.v1.TransactionState
|
|
23, // 13: ledger.v1.AppendTransactionEventRequest.occurred_at:type_name -> google.protobuf.Timestamp
|
|
4, // 14: ledger.v1.AppendTransactionEventRequest.blockchain:type_name -> ledger.v1.BlockchainReference
|
|
22, // 15: ledger.v1.AppendTransactionEventRequest.metadata:type_name -> ledger.v1.AppendTransactionEventRequest.MetadataEntry
|
|
8, // 16: ledger.v1.TransactionEvent.event:type_name -> ledger.v1.AppendTransactionEventRequest
|
|
23, // 17: ledger.v1.TransactionEvent.recorded_at:type_name -> google.protobuf.Timestamp
|
|
9, // 18: ledger.v1.AppendTransactionEventResponse.event:type_name -> ledger.v1.TransactionEvent
|
|
2, // 19: ledger.v1.ListEntriesRequest.account:type_name -> ledger.v1.AccountReference
|
|
23, // 20: ledger.v1.ListEntriesRequest.recorded_from:type_name -> google.protobuf.Timestamp
|
|
23, // 21: ledger.v1.ListEntriesRequest.recorded_to:type_name -> google.protobuf.Timestamp
|
|
5, // 22: ledger.v1.ListEntriesResponse.journals:type_name -> ledger.v1.Journal
|
|
2, // 23: ledger.v1.GetBalanceRequest.account:type_name -> ledger.v1.AccountReference
|
|
23, // 24: ledger.v1.GetBalanceRequest.as_of:type_name -> google.protobuf.Timestamp
|
|
2, // 25: ledger.v1.GetBalanceResponse.account:type_name -> ledger.v1.AccountReference
|
|
23, // 26: ledger.v1.GetBalanceResponse.as_of:type_name -> google.protobuf.Timestamp
|
|
6, // 27: ledger.v1.ReplayJournalsRequest.journals:type_name -> ledger.v1.AppendJournalRequest
|
|
5, // 28: ledger.v1.ReplayJournalResult.journal:type_name -> ledger.v1.Journal
|
|
17, // 29: ledger.v1.ReplayJournalsResponse.results:type_name -> ledger.v1.ReplayJournalResult
|
|
30, // [30:30] is the sub-list for method output_type
|
|
30, // [30:30] is the sub-list for method input_type
|
|
30, // [30:30] is the sub-list for extension type_name
|
|
30, // [30:30] is the sub-list for extension extendee
|
|
0, // [0:30] is the sub-list for field type_name
|
|
}
|
|
|
|
func init() { file_ledger_v1_msg_proto_init() }
|
|
func file_ledger_v1_msg_proto_init() {
|
|
if File_ledger_v1_msg_proto != nil {
|
|
return
|
|
}
|
|
file_ledger_v1_msg_proto_msgTypes[3].OneofWrappers = []any{}
|
|
file_ledger_v1_msg_proto_msgTypes[4].OneofWrappers = []any{}
|
|
file_ledger_v1_msg_proto_msgTypes[9].OneofWrappers = []any{
|
|
(*GetJournalRequest_JournalId)(nil),
|
|
(*GetJournalRequest_IdempotencyKey)(nil),
|
|
}
|
|
file_ledger_v1_msg_proto_msgTypes[10].OneofWrappers = []any{}
|
|
type x struct{}
|
|
out := protoimpl.TypeBuilder{
|
|
File: protoimpl.DescBuilder{
|
|
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
|
|
RawDescriptor: unsafe.Slice(unsafe.StringData(file_ledger_v1_msg_proto_rawDesc), len(file_ledger_v1_msg_proto_rawDesc)),
|
|
NumEnums: 2,
|
|
NumMessages: 21,
|
|
NumExtensions: 0,
|
|
NumServices: 0,
|
|
},
|
|
GoTypes: file_ledger_v1_msg_proto_goTypes,
|
|
DependencyIndexes: file_ledger_v1_msg_proto_depIdxs,
|
|
EnumInfos: file_ledger_v1_msg_proto_enumTypes,
|
|
MessageInfos: file_ledger_v1_msg_proto_msgTypes,
|
|
}.Build()
|
|
File_ledger_v1_msg_proto = out.File
|
|
file_ledger_v1_msg_proto_goTypes = nil
|
|
file_ledger_v1_msg_proto_depIdxs = nil
|
|
}
|