Kahroba/GL
SHA256
8
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Files
feat/refactor-v1
GL/gen/ledger/v1/msg.pb.go
T

1768 lines
58 KiB
Go
Raw Permalink Blame History

// 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
}
Reference in New Issue View Git Blame Copy Permalink