Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterCommandCompletionServiceServer(s grpc.ServiceRegistrar, srv CommandCompletionServiceServer)
- func RegisterCommandServiceServer(s grpc.ServiceRegistrar, srv CommandServiceServer)
- func RegisterCommandSubmissionServiceServer(s grpc.ServiceRegistrar, srv CommandSubmissionServiceServer)
- func RegisterEventQueryServiceServer(s grpc.ServiceRegistrar, srv EventQueryServiceServer)
- func RegisterPackageServiceServer(s grpc.ServiceRegistrar, srv PackageServiceServer)
- func RegisterStateServiceServer(s grpc.ServiceRegistrar, srv StateServiceServer)
- func RegisterUpdateServiceServer(s grpc.ServiceRegistrar, srv UpdateServiceServer)
- func RegisterVersionServiceServer(s grpc.ServiceRegistrar, srv VersionServiceServer)
- type ActiveContract
- func (*ActiveContract) Descriptor() ([]byte, []int)deprecated
- func (x *ActiveContract) GetCreatedEvent() *CreatedEvent
- func (x *ActiveContract) GetReassignmentCounter() uint64
- func (x *ActiveContract) GetSynchronizerId() string
- func (*ActiveContract) ProtoMessage()
- func (x *ActiveContract) ProtoReflect() protoreflect.Message
- func (x *ActiveContract) Reset()
- func (x *ActiveContract) String() string
- type Archived
- func (*Archived) Descriptor() ([]byte, []int)deprecated
- func (x *Archived) GetArchivedEvent() *ArchivedEvent
- func (x *Archived) GetSynchronizerId() string
- func (*Archived) ProtoMessage()
- func (x *Archived) ProtoReflect() protoreflect.Message
- func (x *Archived) Reset()
- func (x *Archived) String() string
- type ArchivedEvent
- func (*ArchivedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ArchivedEvent) GetContractId() string
- func (x *ArchivedEvent) GetImplementedInterfaces() []*Identifier
- func (x *ArchivedEvent) GetNodeId() int32
- func (x *ArchivedEvent) GetOffset() int64
- func (x *ArchivedEvent) GetPackageName() string
- func (x *ArchivedEvent) GetTemplateId() *Identifier
- func (x *ArchivedEvent) GetWitnessParties() []string
- func (*ArchivedEvent) ProtoMessage()
- func (x *ArchivedEvent) ProtoReflect() protoreflect.Message
- func (x *ArchivedEvent) Reset()
- func (x *ArchivedEvent) String() string
- type AssignCommand
- func (*AssignCommand) Descriptor() ([]byte, []int)deprecated
- func (x *AssignCommand) GetReassignmentId() string
- func (x *AssignCommand) GetSource() string
- func (x *AssignCommand) GetTarget() string
- func (*AssignCommand) ProtoMessage()
- func (x *AssignCommand) ProtoReflect() protoreflect.Message
- func (x *AssignCommand) Reset()
- func (x *AssignCommand) String() string
- type AssignedEvent
- func (*AssignedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *AssignedEvent) GetCreatedEvent() *CreatedEvent
- func (x *AssignedEvent) GetReassignmentCounter() uint64
- func (x *AssignedEvent) GetReassignmentId() string
- func (x *AssignedEvent) GetSource() string
- func (x *AssignedEvent) GetSubmitter() string
- func (x *AssignedEvent) GetTarget() string
- func (*AssignedEvent) ProtoMessage()
- func (x *AssignedEvent) ProtoReflect() protoreflect.Message
- func (x *AssignedEvent) Reset()
- func (x *AssignedEvent) String() string
- type Command
- func (*Command) Descriptor() ([]byte, []int)deprecated
- func (x *Command) GetCommand() isCommand_Command
- func (x *Command) GetCreate() *CreateCommand
- func (x *Command) GetCreateAndExercise() *CreateAndExerciseCommand
- func (x *Command) GetExercise() *ExerciseCommand
- func (x *Command) GetExerciseByKey() *ExerciseByKeyCommand
- func (*Command) ProtoMessage()
- func (x *Command) ProtoReflect() protoreflect.Message
- func (x *Command) Reset()
- func (x *Command) String() string
- type CommandCompletionServiceClient
- type CommandCompletionServiceServer
- type CommandCompletionService_CompletionStreamClient
- type CommandCompletionService_CompletionStreamServer
- type CommandServiceClient
- type CommandServiceServer
- type CommandSubmissionServiceClient
- type CommandSubmissionServiceServer
- type Command_Create
- type Command_CreateAndExercise
- type Command_Exercise
- type Command_ExerciseByKey
- type Commands
- func (*Commands) Descriptor() ([]byte, []int)deprecated
- func (x *Commands) GetActAs() []string
- func (x *Commands) GetCommandId() string
- func (x *Commands) GetCommands() []*Command
- func (x *Commands) GetDeduplicationDuration() *durationpb.Duration
- func (x *Commands) GetDeduplicationOffset() int64
- func (x *Commands) GetDeduplicationPeriod() isCommands_DeduplicationPeriod
- func (x *Commands) GetDisclosedContracts() []*DisclosedContract
- func (x *Commands) GetMinLedgerTimeAbs() *timestamppb.Timestamp
- func (x *Commands) GetMinLedgerTimeRel() *durationpb.Duration
- func (x *Commands) GetPackageIdSelectionPreference() []string
- func (x *Commands) GetPrefetchContractKeys() []*PrefetchContractKey
- func (x *Commands) GetReadAs() []string
- func (x *Commands) GetSubmissionId() string
- func (x *Commands) GetSynchronizerId() string
- func (x *Commands) GetUserId() string
- func (x *Commands) GetWorkflowId() string
- func (*Commands) ProtoMessage()
- func (x *Commands) ProtoReflect() protoreflect.Message
- func (x *Commands) Reset()
- func (x *Commands) String() string
- type Commands_DeduplicationDuration
- type Commands_DeduplicationOffset
- type Completion
- func (*Completion) Descriptor() ([]byte, []int)deprecated
- func (x *Completion) GetActAs() []string
- func (x *Completion) GetCommandId() string
- func (x *Completion) GetDeduplicationDuration() *durationpb.Duration
- func (x *Completion) GetDeduplicationOffset() int64
- func (x *Completion) GetDeduplicationPeriod() isCompletion_DeduplicationPeriod
- func (x *Completion) GetOffset() int64
- func (x *Completion) GetStatus() *status.Status
- func (x *Completion) GetSubmissionId() string
- func (x *Completion) GetSynchronizerTime() *SynchronizerTime
- func (x *Completion) GetTraceContext() *TraceContext
- func (x *Completion) GetUpdateId() string
- func (x *Completion) GetUserId() string
- func (*Completion) ProtoMessage()
- func (x *Completion) ProtoReflect() protoreflect.Message
- func (x *Completion) Reset()
- func (x *Completion) String() string
- type CompletionStreamRequest
- func (*CompletionStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CompletionStreamRequest) GetBeginExclusive() int64
- func (x *CompletionStreamRequest) GetParties() []string
- func (x *CompletionStreamRequest) GetUserId() string
- func (*CompletionStreamRequest) ProtoMessage()
- func (x *CompletionStreamRequest) ProtoReflect() protoreflect.Message
- func (x *CompletionStreamRequest) Reset()
- func (x *CompletionStreamRequest) String() string
- type CompletionStreamResponse
- func (*CompletionStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CompletionStreamResponse) GetCompletion() *Completion
- func (x *CompletionStreamResponse) GetCompletionResponse() isCompletionStreamResponse_CompletionResponse
- func (x *CompletionStreamResponse) GetOffsetCheckpoint() *OffsetCheckpoint
- func (*CompletionStreamResponse) ProtoMessage()
- func (x *CompletionStreamResponse) ProtoReflect() protoreflect.Message
- func (x *CompletionStreamResponse) Reset()
- func (x *CompletionStreamResponse) String() string
- type CompletionStreamResponse_Completion
- type CompletionStreamResponse_OffsetCheckpoint
- type Completion_DeduplicationDuration
- type Completion_DeduplicationOffset
- type CreateAndExerciseCommand
- func (*CreateAndExerciseCommand) Descriptor() ([]byte, []int)deprecated
- func (x *CreateAndExerciseCommand) GetChoice() string
- func (x *CreateAndExerciseCommand) GetChoiceArgument() *Value
- func (x *CreateAndExerciseCommand) GetCreateArguments() *Record
- func (x *CreateAndExerciseCommand) GetTemplateId() *Identifier
- func (*CreateAndExerciseCommand) ProtoMessage()
- func (x *CreateAndExerciseCommand) ProtoReflect() protoreflect.Message
- func (x *CreateAndExerciseCommand) Reset()
- func (x *CreateAndExerciseCommand) String() string
- type CreateCommand
- func (*CreateCommand) Descriptor() ([]byte, []int)deprecated
- func (x *CreateCommand) GetCreateArguments() *Record
- func (x *CreateCommand) GetTemplateId() *Identifier
- func (*CreateCommand) ProtoMessage()
- func (x *CreateCommand) ProtoReflect() protoreflect.Message
- func (x *CreateCommand) Reset()
- func (x *CreateCommand) String() string
- type Created
- type CreatedEvent
- func (*CreatedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *CreatedEvent) GetAcsDelta() bool
- func (x *CreatedEvent) GetContractId() string
- func (x *CreatedEvent) GetContractKey() *Value
- func (x *CreatedEvent) GetCreateArguments() *Record
- func (x *CreatedEvent) GetCreatedAt() *timestamppb.Timestamp
- func (x *CreatedEvent) GetCreatedEventBlob() []byte
- func (x *CreatedEvent) GetInterfaceViews() []*InterfaceView
- func (x *CreatedEvent) GetNodeId() int32
- func (x *CreatedEvent) GetObservers() []string
- func (x *CreatedEvent) GetOffset() int64
- func (x *CreatedEvent) GetPackageName() string
- func (x *CreatedEvent) GetRepresentativePackageId() string
- func (x *CreatedEvent) GetSignatories() []string
- func (x *CreatedEvent) GetTemplateId() *Identifier
- func (x *CreatedEvent) GetWitnessParties() []string
- func (*CreatedEvent) ProtoMessage()
- func (x *CreatedEvent) ProtoReflect() protoreflect.Message
- func (x *CreatedEvent) Reset()
- func (x *CreatedEvent) String() string
- type CryptoKeyFormat
- func (CryptoKeyFormat) Descriptor() protoreflect.EnumDescriptor
- func (x CryptoKeyFormat) Enum() *CryptoKeyFormat
- func (CryptoKeyFormat) EnumDescriptor() ([]byte, []int)deprecated
- func (x CryptoKeyFormat) Number() protoreflect.EnumNumber
- func (x CryptoKeyFormat) String() string
- func (CryptoKeyFormat) Type() protoreflect.EnumType
- type CumulativeFilter
- func (*CumulativeFilter) Descriptor() ([]byte, []int)deprecated
- func (x *CumulativeFilter) GetIdentifierFilter() isCumulativeFilter_IdentifierFilter
- func (x *CumulativeFilter) GetInterfaceFilter() *InterfaceFilter
- func (x *CumulativeFilter) GetTemplateFilter() *TemplateFilter
- func (x *CumulativeFilter) GetWildcardFilter() *WildcardFilter
- func (*CumulativeFilter) ProtoMessage()
- func (x *CumulativeFilter) ProtoReflect() protoreflect.Message
- func (x *CumulativeFilter) Reset()
- func (x *CumulativeFilter) String() string
- type CumulativeFilter_InterfaceFilter
- type CumulativeFilter_TemplateFilter
- type CumulativeFilter_WildcardFilter
- type DisclosedContract
- func (*DisclosedContract) Descriptor() ([]byte, []int)deprecated
- func (x *DisclosedContract) GetContractId() string
- func (x *DisclosedContract) GetCreatedEventBlob() []byte
- func (x *DisclosedContract) GetSynchronizerId() string
- func (x *DisclosedContract) GetTemplateId() *Identifier
- func (*DisclosedContract) ProtoMessage()
- func (x *DisclosedContract) ProtoReflect() protoreflect.Message
- func (x *DisclosedContract) Reset()
- func (x *DisclosedContract) String() string
- type Enum
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetArchived() *ArchivedEvent
- func (x *Event) GetCreated() *CreatedEvent
- func (x *Event) GetEvent() isEvent_Event
- func (x *Event) GetExercised() *ExercisedEvent
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) String() string
- type EventFormat
- func (*EventFormat) Descriptor() ([]byte, []int)deprecated
- func (x *EventFormat) GetFiltersByParty() map[string]*Filters
- func (x *EventFormat) GetFiltersForAnyParty() *Filters
- func (x *EventFormat) GetVerbose() bool
- func (*EventFormat) ProtoMessage()
- func (x *EventFormat) ProtoReflect() protoreflect.Message
- func (x *EventFormat) Reset()
- func (x *EventFormat) String() string
- type EventQueryServiceClient
- type EventQueryServiceServer
- type Event_Archived
- type Event_Created
- type Event_Exercised
- type ExerciseByKeyCommand
- func (*ExerciseByKeyCommand) Descriptor() ([]byte, []int)deprecated
- func (x *ExerciseByKeyCommand) GetChoice() string
- func (x *ExerciseByKeyCommand) GetChoiceArgument() *Value
- func (x *ExerciseByKeyCommand) GetContractKey() *Value
- func (x *ExerciseByKeyCommand) GetTemplateId() *Identifier
- func (*ExerciseByKeyCommand) ProtoMessage()
- func (x *ExerciseByKeyCommand) ProtoReflect() protoreflect.Message
- func (x *ExerciseByKeyCommand) Reset()
- func (x *ExerciseByKeyCommand) String() string
- type ExerciseCommand
- func (*ExerciseCommand) Descriptor() ([]byte, []int)deprecated
- func (x *ExerciseCommand) GetChoice() string
- func (x *ExerciseCommand) GetChoiceArgument() *Value
- func (x *ExerciseCommand) GetContractId() string
- func (x *ExerciseCommand) GetTemplateId() *Identifier
- func (*ExerciseCommand) ProtoMessage()
- func (x *ExerciseCommand) ProtoReflect() protoreflect.Message
- func (x *ExerciseCommand) Reset()
- func (x *ExerciseCommand) String() string
- type ExercisedEvent
- func (*ExercisedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ExercisedEvent) GetAcsDelta() bool
- func (x *ExercisedEvent) GetActingParties() []string
- func (x *ExercisedEvent) GetChoice() string
- func (x *ExercisedEvent) GetChoiceArgument() *Value
- func (x *ExercisedEvent) GetConsuming() bool
- func (x *ExercisedEvent) GetContractId() string
- func (x *ExercisedEvent) GetExerciseResult() *Value
- func (x *ExercisedEvent) GetImplementedInterfaces() []*Identifier
- func (x *ExercisedEvent) GetInterfaceId() *Identifier
- func (x *ExercisedEvent) GetLastDescendantNodeId() int32
- func (x *ExercisedEvent) GetNodeId() int32
- func (x *ExercisedEvent) GetOffset() int64
- func (x *ExercisedEvent) GetPackageName() string
- func (x *ExercisedEvent) GetTemplateId() *Identifier
- func (x *ExercisedEvent) GetWitnessParties() []string
- func (*ExercisedEvent) ProtoMessage()
- func (x *ExercisedEvent) ProtoReflect() protoreflect.Message
- func (x *ExercisedEvent) Reset()
- func (x *ExercisedEvent) String() string
- type ExperimentalCommandInspectionService
- func (*ExperimentalCommandInspectionService) Descriptor() ([]byte, []int)deprecated
- func (x *ExperimentalCommandInspectionService) GetSupported() bool
- func (*ExperimentalCommandInspectionService) ProtoMessage()
- func (x *ExperimentalCommandInspectionService) ProtoReflect() protoreflect.Message
- func (x *ExperimentalCommandInspectionService) Reset()
- func (x *ExperimentalCommandInspectionService) String() string
- type ExperimentalFeatures
- func (*ExperimentalFeatures) Descriptor() ([]byte, []int)deprecated
- func (x *ExperimentalFeatures) GetCommandInspectionService() *ExperimentalCommandInspectionService
- func (x *ExperimentalFeatures) GetStaticTime() *ExperimentalStaticTime
- func (*ExperimentalFeatures) ProtoMessage()
- func (x *ExperimentalFeatures) ProtoReflect() protoreflect.Message
- func (x *ExperimentalFeatures) Reset()
- func (x *ExperimentalFeatures) String() string
- type ExperimentalPartyTopologyEvents
- func (*ExperimentalPartyTopologyEvents) Descriptor() ([]byte, []int)deprecated
- func (x *ExperimentalPartyTopologyEvents) GetSupported() bool
- func (*ExperimentalPartyTopologyEvents) ProtoMessage()
- func (x *ExperimentalPartyTopologyEvents) ProtoReflect() protoreflect.Message
- func (x *ExperimentalPartyTopologyEvents) Reset()
- func (x *ExperimentalPartyTopologyEvents) String() string
- type ExperimentalStaticTime
- func (*ExperimentalStaticTime) Descriptor() ([]byte, []int)deprecated
- func (x *ExperimentalStaticTime) GetSupported() bool
- func (*ExperimentalStaticTime) ProtoMessage()
- func (x *ExperimentalStaticTime) ProtoReflect() protoreflect.Message
- func (x *ExperimentalStaticTime) Reset()
- func (x *ExperimentalStaticTime) String() string
- type FeaturesDescriptor
- func (*FeaturesDescriptor) Descriptor() ([]byte, []int)deprecated
- func (x *FeaturesDescriptor) GetExperimental() *ExperimentalFeatures
- func (x *FeaturesDescriptor) GetOffsetCheckpoint() *OffsetCheckpointFeature
- func (x *FeaturesDescriptor) GetPackageFeature() *PackageFeature
- func (x *FeaturesDescriptor) GetPartyManagement() *PartyManagementFeature
- func (x *FeaturesDescriptor) GetUserManagement() *UserManagementFeature
- func (*FeaturesDescriptor) ProtoMessage()
- func (x *FeaturesDescriptor) ProtoReflect() protoreflect.Message
- func (x *FeaturesDescriptor) Reset()
- func (x *FeaturesDescriptor) String() string
- type Filters
- type GenMap
- type GenMap_Entry
- func (*GenMap_Entry) Descriptor() ([]byte, []int)deprecated
- func (x *GenMap_Entry) GetKey() *Value
- func (x *GenMap_Entry) GetValue() *Value
- func (*GenMap_Entry) ProtoMessage()
- func (x *GenMap_Entry) ProtoReflect() protoreflect.Message
- func (x *GenMap_Entry) Reset()
- func (x *GenMap_Entry) String() string
- type GetActiveContractsRequest
- func (*GetActiveContractsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetActiveContractsRequest) GetActiveAtOffset() int64
- func (x *GetActiveContractsRequest) GetEventFormat() *EventFormat
- func (*GetActiveContractsRequest) ProtoMessage()
- func (x *GetActiveContractsRequest) ProtoReflect() protoreflect.Message
- func (x *GetActiveContractsRequest) Reset()
- func (x *GetActiveContractsRequest) String() string
- type GetActiveContractsResponse
- func (*GetActiveContractsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetActiveContractsResponse) GetActiveContract() *ActiveContract
- func (x *GetActiveContractsResponse) GetContractEntry() isGetActiveContractsResponse_ContractEntry
- func (x *GetActiveContractsResponse) GetIncompleteAssigned() *IncompleteAssigned
- func (x *GetActiveContractsResponse) GetIncompleteUnassigned() *IncompleteUnassigned
- func (x *GetActiveContractsResponse) GetWorkflowId() string
- func (*GetActiveContractsResponse) ProtoMessage()
- func (x *GetActiveContractsResponse) ProtoReflect() protoreflect.Message
- func (x *GetActiveContractsResponse) Reset()
- func (x *GetActiveContractsResponse) String() string
- type GetActiveContractsResponse_ActiveContract
- type GetActiveContractsResponse_IncompleteAssigned
- type GetActiveContractsResponse_IncompleteUnassigned
- type GetConnectedSynchronizersRequest
- func (*GetConnectedSynchronizersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetConnectedSynchronizersRequest) GetIdentityProviderId() string
- func (x *GetConnectedSynchronizersRequest) GetParticipantId() string
- func (x *GetConnectedSynchronizersRequest) GetParty() string
- func (*GetConnectedSynchronizersRequest) ProtoMessage()
- func (x *GetConnectedSynchronizersRequest) ProtoReflect() protoreflect.Message
- func (x *GetConnectedSynchronizersRequest) Reset()
- func (x *GetConnectedSynchronizersRequest) String() string
- type GetConnectedSynchronizersResponse
- func (*GetConnectedSynchronizersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetConnectedSynchronizersResponse) GetConnectedSynchronizers() []*GetConnectedSynchronizersResponse_ConnectedSynchronizer
- func (*GetConnectedSynchronizersResponse) ProtoMessage()
- func (x *GetConnectedSynchronizersResponse) ProtoReflect() protoreflect.Message
- func (x *GetConnectedSynchronizersResponse) Reset()
- func (x *GetConnectedSynchronizersResponse) String() string
- type GetConnectedSynchronizersResponse_ConnectedSynchronizer
- func (*GetConnectedSynchronizersResponse_ConnectedSynchronizer) Descriptor() ([]byte, []int)deprecated
- func (x *GetConnectedSynchronizersResponse_ConnectedSynchronizer) GetPermission() ParticipantPermission
- func (x *GetConnectedSynchronizersResponse_ConnectedSynchronizer) GetSynchronizerAlias() string
- func (x *GetConnectedSynchronizersResponse_ConnectedSynchronizer) GetSynchronizerId() string
- func (*GetConnectedSynchronizersResponse_ConnectedSynchronizer) ProtoMessage()
- func (x *GetConnectedSynchronizersResponse_ConnectedSynchronizer) ProtoReflect() protoreflect.Message
- func (x *GetConnectedSynchronizersResponse_ConnectedSynchronizer) Reset()
- func (x *GetConnectedSynchronizersResponse_ConnectedSynchronizer) String() string
- type GetEventsByContractIdRequest
- func (*GetEventsByContractIdRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetEventsByContractIdRequest) GetContractId() string
- func (x *GetEventsByContractIdRequest) GetEventFormat() *EventFormat
- func (*GetEventsByContractIdRequest) ProtoMessage()
- func (x *GetEventsByContractIdRequest) ProtoReflect() protoreflect.Message
- func (x *GetEventsByContractIdRequest) Reset()
- func (x *GetEventsByContractIdRequest) String() string
- type GetEventsByContractIdResponse
- func (*GetEventsByContractIdResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetEventsByContractIdResponse) GetArchived() *Archived
- func (x *GetEventsByContractIdResponse) GetCreated() *Created
- func (*GetEventsByContractIdResponse) ProtoMessage()
- func (x *GetEventsByContractIdResponse) ProtoReflect() protoreflect.Message
- func (x *GetEventsByContractIdResponse) Reset()
- func (x *GetEventsByContractIdResponse) String() string
- type GetLatestPrunedOffsetsRequest
- func (*GetLatestPrunedOffsetsRequest) Descriptor() ([]byte, []int)deprecated
- func (*GetLatestPrunedOffsetsRequest) ProtoMessage()
- func (x *GetLatestPrunedOffsetsRequest) ProtoReflect() protoreflect.Message
- func (x *GetLatestPrunedOffsetsRequest) Reset()
- func (x *GetLatestPrunedOffsetsRequest) String() string
- type GetLatestPrunedOffsetsResponse
- func (*GetLatestPrunedOffsetsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetLatestPrunedOffsetsResponse) GetAllDivulgedContractsPrunedUpToInclusive() int64
- func (x *GetLatestPrunedOffsetsResponse) GetParticipantPrunedUpToInclusive() int64
- func (*GetLatestPrunedOffsetsResponse) ProtoMessage()
- func (x *GetLatestPrunedOffsetsResponse) ProtoReflect() protoreflect.Message
- func (x *GetLatestPrunedOffsetsResponse) Reset()
- func (x *GetLatestPrunedOffsetsResponse) String() string
- type GetLedgerApiVersionRequest
- type GetLedgerApiVersionResponse
- func (*GetLedgerApiVersionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetLedgerApiVersionResponse) GetFeatures() *FeaturesDescriptor
- func (x *GetLedgerApiVersionResponse) GetVersion() string
- func (*GetLedgerApiVersionResponse) ProtoMessage()
- func (x *GetLedgerApiVersionResponse) ProtoReflect() protoreflect.Message
- func (x *GetLedgerApiVersionResponse) Reset()
- func (x *GetLedgerApiVersionResponse) String() string
- type GetLedgerEndRequest
- type GetLedgerEndResponse
- func (*GetLedgerEndResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetLedgerEndResponse) GetOffset() int64
- func (*GetLedgerEndResponse) ProtoMessage()
- func (x *GetLedgerEndResponse) ProtoReflect() protoreflect.Message
- func (x *GetLedgerEndResponse) Reset()
- func (x *GetLedgerEndResponse) String() string
- type GetPackageRequest
- type GetPackageResponse
- func (*GetPackageResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetPackageResponse) GetArchivePayload() []byte
- func (x *GetPackageResponse) GetHash() string
- func (x *GetPackageResponse) GetHashFunction() HashFunction
- func (*GetPackageResponse) ProtoMessage()
- func (x *GetPackageResponse) ProtoReflect() protoreflect.Message
- func (x *GetPackageResponse) Reset()
- func (x *GetPackageResponse) String() string
- type GetPackageStatusRequest
- func (*GetPackageStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetPackageStatusRequest) GetPackageId() string
- func (*GetPackageStatusRequest) ProtoMessage()
- func (x *GetPackageStatusRequest) ProtoReflect() protoreflect.Message
- func (x *GetPackageStatusRequest) Reset()
- func (x *GetPackageStatusRequest) String() string
- type GetPackageStatusResponse
- func (*GetPackageStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetPackageStatusResponse) GetPackageStatus() PackageStatus
- func (*GetPackageStatusResponse) ProtoMessage()
- func (x *GetPackageStatusResponse) ProtoReflect() protoreflect.Message
- func (x *GetPackageStatusResponse) Reset()
- func (x *GetPackageStatusResponse) String() string
- type GetUpdateByIdRequest
- func (*GetUpdateByIdRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetUpdateByIdRequest) GetUpdateFormat() *UpdateFormat
- func (x *GetUpdateByIdRequest) GetUpdateId() string
- func (*GetUpdateByIdRequest) ProtoMessage()
- func (x *GetUpdateByIdRequest) ProtoReflect() protoreflect.Message
- func (x *GetUpdateByIdRequest) Reset()
- func (x *GetUpdateByIdRequest) String() string
- type GetUpdateByOffsetRequest
- func (*GetUpdateByOffsetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetUpdateByOffsetRequest) GetOffset() int64
- func (x *GetUpdateByOffsetRequest) GetUpdateFormat() *UpdateFormat
- func (*GetUpdateByOffsetRequest) ProtoMessage()
- func (x *GetUpdateByOffsetRequest) ProtoReflect() protoreflect.Message
- func (x *GetUpdateByOffsetRequest) Reset()
- func (x *GetUpdateByOffsetRequest) String() string
- type GetUpdateResponse
- func (*GetUpdateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetUpdateResponse) GetReassignment() *Reassignment
- func (x *GetUpdateResponse) GetTopologyTransaction() *TopologyTransaction
- func (x *GetUpdateResponse) GetTransaction() *Transaction
- func (x *GetUpdateResponse) GetUpdate() isGetUpdateResponse_Update
- func (*GetUpdateResponse) ProtoMessage()
- func (x *GetUpdateResponse) ProtoReflect() protoreflect.Message
- func (x *GetUpdateResponse) Reset()
- func (x *GetUpdateResponse) String() string
- type GetUpdateResponse_Reassignment
- type GetUpdateResponse_TopologyTransaction
- type GetUpdateResponse_Transaction
- type GetUpdatesRequest
- func (*GetUpdatesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetUpdatesRequest) GetBeginExclusive() int64
- func (x *GetUpdatesRequest) GetEndInclusive() int64
- func (x *GetUpdatesRequest) GetUpdateFormat() *UpdateFormat
- func (*GetUpdatesRequest) ProtoMessage()
- func (x *GetUpdatesRequest) ProtoReflect() protoreflect.Message
- func (x *GetUpdatesRequest) Reset()
- func (x *GetUpdatesRequest) String() string
- type GetUpdatesResponse
- func (*GetUpdatesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetUpdatesResponse) GetOffsetCheckpoint() *OffsetCheckpoint
- func (x *GetUpdatesResponse) GetReassignment() *Reassignment
- func (x *GetUpdatesResponse) GetTopologyTransaction() *TopologyTransaction
- func (x *GetUpdatesResponse) GetTransaction() *Transaction
- func (x *GetUpdatesResponse) GetUpdate() isGetUpdatesResponse_Update
- func (*GetUpdatesResponse) ProtoMessage()
- func (x *GetUpdatesResponse) ProtoReflect() protoreflect.Message
- func (x *GetUpdatesResponse) Reset()
- func (x *GetUpdatesResponse) String() string
- type GetUpdatesResponse_OffsetCheckpoint
- type GetUpdatesResponse_Reassignment
- type GetUpdatesResponse_TopologyTransaction
- type GetUpdatesResponse_Transaction
- type HashFunction
- func (HashFunction) Descriptor() protoreflect.EnumDescriptor
- func (x HashFunction) Enum() *HashFunction
- func (HashFunction) EnumDescriptor() ([]byte, []int)deprecated
- func (x HashFunction) Number() protoreflect.EnumNumber
- func (x HashFunction) String() string
- func (HashFunction) Type() protoreflect.EnumType
- type Identifier
- func (*Identifier) Descriptor() ([]byte, []int)deprecated
- func (x *Identifier) GetEntityName() string
- func (x *Identifier) GetModuleName() string
- func (x *Identifier) GetPackageId() string
- func (*Identifier) ProtoMessage()
- func (x *Identifier) ProtoReflect() protoreflect.Message
- func (x *Identifier) Reset()
- func (x *Identifier) String() string
- type IncompleteAssigned
- func (*IncompleteAssigned) Descriptor() ([]byte, []int)deprecated
- func (x *IncompleteAssigned) GetAssignedEvent() *AssignedEvent
- func (*IncompleteAssigned) ProtoMessage()
- func (x *IncompleteAssigned) ProtoReflect() protoreflect.Message
- func (x *IncompleteAssigned) Reset()
- func (x *IncompleteAssigned) String() string
- type IncompleteUnassigned
- func (*IncompleteUnassigned) Descriptor() ([]byte, []int)deprecated
- func (x *IncompleteUnassigned) GetCreatedEvent() *CreatedEvent
- func (x *IncompleteUnassigned) GetUnassignedEvent() *UnassignedEvent
- func (*IncompleteUnassigned) ProtoMessage()
- func (x *IncompleteUnassigned) ProtoReflect() protoreflect.Message
- func (x *IncompleteUnassigned) Reset()
- func (x *IncompleteUnassigned) String() string
- type InterfaceFilter
- func (*InterfaceFilter) Descriptor() ([]byte, []int)deprecated
- func (x *InterfaceFilter) GetIncludeCreatedEventBlob() bool
- func (x *InterfaceFilter) GetIncludeInterfaceView() bool
- func (x *InterfaceFilter) GetInterfaceId() *Identifier
- func (*InterfaceFilter) ProtoMessage()
- func (x *InterfaceFilter) ProtoReflect() protoreflect.Message
- func (x *InterfaceFilter) Reset()
- func (x *InterfaceFilter) String() string
- type InterfaceView
- func (*InterfaceView) Descriptor() ([]byte, []int)deprecated
- func (x *InterfaceView) GetInterfaceId() *Identifier
- func (x *InterfaceView) GetViewStatus() *status.Status
- func (x *InterfaceView) GetViewValue() *Record
- func (*InterfaceView) ProtoMessage()
- func (x *InterfaceView) ProtoReflect() protoreflect.Message
- func (x *InterfaceView) Reset()
- func (x *InterfaceView) String() string
- type List
- type ListPackagesRequest
- type ListPackagesResponse
- func (*ListPackagesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListPackagesResponse) GetPackageIds() []string
- func (*ListPackagesResponse) ProtoMessage()
- func (x *ListPackagesResponse) ProtoReflect() protoreflect.Message
- func (x *ListPackagesResponse) Reset()
- func (x *ListPackagesResponse) String() string
- type ListVettedPackagesRequest
- func (*ListVettedPackagesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListVettedPackagesRequest) GetPackageMetadataFilter() *PackageMetadataFilter
- func (x *ListVettedPackagesRequest) GetPageSize() uint32
- func (x *ListVettedPackagesRequest) GetPageToken() string
- func (x *ListVettedPackagesRequest) GetTopologyStateFilter() *TopologyStateFilter
- func (*ListVettedPackagesRequest) ProtoMessage()
- func (x *ListVettedPackagesRequest) ProtoReflect() protoreflect.Message
- func (x *ListVettedPackagesRequest) Reset()
- func (x *ListVettedPackagesRequest) String() string
- type ListVettedPackagesResponse
- func (*ListVettedPackagesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListVettedPackagesResponse) GetNextPageToken() string
- func (x *ListVettedPackagesResponse) GetVettedPackages() []*VettedPackages
- func (*ListVettedPackagesResponse) ProtoMessage()
- func (x *ListVettedPackagesResponse) ProtoReflect() protoreflect.Message
- func (x *ListVettedPackagesResponse) Reset()
- func (x *ListVettedPackagesResponse) String() string
- type OffsetCheckpoint
- func (*OffsetCheckpoint) Descriptor() ([]byte, []int)deprecated
- func (x *OffsetCheckpoint) GetOffset() int64
- func (x *OffsetCheckpoint) GetSynchronizerTimes() []*SynchronizerTime
- func (*OffsetCheckpoint) ProtoMessage()
- func (x *OffsetCheckpoint) ProtoReflect() protoreflect.Message
- func (x *OffsetCheckpoint) Reset()
- func (x *OffsetCheckpoint) String() string
- type OffsetCheckpointFeature
- func (*OffsetCheckpointFeature) Descriptor() ([]byte, []int)deprecated
- func (x *OffsetCheckpointFeature) GetMaxOffsetCheckpointEmissionDelay() *durationpb.Duration
- func (*OffsetCheckpointFeature) ProtoMessage()
- func (x *OffsetCheckpointFeature) ProtoReflect() protoreflect.Message
- func (x *OffsetCheckpointFeature) Reset()
- func (x *OffsetCheckpointFeature) String() string
- type Optional
- type PackageFeature
- type PackageMetadataFilter
- func (*PackageMetadataFilter) Descriptor() ([]byte, []int)deprecated
- func (x *PackageMetadataFilter) GetPackageIds() []string
- func (x *PackageMetadataFilter) GetPackageNamePrefixes() []string
- func (*PackageMetadataFilter) ProtoMessage()
- func (x *PackageMetadataFilter) ProtoReflect() protoreflect.Message
- func (x *PackageMetadataFilter) Reset()
- func (x *PackageMetadataFilter) String() string
- type PackageReference
- func (*PackageReference) Descriptor() ([]byte, []int)deprecated
- func (x *PackageReference) GetPackageId() string
- func (x *PackageReference) GetPackageName() string
- func (x *PackageReference) GetPackageVersion() string
- func (*PackageReference) ProtoMessage()
- func (x *PackageReference) ProtoReflect() protoreflect.Message
- func (x *PackageReference) Reset()
- func (x *PackageReference) String() string
- type PackageServiceClient
- type PackageServiceServer
- type PackageStatus
- func (PackageStatus) Descriptor() protoreflect.EnumDescriptor
- func (x PackageStatus) Enum() *PackageStatus
- func (PackageStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x PackageStatus) Number() protoreflect.EnumNumber
- func (x PackageStatus) String() string
- func (PackageStatus) Type() protoreflect.EnumType
- type ParticipantAuthorizationAdded
- func (*ParticipantAuthorizationAdded) Descriptor() ([]byte, []int)deprecated
- func (x *ParticipantAuthorizationAdded) GetParticipantId() string
- func (x *ParticipantAuthorizationAdded) GetParticipantPermission() ParticipantPermission
- func (x *ParticipantAuthorizationAdded) GetPartyId() string
- func (*ParticipantAuthorizationAdded) ProtoMessage()
- func (x *ParticipantAuthorizationAdded) ProtoReflect() protoreflect.Message
- func (x *ParticipantAuthorizationAdded) Reset()
- func (x *ParticipantAuthorizationAdded) String() string
- type ParticipantAuthorizationChanged
- func (*ParticipantAuthorizationChanged) Descriptor() ([]byte, []int)deprecated
- func (x *ParticipantAuthorizationChanged) GetParticipantId() string
- func (x *ParticipantAuthorizationChanged) GetParticipantPermission() ParticipantPermission
- func (x *ParticipantAuthorizationChanged) GetPartyId() string
- func (*ParticipantAuthorizationChanged) ProtoMessage()
- func (x *ParticipantAuthorizationChanged) ProtoReflect() protoreflect.Message
- func (x *ParticipantAuthorizationChanged) Reset()
- func (x *ParticipantAuthorizationChanged) String() string
- type ParticipantAuthorizationRevoked
- func (*ParticipantAuthorizationRevoked) Descriptor() ([]byte, []int)deprecated
- func (x *ParticipantAuthorizationRevoked) GetParticipantId() string
- func (x *ParticipantAuthorizationRevoked) GetPartyId() string
- func (*ParticipantAuthorizationRevoked) ProtoMessage()
- func (x *ParticipantAuthorizationRevoked) ProtoReflect() protoreflect.Message
- func (x *ParticipantAuthorizationRevoked) Reset()
- func (x *ParticipantAuthorizationRevoked) String() string
- type ParticipantAuthorizationTopologyFormat
- func (*ParticipantAuthorizationTopologyFormat) Descriptor() ([]byte, []int)deprecated
- func (x *ParticipantAuthorizationTopologyFormat) GetParties() []string
- func (*ParticipantAuthorizationTopologyFormat) ProtoMessage()
- func (x *ParticipantAuthorizationTopologyFormat) ProtoReflect() protoreflect.Message
- func (x *ParticipantAuthorizationTopologyFormat) Reset()
- func (x *ParticipantAuthorizationTopologyFormat) String() string
- type ParticipantPermission
- func (ParticipantPermission) Descriptor() protoreflect.EnumDescriptor
- func (x ParticipantPermission) Enum() *ParticipantPermission
- func (ParticipantPermission) EnumDescriptor() ([]byte, []int)deprecated
- func (x ParticipantPermission) Number() protoreflect.EnumNumber
- func (x ParticipantPermission) String() string
- func (ParticipantPermission) Type() protoreflect.EnumType
- type PartyManagementFeature
- func (*PartyManagementFeature) Descriptor() ([]byte, []int)deprecated
- func (x *PartyManagementFeature) GetMaxPartiesPageSize() int32
- func (*PartyManagementFeature) ProtoMessage()
- func (x *PartyManagementFeature) ProtoReflect() protoreflect.Message
- func (x *PartyManagementFeature) Reset()
- func (x *PartyManagementFeature) String() string
- type PrefetchContractKey
- func (*PrefetchContractKey) Descriptor() ([]byte, []int)deprecated
- func (x *PrefetchContractKey) GetContractKey() *Value
- func (x *PrefetchContractKey) GetTemplateId() *Identifier
- func (*PrefetchContractKey) ProtoMessage()
- func (x *PrefetchContractKey) ProtoReflect() protoreflect.Message
- func (x *PrefetchContractKey) Reset()
- func (x *PrefetchContractKey) String() string
- type PriorTopologySerial
- func (*PriorTopologySerial) Descriptor() ([]byte, []int)deprecated
- func (x *PriorTopologySerial) GetNoPrior() *emptypb.Empty
- func (x *PriorTopologySerial) GetPrior() uint32
- func (x *PriorTopologySerial) GetSerial() isPriorTopologySerial_Serial
- func (*PriorTopologySerial) ProtoMessage()
- func (x *PriorTopologySerial) ProtoReflect() protoreflect.Message
- func (x *PriorTopologySerial) Reset()
- func (x *PriorTopologySerial) String() string
- type PriorTopologySerial_NoPrior
- type PriorTopologySerial_Prior
- type Reassignment
- func (*Reassignment) Descriptor() ([]byte, []int)deprecated
- func (x *Reassignment) GetCommandId() string
- func (x *Reassignment) GetEvents() []*ReassignmentEvent
- func (x *Reassignment) GetOffset() int64
- func (x *Reassignment) GetRecordTime() *timestamppb.Timestamp
- func (x *Reassignment) GetSynchronizerId() string
- func (x *Reassignment) GetTraceContext() *TraceContext
- func (x *Reassignment) GetUpdateId() string
- func (x *Reassignment) GetWorkflowId() string
- func (*Reassignment) ProtoMessage()
- func (x *Reassignment) ProtoReflect() protoreflect.Message
- func (x *Reassignment) Reset()
- func (x *Reassignment) String() string
- type ReassignmentCommand
- func (*ReassignmentCommand) Descriptor() ([]byte, []int)deprecated
- func (x *ReassignmentCommand) GetAssignCommand() *AssignCommand
- func (x *ReassignmentCommand) GetCommand() isReassignmentCommand_Command
- func (x *ReassignmentCommand) GetUnassignCommand() *UnassignCommand
- func (*ReassignmentCommand) ProtoMessage()
- func (x *ReassignmentCommand) ProtoReflect() protoreflect.Message
- func (x *ReassignmentCommand) Reset()
- func (x *ReassignmentCommand) String() string
- type ReassignmentCommand_AssignCommand
- type ReassignmentCommand_UnassignCommand
- type ReassignmentCommands
- func (*ReassignmentCommands) Descriptor() ([]byte, []int)deprecated
- func (x *ReassignmentCommands) GetCommandId() string
- func (x *ReassignmentCommands) GetCommands() []*ReassignmentCommand
- func (x *ReassignmentCommands) GetSubmissionId() string
- func (x *ReassignmentCommands) GetSubmitter() string
- func (x *ReassignmentCommands) GetUserId() string
- func (x *ReassignmentCommands) GetWorkflowId() string
- func (*ReassignmentCommands) ProtoMessage()
- func (x *ReassignmentCommands) ProtoReflect() protoreflect.Message
- func (x *ReassignmentCommands) Reset()
- func (x *ReassignmentCommands) String() string
- type ReassignmentEvent
- func (*ReassignmentEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ReassignmentEvent) GetAssigned() *AssignedEvent
- func (x *ReassignmentEvent) GetEvent() isReassignmentEvent_Event
- func (x *ReassignmentEvent) GetUnassigned() *UnassignedEvent
- func (*ReassignmentEvent) ProtoMessage()
- func (x *ReassignmentEvent) ProtoReflect() protoreflect.Message
- func (x *ReassignmentEvent) Reset()
- func (x *ReassignmentEvent) String() string
- type ReassignmentEvent_Assigned
- type ReassignmentEvent_Unassigned
- type Record
- type RecordField
- type Signature
- func (*Signature) Descriptor() ([]byte, []int)deprecated
- func (x *Signature) GetFormat() SignatureFormat
- func (x *Signature) GetSignature() []byte
- func (x *Signature) GetSignedBy() string
- func (x *Signature) GetSigningAlgorithmSpec() SigningAlgorithmSpec
- func (*Signature) ProtoMessage()
- func (x *Signature) ProtoReflect() protoreflect.Message
- func (x *Signature) Reset()
- func (x *Signature) String() string
- type SignatureFormat
- func (SignatureFormat) Descriptor() protoreflect.EnumDescriptor
- func (x SignatureFormat) Enum() *SignatureFormat
- func (SignatureFormat) EnumDescriptor() ([]byte, []int)deprecated
- func (x SignatureFormat) Number() protoreflect.EnumNumber
- func (x SignatureFormat) String() string
- func (SignatureFormat) Type() protoreflect.EnumType
- type SigningAlgorithmSpec
- func (SigningAlgorithmSpec) Descriptor() protoreflect.EnumDescriptor
- func (x SigningAlgorithmSpec) Enum() *SigningAlgorithmSpec
- func (SigningAlgorithmSpec) EnumDescriptor() ([]byte, []int)deprecated
- func (x SigningAlgorithmSpec) Number() protoreflect.EnumNumber
- func (x SigningAlgorithmSpec) String() string
- func (SigningAlgorithmSpec) Type() protoreflect.EnumType
- type SigningKeySpec
- func (SigningKeySpec) Descriptor() protoreflect.EnumDescriptor
- func (x SigningKeySpec) Enum() *SigningKeySpec
- func (SigningKeySpec) EnumDescriptor() ([]byte, []int)deprecated
- func (x SigningKeySpec) Number() protoreflect.EnumNumber
- func (x SigningKeySpec) String() string
- func (SigningKeySpec) Type() protoreflect.EnumType
- type SigningPublicKey
- func (*SigningPublicKey) Descriptor() ([]byte, []int)deprecated
- func (x *SigningPublicKey) GetFormat() CryptoKeyFormat
- func (x *SigningPublicKey) GetKeyData() []byte
- func (x *SigningPublicKey) GetKeySpec() SigningKeySpec
- func (*SigningPublicKey) ProtoMessage()
- func (x *SigningPublicKey) ProtoReflect() protoreflect.Message
- func (x *SigningPublicKey) Reset()
- func (x *SigningPublicKey) String() string
- type StateServiceClient
- type StateServiceServer
- type StateService_GetActiveContractsClient
- type StateService_GetActiveContractsServer
- type SubmitAndWaitForReassignmentRequest
- func (*SubmitAndWaitForReassignmentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubmitAndWaitForReassignmentRequest) GetEventFormat() *EventFormat
- func (x *SubmitAndWaitForReassignmentRequest) GetReassignmentCommands() *ReassignmentCommands
- func (*SubmitAndWaitForReassignmentRequest) ProtoMessage()
- func (x *SubmitAndWaitForReassignmentRequest) ProtoReflect() protoreflect.Message
- func (x *SubmitAndWaitForReassignmentRequest) Reset()
- func (x *SubmitAndWaitForReassignmentRequest) String() string
- type SubmitAndWaitForReassignmentResponse
- func (*SubmitAndWaitForReassignmentResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SubmitAndWaitForReassignmentResponse) GetReassignment() *Reassignment
- func (*SubmitAndWaitForReassignmentResponse) ProtoMessage()
- func (x *SubmitAndWaitForReassignmentResponse) ProtoReflect() protoreflect.Message
- func (x *SubmitAndWaitForReassignmentResponse) Reset()
- func (x *SubmitAndWaitForReassignmentResponse) String() string
- type SubmitAndWaitForTransactionRequest
- func (*SubmitAndWaitForTransactionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubmitAndWaitForTransactionRequest) GetCommands() *Commands
- func (x *SubmitAndWaitForTransactionRequest) GetTransactionFormat() *TransactionFormat
- func (*SubmitAndWaitForTransactionRequest) ProtoMessage()
- func (x *SubmitAndWaitForTransactionRequest) ProtoReflect() protoreflect.Message
- func (x *SubmitAndWaitForTransactionRequest) Reset()
- func (x *SubmitAndWaitForTransactionRequest) String() string
- type SubmitAndWaitForTransactionResponse
- func (*SubmitAndWaitForTransactionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SubmitAndWaitForTransactionResponse) GetTransaction() *Transaction
- func (*SubmitAndWaitForTransactionResponse) ProtoMessage()
- func (x *SubmitAndWaitForTransactionResponse) ProtoReflect() protoreflect.Message
- func (x *SubmitAndWaitForTransactionResponse) Reset()
- func (x *SubmitAndWaitForTransactionResponse) String() string
- type SubmitAndWaitRequest
- func (*SubmitAndWaitRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubmitAndWaitRequest) GetCommands() *Commands
- func (*SubmitAndWaitRequest) ProtoMessage()
- func (x *SubmitAndWaitRequest) ProtoReflect() protoreflect.Message
- func (x *SubmitAndWaitRequest) Reset()
- func (x *SubmitAndWaitRequest) String() string
- type SubmitAndWaitResponse
- func (*SubmitAndWaitResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SubmitAndWaitResponse) GetCompletionOffset() int64
- func (x *SubmitAndWaitResponse) GetUpdateId() string
- func (*SubmitAndWaitResponse) ProtoMessage()
- func (x *SubmitAndWaitResponse) ProtoReflect() protoreflect.Message
- func (x *SubmitAndWaitResponse) Reset()
- func (x *SubmitAndWaitResponse) String() string
- type SubmitReassignmentRequest
- func (*SubmitReassignmentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubmitReassignmentRequest) GetReassignmentCommands() *ReassignmentCommands
- func (*SubmitReassignmentRequest) ProtoMessage()
- func (x *SubmitReassignmentRequest) ProtoReflect() protoreflect.Message
- func (x *SubmitReassignmentRequest) Reset()
- func (x *SubmitReassignmentRequest) String() string
- type SubmitReassignmentResponse
- type SubmitRequest
- type SubmitResponse
- type SynchronizerTime
- func (*SynchronizerTime) Descriptor() ([]byte, []int)deprecated
- func (x *SynchronizerTime) GetRecordTime() *timestamppb.Timestamp
- func (x *SynchronizerTime) GetSynchronizerId() string
- func (*SynchronizerTime) ProtoMessage()
- func (x *SynchronizerTime) ProtoReflect() protoreflect.Message
- func (x *SynchronizerTime) Reset()
- func (x *SynchronizerTime) String() string
- type TemplateFilter
- func (*TemplateFilter) Descriptor() ([]byte, []int)deprecated
- func (x *TemplateFilter) GetIncludeCreatedEventBlob() bool
- func (x *TemplateFilter) GetTemplateId() *Identifier
- func (*TemplateFilter) ProtoMessage()
- func (x *TemplateFilter) ProtoReflect() protoreflect.Message
- func (x *TemplateFilter) Reset()
- func (x *TemplateFilter) String() string
- type TextMap
- type TextMap_Entry
- func (*TextMap_Entry) Descriptor() ([]byte, []int)deprecated
- func (x *TextMap_Entry) GetKey() string
- func (x *TextMap_Entry) GetValue() *Value
- func (*TextMap_Entry) ProtoMessage()
- func (x *TextMap_Entry) ProtoReflect() protoreflect.Message
- func (x *TextMap_Entry) Reset()
- func (x *TextMap_Entry) String() string
- type TopologyEvent
- func (*TopologyEvent) Descriptor() ([]byte, []int)deprecated
- func (x *TopologyEvent) GetEvent() isTopologyEvent_Event
- func (x *TopologyEvent) GetParticipantAuthorizationAdded() *ParticipantAuthorizationAdded
- func (x *TopologyEvent) GetParticipantAuthorizationChanged() *ParticipantAuthorizationChanged
- func (x *TopologyEvent) GetParticipantAuthorizationRevoked() *ParticipantAuthorizationRevoked
- func (*TopologyEvent) ProtoMessage()
- func (x *TopologyEvent) ProtoReflect() protoreflect.Message
- func (x *TopologyEvent) Reset()
- func (x *TopologyEvent) String() string
- type TopologyEvent_ParticipantAuthorizationAdded
- type TopologyEvent_ParticipantAuthorizationChanged
- type TopologyEvent_ParticipantAuthorizationRevoked
- type TopologyFormat
- func (*TopologyFormat) Descriptor() ([]byte, []int)deprecated
- func (x *TopologyFormat) GetIncludeParticipantAuthorizationEvents() *ParticipantAuthorizationTopologyFormat
- func (*TopologyFormat) ProtoMessage()
- func (x *TopologyFormat) ProtoReflect() protoreflect.Message
- func (x *TopologyFormat) Reset()
- func (x *TopologyFormat) String() string
- type TopologyStateFilter
- func (*TopologyStateFilter) Descriptor() ([]byte, []int)deprecated
- func (x *TopologyStateFilter) GetParticipantIds() []string
- func (x *TopologyStateFilter) GetSynchronizerIds() []string
- func (*TopologyStateFilter) ProtoMessage()
- func (x *TopologyStateFilter) ProtoReflect() protoreflect.Message
- func (x *TopologyStateFilter) Reset()
- func (x *TopologyStateFilter) String() string
- type TopologyTransaction
- func (*TopologyTransaction) Descriptor() ([]byte, []int)deprecated
- func (x *TopologyTransaction) GetEvents() []*TopologyEvent
- func (x *TopologyTransaction) GetOffset() int64
- func (x *TopologyTransaction) GetRecordTime() *timestamppb.Timestamp
- func (x *TopologyTransaction) GetSynchronizerId() string
- func (x *TopologyTransaction) GetTraceContext() *TraceContext
- func (x *TopologyTransaction) GetUpdateId() string
- func (*TopologyTransaction) ProtoMessage()
- func (x *TopologyTransaction) ProtoReflect() protoreflect.Message
- func (x *TopologyTransaction) Reset()
- func (x *TopologyTransaction) String() string
- type TraceContext
- func (*TraceContext) Descriptor() ([]byte, []int)deprecated
- func (x *TraceContext) GetTraceparent() string
- func (x *TraceContext) GetTracestate() string
- func (*TraceContext) ProtoMessage()
- func (x *TraceContext) ProtoReflect() protoreflect.Message
- func (x *TraceContext) Reset()
- func (x *TraceContext) String() string
- type Transaction
- func (*Transaction) Descriptor() ([]byte, []int)deprecated
- func (x *Transaction) GetCommandId() string
- func (x *Transaction) GetEffectiveAt() *timestamppb.Timestamp
- func (x *Transaction) GetEvents() []*Event
- func (x *Transaction) GetExternalTransactionHash() []byte
- func (x *Transaction) GetOffset() int64
- func (x *Transaction) GetRecordTime() *timestamppb.Timestamp
- func (x *Transaction) GetSynchronizerId() string
- func (x *Transaction) GetTraceContext() *TraceContext
- func (x *Transaction) GetUpdateId() string
- func (x *Transaction) GetWorkflowId() string
- func (*Transaction) ProtoMessage()
- func (x *Transaction) ProtoReflect() protoreflect.Message
- func (x *Transaction) Reset()
- func (x *Transaction) String() string
- type TransactionFormat
- func (*TransactionFormat) Descriptor() ([]byte, []int)deprecated
- func (x *TransactionFormat) GetEventFormat() *EventFormat
- func (x *TransactionFormat) GetTransactionShape() TransactionShape
- func (*TransactionFormat) ProtoMessage()
- func (x *TransactionFormat) ProtoReflect() protoreflect.Message
- func (x *TransactionFormat) Reset()
- func (x *TransactionFormat) String() string
- type TransactionShape
- func (TransactionShape) Descriptor() protoreflect.EnumDescriptor
- func (x TransactionShape) Enum() *TransactionShape
- func (TransactionShape) EnumDescriptor() ([]byte, []int)deprecated
- func (x TransactionShape) Number() protoreflect.EnumNumber
- func (x TransactionShape) String() string
- func (TransactionShape) Type() protoreflect.EnumType
- type UnassignCommand
- func (*UnassignCommand) Descriptor() ([]byte, []int)deprecated
- func (x *UnassignCommand) GetContractId() string
- func (x *UnassignCommand) GetSource() string
- func (x *UnassignCommand) GetTarget() string
- func (*UnassignCommand) ProtoMessage()
- func (x *UnassignCommand) ProtoReflect() protoreflect.Message
- func (x *UnassignCommand) Reset()
- func (x *UnassignCommand) String() string
- type UnassignedEvent
- func (*UnassignedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *UnassignedEvent) GetAssignmentExclusivity() *timestamppb.Timestamp
- func (x *UnassignedEvent) GetContractId() string
- func (x *UnassignedEvent) GetNodeId() int32
- func (x *UnassignedEvent) GetOffset() int64
- func (x *UnassignedEvent) GetPackageName() string
- func (x *UnassignedEvent) GetReassignmentCounter() uint64
- func (x *UnassignedEvent) GetReassignmentId() string
- func (x *UnassignedEvent) GetSource() string
- func (x *UnassignedEvent) GetSubmitter() string
- func (x *UnassignedEvent) GetTarget() string
- func (x *UnassignedEvent) GetTemplateId() *Identifier
- func (x *UnassignedEvent) GetWitnessParties() []string
- func (*UnassignedEvent) ProtoMessage()
- func (x *UnassignedEvent) ProtoReflect() protoreflect.Message
- func (x *UnassignedEvent) Reset()
- func (x *UnassignedEvent) String() string
- type UnimplementedCommandCompletionServiceServer
- type UnimplementedCommandServiceServer
- func (UnimplementedCommandServiceServer) SubmitAndWait(context.Context, *SubmitAndWaitRequest) (*SubmitAndWaitResponse, error)
- func (UnimplementedCommandServiceServer) SubmitAndWaitForReassignment(context.Context, *SubmitAndWaitForReassignmentRequest) (*SubmitAndWaitForReassignmentResponse, error)
- func (UnimplementedCommandServiceServer) SubmitAndWaitForTransaction(context.Context, *SubmitAndWaitForTransactionRequest) (*SubmitAndWaitForTransactionResponse, error)
- type UnimplementedCommandSubmissionServiceServer
- type UnimplementedEventQueryServiceServer
- type UnimplementedPackageServiceServer
- func (UnimplementedPackageServiceServer) GetPackage(context.Context, *GetPackageRequest) (*GetPackageResponse, error)
- func (UnimplementedPackageServiceServer) GetPackageStatus(context.Context, *GetPackageStatusRequest) (*GetPackageStatusResponse, error)
- func (UnimplementedPackageServiceServer) ListPackages(context.Context, *ListPackagesRequest) (*ListPackagesResponse, error)
- func (UnimplementedPackageServiceServer) ListVettedPackages(context.Context, *ListVettedPackagesRequest) (*ListVettedPackagesResponse, error)
- type UnimplementedStateServiceServer
- func (UnimplementedStateServiceServer) GetActiveContracts(*GetActiveContractsRequest, ...) error
- func (UnimplementedStateServiceServer) GetConnectedSynchronizers(context.Context, *GetConnectedSynchronizersRequest) (*GetConnectedSynchronizersResponse, error)
- func (UnimplementedStateServiceServer) GetLatestPrunedOffsets(context.Context, *GetLatestPrunedOffsetsRequest) (*GetLatestPrunedOffsetsResponse, error)
- func (UnimplementedStateServiceServer) GetLedgerEnd(context.Context, *GetLedgerEndRequest) (*GetLedgerEndResponse, error)
- type UnimplementedUpdateServiceServer
- func (UnimplementedUpdateServiceServer) GetUpdateById(context.Context, *GetUpdateByIdRequest) (*GetUpdateResponse, error)
- func (UnimplementedUpdateServiceServer) GetUpdateByOffset(context.Context, *GetUpdateByOffsetRequest) (*GetUpdateResponse, error)
- func (UnimplementedUpdateServiceServer) GetUpdates(*GetUpdatesRequest, grpc.ServerStreamingServer[GetUpdatesResponse]) error
- type UnimplementedVersionServiceServer
- type UnsafeCommandCompletionServiceServer
- type UnsafeCommandServiceServer
- type UnsafeCommandSubmissionServiceServer
- type UnsafeEventQueryServiceServer
- type UnsafePackageServiceServer
- type UnsafeStateServiceServer
- type UnsafeUpdateServiceServer
- type UnsafeVersionServiceServer
- type UpdateFormat
- func (*UpdateFormat) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateFormat) GetIncludeReassignments() *EventFormat
- func (x *UpdateFormat) GetIncludeTopologyEvents() *TopologyFormat
- func (x *UpdateFormat) GetIncludeTransactions() *TransactionFormat
- func (*UpdateFormat) ProtoMessage()
- func (x *UpdateFormat) ProtoReflect() protoreflect.Message
- func (x *UpdateFormat) Reset()
- func (x *UpdateFormat) String() string
- type UpdateServiceClient
- type UpdateServiceServer
- type UpdateService_GetUpdatesClient
- type UpdateService_GetUpdatesServer
- type UserManagementFeature
- func (*UserManagementFeature) Descriptor() ([]byte, []int)deprecated
- func (x *UserManagementFeature) GetMaxRightsPerUser() int32
- func (x *UserManagementFeature) GetMaxUsersPageSize() int32
- func (x *UserManagementFeature) GetSupported() bool
- func (*UserManagementFeature) ProtoMessage()
- func (x *UserManagementFeature) ProtoReflect() protoreflect.Message
- func (x *UserManagementFeature) Reset()
- func (x *UserManagementFeature) String() string
- type Value
- func (*Value) Descriptor() ([]byte, []int)deprecated
- func (x *Value) GetBool() bool
- func (x *Value) GetContractId() string
- func (x *Value) GetDate() int32
- func (x *Value) GetEnum() *Enum
- func (x *Value) GetGenMap() *GenMap
- func (x *Value) GetInt64() int64
- func (x *Value) GetList() *List
- func (x *Value) GetNumeric() string
- func (x *Value) GetOptional() *Optional
- func (x *Value) GetParty() string
- func (x *Value) GetRecord() *Record
- func (x *Value) GetSum() isValue_Sum
- func (x *Value) GetText() string
- func (x *Value) GetTextMap() *TextMap
- func (x *Value) GetTimestamp() int64
- func (x *Value) GetUnit() *emptypb.Empty
- func (x *Value) GetVariant() *Variant
- func (*Value) ProtoMessage()
- func (x *Value) ProtoReflect() protoreflect.Message
- func (x *Value) Reset()
- func (x *Value) String() string
- type Value_Bool
- type Value_ContractId
- type Value_Date
- type Value_Enum
- type Value_GenMap
- type Value_Int64
- type Value_List
- type Value_Numeric
- type Value_Optional
- type Value_Party
- type Value_Record
- type Value_Text
- type Value_TextMap
- type Value_Timestamp
- type Value_Unit
- type Value_Variant
- type Variant
- func (*Variant) Descriptor() ([]byte, []int)deprecated
- func (x *Variant) GetConstructor() string
- func (x *Variant) GetValue() *Value
- func (x *Variant) GetVariantId() *Identifier
- func (*Variant) ProtoMessage()
- func (x *Variant) ProtoReflect() protoreflect.Message
- func (x *Variant) Reset()
- func (x *Variant) String() string
- type VersionServiceClient
- type VersionServiceServer
- type VettedPackage
- func (*VettedPackage) Descriptor() ([]byte, []int)deprecated
- func (x *VettedPackage) GetPackageId() string
- func (x *VettedPackage) GetPackageName() string
- func (x *VettedPackage) GetPackageVersion() string
- func (x *VettedPackage) GetValidFromInclusive() *timestamppb.Timestamp
- func (x *VettedPackage) GetValidUntilExclusive() *timestamppb.Timestamp
- func (*VettedPackage) ProtoMessage()
- func (x *VettedPackage) ProtoReflect() protoreflect.Message
- func (x *VettedPackage) Reset()
- func (x *VettedPackage) String() string
- type VettedPackages
- func (*VettedPackages) Descriptor() ([]byte, []int)deprecated
- func (x *VettedPackages) GetPackages() []*VettedPackage
- func (x *VettedPackages) GetParticipantId() string
- func (x *VettedPackages) GetSynchronizerId() string
- func (x *VettedPackages) GetTopologySerial() uint32
- func (*VettedPackages) ProtoMessage()
- func (x *VettedPackages) ProtoReflect() protoreflect.Message
- func (x *VettedPackages) Reset()
- func (x *VettedPackages) String() string
- type WildcardFilter
Constants ¶
const ( CommandService_SubmitAndWait_FullMethodName = "/com.daml.ledger.api.v2.CommandService/SubmitAndWait" CommandService_SubmitAndWaitForTransaction_FullMethodName = "/com.daml.ledger.api.v2.CommandService/SubmitAndWaitForTransaction" CommandService_SubmitAndWaitForReassignment_FullMethodName = "/com.daml.ledger.api.v2.CommandService/SubmitAndWaitForReassignment" )
const ( CommandSubmissionService_Submit_FullMethodName = "/com.daml.ledger.api.v2.CommandSubmissionService/Submit" CommandSubmissionService_SubmitReassignment_FullMethodName = "/com.daml.ledger.api.v2.CommandSubmissionService/SubmitReassignment" )
const ( PackageService_ListPackages_FullMethodName = "/com.daml.ledger.api.v2.PackageService/ListPackages" PackageService_GetPackage_FullMethodName = "/com.daml.ledger.api.v2.PackageService/GetPackage" PackageService_GetPackageStatus_FullMethodName = "/com.daml.ledger.api.v2.PackageService/GetPackageStatus" PackageService_ListVettedPackages_FullMethodName = "/com.daml.ledger.api.v2.PackageService/ListVettedPackages" )
const ( StateService_GetActiveContracts_FullMethodName = "/com.daml.ledger.api.v2.StateService/GetActiveContracts" StateService_GetConnectedSynchronizers_FullMethodName = "/com.daml.ledger.api.v2.StateService/GetConnectedSynchronizers" StateService_GetLedgerEnd_FullMethodName = "/com.daml.ledger.api.v2.StateService/GetLedgerEnd" StateService_GetLatestPrunedOffsets_FullMethodName = "/com.daml.ledger.api.v2.StateService/GetLatestPrunedOffsets" )
const ( UpdateService_GetUpdates_FullMethodName = "/com.daml.ledger.api.v2.UpdateService/GetUpdates" UpdateService_GetUpdateByOffset_FullMethodName = "/com.daml.ledger.api.v2.UpdateService/GetUpdateByOffset" UpdateService_GetUpdateById_FullMethodName = "/com.daml.ledger.api.v2.UpdateService/GetUpdateById" )
const (
CommandCompletionService_CompletionStream_FullMethodName = "/com.daml.ledger.api.v2.CommandCompletionService/CompletionStream"
)
const (
EventQueryService_GetEventsByContractId_FullMethodName = "/com.daml.ledger.api.v2.EventQueryService/GetEventsByContractId"
)
const (
VersionService_GetLedgerApiVersion_FullMethodName = "/com.daml.ledger.api.v2.VersionService/GetLedgerApiVersion"
)
Variables ¶
var ( SigningKeySpec_name = map[int32]string{ 0: "SIGNING_KEY_SPEC_UNSPECIFIED", 1: "SIGNING_KEY_SPEC_EC_CURVE25519", 2: "SIGNING_KEY_SPEC_EC_P256", 3: "SIGNING_KEY_SPEC_EC_P384", 4: "SIGNING_KEY_SPEC_EC_SECP256K1", } SigningKeySpec_value = map[string]int32{ "SIGNING_KEY_SPEC_UNSPECIFIED": 0, "SIGNING_KEY_SPEC_EC_CURVE25519": 1, "SIGNING_KEY_SPEC_EC_P256": 2, "SIGNING_KEY_SPEC_EC_P384": 3, "SIGNING_KEY_SPEC_EC_SECP256K1": 4, } )
Enum value maps for SigningKeySpec.
var ( CryptoKeyFormat_name = map[int32]string{ 0: "CRYPTO_KEY_FORMAT_UNSPECIFIED", 1: "CRYPTO_KEY_FORMAT_DER", 2: "CRYPTO_KEY_FORMAT_RAW", 3: "CRYPTO_KEY_FORMAT_DER_X509_SUBJECT_PUBLIC_KEY_INFO", } CryptoKeyFormat_value = map[string]int32{ "CRYPTO_KEY_FORMAT_UNSPECIFIED": 0, "CRYPTO_KEY_FORMAT_DER": 1, "CRYPTO_KEY_FORMAT_RAW": 2, "CRYPTO_KEY_FORMAT_DER_X509_SUBJECT_PUBLIC_KEY_INFO": 3, } )
Enum value maps for CryptoKeyFormat.
var ( SigningAlgorithmSpec_name = map[int32]string{ 0: "SIGNING_ALGORITHM_SPEC_UNSPECIFIED", 1: "SIGNING_ALGORITHM_SPEC_ED25519", 2: "SIGNING_ALGORITHM_SPEC_EC_DSA_SHA_256", 3: "SIGNING_ALGORITHM_SPEC_EC_DSA_SHA_384", } SigningAlgorithmSpec_value = map[string]int32{ "SIGNING_ALGORITHM_SPEC_UNSPECIFIED": 0, "SIGNING_ALGORITHM_SPEC_ED25519": 1, "SIGNING_ALGORITHM_SPEC_EC_DSA_SHA_256": 2, "SIGNING_ALGORITHM_SPEC_EC_DSA_SHA_384": 3, } )
Enum value maps for SigningAlgorithmSpec.
var ( SignatureFormat_name = map[int32]string{ 0: "SIGNATURE_FORMAT_UNSPECIFIED", 1: "SIGNATURE_FORMAT_RAW", 2: "SIGNATURE_FORMAT_DER", 3: "SIGNATURE_FORMAT_CONCAT", 10000: "SIGNATURE_FORMAT_SYMBOLIC", } SignatureFormat_value = map[string]int32{ "SIGNATURE_FORMAT_UNSPECIFIED": 0, "SIGNATURE_FORMAT_RAW": 1, "SIGNATURE_FORMAT_DER": 2, "SIGNATURE_FORMAT_CONCAT": 3, "SIGNATURE_FORMAT_SYMBOLIC": 10000, } )
Enum value maps for SignatureFormat.
var ( PackageStatus_name = map[int32]string{ 0: "PACKAGE_STATUS_UNSPECIFIED", 1: "PACKAGE_STATUS_REGISTERED", } PackageStatus_value = map[string]int32{ "PACKAGE_STATUS_UNSPECIFIED": 0, "PACKAGE_STATUS_REGISTERED": 1, } )
Enum value maps for PackageStatus.
var ( HashFunction_name = map[int32]string{ 0: "HASH_FUNCTION_SHA256", } HashFunction_value = map[string]int32{ "HASH_FUNCTION_SHA256": 0, } )
Enum value maps for HashFunction.
var ( ParticipantPermission_name = map[int32]string{ 0: "PARTICIPANT_PERMISSION_UNSPECIFIED", 1: "PARTICIPANT_PERMISSION_SUBMISSION", 2: "PARTICIPANT_PERMISSION_CONFIRMATION", 3: "PARTICIPANT_PERMISSION_OBSERVATION", } ParticipantPermission_value = map[string]int32{ "PARTICIPANT_PERMISSION_UNSPECIFIED": 0, "PARTICIPANT_PERMISSION_SUBMISSION": 1, "PARTICIPANT_PERMISSION_CONFIRMATION": 2, "PARTICIPANT_PERMISSION_OBSERVATION": 3, } )
Enum value maps for ParticipantPermission.
var ( TransactionShape_name = map[int32]string{ 0: "TRANSACTION_SHAPE_UNSPECIFIED", 1: "TRANSACTION_SHAPE_ACS_DELTA", 2: "TRANSACTION_SHAPE_LEDGER_EFFECTS", } TransactionShape_value = map[string]int32{ "TRANSACTION_SHAPE_UNSPECIFIED": 0, "TRANSACTION_SHAPE_ACS_DELTA": 1, "TRANSACTION_SHAPE_LEDGER_EFFECTS": 2, } )
Enum value maps for TransactionShape.
var CommandCompletionService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "com.daml.ledger.api.v2.CommandCompletionService", HandlerType: (*CommandCompletionServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "CompletionStream", Handler: _CommandCompletionService_CompletionStream_Handler, ServerStreams: true, }, }, Metadata: "com/daml/ledger/api/v2/command_completion_service.proto", }
CommandCompletionService_ServiceDesc is the grpc.ServiceDesc for CommandCompletionService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var CommandService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "com.daml.ledger.api.v2.CommandService", HandlerType: (*CommandServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SubmitAndWait", Handler: _CommandService_SubmitAndWait_Handler, }, { MethodName: "SubmitAndWaitForTransaction", Handler: _CommandService_SubmitAndWaitForTransaction_Handler, }, { MethodName: "SubmitAndWaitForReassignment", Handler: _CommandService_SubmitAndWaitForReassignment_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "com/daml/ledger/api/v2/command_service.proto", }
CommandService_ServiceDesc is the grpc.ServiceDesc for CommandService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var CommandSubmissionService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "com.daml.ledger.api.v2.CommandSubmissionService", HandlerType: (*CommandSubmissionServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Submit", Handler: _CommandSubmissionService_Submit_Handler, }, { MethodName: "SubmitReassignment", Handler: _CommandSubmissionService_SubmitReassignment_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "com/daml/ledger/api/v2/command_submission_service.proto", }
CommandSubmissionService_ServiceDesc is the grpc.ServiceDesc for CommandSubmissionService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var EventQueryService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "com.daml.ledger.api.v2.EventQueryService", HandlerType: (*EventQueryServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetEventsByContractId", Handler: _EventQueryService_GetEventsByContractId_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "com/daml/ledger/api/v2/event_query_service.proto", }
EventQueryService_ServiceDesc is the grpc.ServiceDesc for EventQueryService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_com_daml_ledger_api_v2_command_completion_service_proto protoreflect.FileDescriptor
var File_com_daml_ledger_api_v2_command_service_proto protoreflect.FileDescriptor
var File_com_daml_ledger_api_v2_command_submission_service_proto protoreflect.FileDescriptor
var File_com_daml_ledger_api_v2_commands_proto protoreflect.FileDescriptor
var File_com_daml_ledger_api_v2_completion_proto protoreflect.FileDescriptor
var File_com_daml_ledger_api_v2_crypto_proto protoreflect.FileDescriptor
var File_com_daml_ledger_api_v2_event_proto protoreflect.FileDescriptor
var File_com_daml_ledger_api_v2_event_query_service_proto protoreflect.FileDescriptor
var File_com_daml_ledger_api_v2_experimental_features_proto protoreflect.FileDescriptor
var File_com_daml_ledger_api_v2_offset_checkpoint_proto protoreflect.FileDescriptor
var File_com_daml_ledger_api_v2_package_reference_proto protoreflect.FileDescriptor
var File_com_daml_ledger_api_v2_package_service_proto protoreflect.FileDescriptor
var File_com_daml_ledger_api_v2_reassignment_commands_proto protoreflect.FileDescriptor
var File_com_daml_ledger_api_v2_reassignment_proto protoreflect.FileDescriptor
var File_com_daml_ledger_api_v2_state_service_proto protoreflect.FileDescriptor
var File_com_daml_ledger_api_v2_topology_transaction_proto protoreflect.FileDescriptor
var File_com_daml_ledger_api_v2_trace_context_proto protoreflect.FileDescriptor
var File_com_daml_ledger_api_v2_transaction_filter_proto protoreflect.FileDescriptor
var File_com_daml_ledger_api_v2_transaction_proto protoreflect.FileDescriptor
var File_com_daml_ledger_api_v2_update_service_proto protoreflect.FileDescriptor
var File_com_daml_ledger_api_v2_value_proto protoreflect.FileDescriptor
var File_com_daml_ledger_api_v2_version_service_proto protoreflect.FileDescriptor
var PackageService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "com.daml.ledger.api.v2.PackageService", HandlerType: (*PackageServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ListPackages", Handler: _PackageService_ListPackages_Handler, }, { MethodName: "GetPackage", Handler: _PackageService_GetPackage_Handler, }, { MethodName: "GetPackageStatus", Handler: _PackageService_GetPackageStatus_Handler, }, { MethodName: "ListVettedPackages", Handler: _PackageService_ListVettedPackages_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "com/daml/ledger/api/v2/package_service.proto", }
PackageService_ServiceDesc is the grpc.ServiceDesc for PackageService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var StateService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "com.daml.ledger.api.v2.StateService", HandlerType: (*StateServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetConnectedSynchronizers", Handler: _StateService_GetConnectedSynchronizers_Handler, }, { MethodName: "GetLedgerEnd", Handler: _StateService_GetLedgerEnd_Handler, }, { MethodName: "GetLatestPrunedOffsets", Handler: _StateService_GetLatestPrunedOffsets_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "GetActiveContracts", Handler: _StateService_GetActiveContracts_Handler, ServerStreams: true, }, }, Metadata: "com/daml/ledger/api/v2/state_service.proto", }
StateService_ServiceDesc is the grpc.ServiceDesc for StateService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var UpdateService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "com.daml.ledger.api.v2.UpdateService", HandlerType: (*UpdateServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetUpdateByOffset", Handler: _UpdateService_GetUpdateByOffset_Handler, }, { MethodName: "GetUpdateById", Handler: _UpdateService_GetUpdateById_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "GetUpdates", Handler: _UpdateService_GetUpdates_Handler, ServerStreams: true, }, }, Metadata: "com/daml/ledger/api/v2/update_service.proto", }
UpdateService_ServiceDesc is the grpc.ServiceDesc for UpdateService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var VersionService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "com.daml.ledger.api.v2.VersionService", HandlerType: (*VersionServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetLedgerApiVersion", Handler: _VersionService_GetLedgerApiVersion_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "com/daml/ledger/api/v2/version_service.proto", }
VersionService_ServiceDesc is the grpc.ServiceDesc for VersionService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterCommandCompletionServiceServer ¶
func RegisterCommandCompletionServiceServer(s grpc.ServiceRegistrar, srv CommandCompletionServiceServer)
func RegisterCommandServiceServer ¶
func RegisterCommandServiceServer(s grpc.ServiceRegistrar, srv CommandServiceServer)
func RegisterCommandSubmissionServiceServer ¶
func RegisterCommandSubmissionServiceServer(s grpc.ServiceRegistrar, srv CommandSubmissionServiceServer)
func RegisterEventQueryServiceServer ¶
func RegisterEventQueryServiceServer(s grpc.ServiceRegistrar, srv EventQueryServiceServer)
func RegisterPackageServiceServer ¶
func RegisterPackageServiceServer(s grpc.ServiceRegistrar, srv PackageServiceServer)
func RegisterStateServiceServer ¶
func RegisterStateServiceServer(s grpc.ServiceRegistrar, srv StateServiceServer)
func RegisterUpdateServiceServer ¶
func RegisterUpdateServiceServer(s grpc.ServiceRegistrar, srv UpdateServiceServer)
func RegisterVersionServiceServer ¶
func RegisterVersionServiceServer(s grpc.ServiceRegistrar, srv VersionServiceServer)
Types ¶
type ActiveContract ¶
type ActiveContract struct {
// Required
// The event as it appeared in the context of its last update (i.e. daml transaction or
// reassignment). In particular, the last offset, node_id pair is preserved.
// The last update is the most recent update created or assigned this contract on synchronizer_id synchronizer.
// The offset of the CreatedEvent might point to an already pruned update, therefore it cannot necessarily be used
// for lookups.
CreatedEvent *CreatedEvent `protobuf:"bytes,1,opt,name=created_event,json=createdEvent,proto3" json:"created_event,omitempty"`
// A valid synchronizer id
// Required
SynchronizerId string `protobuf:"bytes,2,opt,name=synchronizer_id,json=synchronizerId,proto3" json:"synchronizer_id,omitempty"`
// Each corresponding assigned and unassigned event has the same reassignment_counter. This strictly increases
// with each unassign command for the same contract. Creation of the contract corresponds to reassignment_counter
// equals zero.
// This field will be the reassignment_counter of the latest observable activation event on this synchronizer, which is
// before the active_at_offset.
// Required
ReassignmentCounter uint64 `protobuf:"varint,3,opt,name=reassignment_counter,json=reassignmentCounter,proto3" json:"reassignment_counter,omitempty"`
// contains filtered or unexported fields
}
func (*ActiveContract) Descriptor
deprecated
func (*ActiveContract) Descriptor() ([]byte, []int)
Deprecated: Use ActiveContract.ProtoReflect.Descriptor instead.
func (*ActiveContract) GetCreatedEvent ¶
func (x *ActiveContract) GetCreatedEvent() *CreatedEvent
func (*ActiveContract) GetReassignmentCounter ¶
func (x *ActiveContract) GetReassignmentCounter() uint64
func (*ActiveContract) GetSynchronizerId ¶
func (x *ActiveContract) GetSynchronizerId() string
func (*ActiveContract) ProtoMessage ¶
func (*ActiveContract) ProtoMessage()
func (*ActiveContract) ProtoReflect ¶
func (x *ActiveContract) ProtoReflect() protoreflect.Message
func (*ActiveContract) Reset ¶
func (x *ActiveContract) Reset()
func (*ActiveContract) String ¶
func (x *ActiveContract) String() string
type Archived ¶
type Archived struct {
// Required
ArchivedEvent *ArchivedEvent `protobuf:"bytes,1,opt,name=archived_event,json=archivedEvent,proto3" json:"archived_event,omitempty"`
// Required
// The synchronizer which sequenced the archival of the contract
SynchronizerId string `protobuf:"bytes,2,opt,name=synchronizer_id,json=synchronizerId,proto3" json:"synchronizer_id,omitempty"`
// contains filtered or unexported fields
}
func (*Archived) Descriptor
deprecated
func (*Archived) GetArchivedEvent ¶
func (x *Archived) GetArchivedEvent() *ArchivedEvent
func (*Archived) GetSynchronizerId ¶
func (*Archived) ProtoMessage ¶
func (*Archived) ProtoMessage()
func (*Archived) ProtoReflect ¶
func (x *Archived) ProtoReflect() protoreflect.Message
type ArchivedEvent ¶
type ArchivedEvent struct {
// The offset of origin.
// Offsets are managed by the participant nodes.
// Transactions can thus NOT be assumed to have the same offsets on different participant nodes.
// Required, it is a valid absolute offset (positive integer)
Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
// The position of this event in the originating transaction or reassignment.
// Node IDs are not necessarily equal across participants,
// as these may see different projections/parts of transactions.
// Required, must be valid node ID (non-negative integer)
NodeId int32 `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
// The ID of the archived contract.
// Must be a valid LedgerString (as described in “value.proto“).
// Required
ContractId string `protobuf:"bytes,3,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
// Identifies the template that defines the choice that archived the contract.
// This template's package-id may differ from the target contract's package-id
// if the target contract has been upgraded or downgraded.
//
// The identifier uses the package-id reference format.
//
// Required
TemplateId *Identifier `protobuf:"bytes,4,opt,name=template_id,json=templateId,proto3" json:"template_id,omitempty"`
// The parties that are notified of this event. For an “ArchivedEvent“,
// these are the intersection of the stakeholders of the contract in
// question and the parties specified in the “TransactionFilter“. The
// stakeholders are the union of the signatories and the observers of
// the contract.
// Each one of its elements must be a valid PartyIdString (as described
// in “value.proto“).
// Required
WitnessParties []string `protobuf:"bytes,5,rep,name=witness_parties,json=witnessParties,proto3" json:"witness_parties,omitempty"`
// The package name of the contract.
// Required
PackageName string `protobuf:"bytes,6,opt,name=package_name,json=packageName,proto3" json:"package_name,omitempty"`
// The interfaces implemented by the target template that have been
// matched from the interface filter query.
// Populated only in case interface filters with include_interface_view set.
//
// If defined, the identifier uses the package-id reference format.
//
// Optional
ImplementedInterfaces []*Identifier `protobuf:"bytes,7,rep,name=implemented_interfaces,json=implementedInterfaces,proto3" json:"implemented_interfaces,omitempty"`
// contains filtered or unexported fields
}
Records that a contract has been archived, and choices may no longer be exercised on it.
func (*ArchivedEvent) Descriptor
deprecated
func (*ArchivedEvent) Descriptor() ([]byte, []int)
Deprecated: Use ArchivedEvent.ProtoReflect.Descriptor instead.
func (*ArchivedEvent) GetContractId ¶
func (x *ArchivedEvent) GetContractId() string
func (*ArchivedEvent) GetImplementedInterfaces ¶
func (x *ArchivedEvent) GetImplementedInterfaces() []*Identifier
func (*ArchivedEvent) GetNodeId ¶
func (x *ArchivedEvent) GetNodeId() int32
func (*ArchivedEvent) GetOffset ¶
func (x *ArchivedEvent) GetOffset() int64
func (*ArchivedEvent) GetPackageName ¶
func (x *ArchivedEvent) GetPackageName() string
func (*ArchivedEvent) GetTemplateId ¶
func (x *ArchivedEvent) GetTemplateId() *Identifier
func (*ArchivedEvent) GetWitnessParties ¶
func (x *ArchivedEvent) GetWitnessParties() []string
func (*ArchivedEvent) ProtoMessage ¶
func (*ArchivedEvent) ProtoMessage()
func (*ArchivedEvent) ProtoReflect ¶
func (x *ArchivedEvent) ProtoReflect() protoreflect.Message
func (*ArchivedEvent) Reset ¶
func (x *ArchivedEvent) Reset()
func (*ArchivedEvent) String ¶
func (x *ArchivedEvent) String() string
type AssignCommand ¶
type AssignCommand struct {
// The ID from the unassigned event to be completed by this assignment.
// Must be a valid LedgerString (as described in “value.proto“).
// Required
ReassignmentId string `protobuf:"bytes,1,opt,name=reassignment_id,json=reassignmentId,proto3" json:"reassignment_id,omitempty"`
// The ID of the source synchronizer
// Must be a valid synchronizer id
// Required
Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
// The ID of the target synchronizer
// Must be a valid synchronizer id
// Required
Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
// contains filtered or unexported fields
}
Assign a contract
func (*AssignCommand) Descriptor
deprecated
func (*AssignCommand) Descriptor() ([]byte, []int)
Deprecated: Use AssignCommand.ProtoReflect.Descriptor instead.
func (*AssignCommand) GetReassignmentId ¶
func (x *AssignCommand) GetReassignmentId() string
func (*AssignCommand) GetSource ¶
func (x *AssignCommand) GetSource() string
func (*AssignCommand) GetTarget ¶
func (x *AssignCommand) GetTarget() string
func (*AssignCommand) ProtoMessage ¶
func (*AssignCommand) ProtoMessage()
func (*AssignCommand) ProtoReflect ¶
func (x *AssignCommand) ProtoReflect() protoreflect.Message
func (*AssignCommand) Reset ¶
func (x *AssignCommand) Reset()
func (*AssignCommand) String ¶
func (x *AssignCommand) String() string
type AssignedEvent ¶
type AssignedEvent struct {
// The ID of the source synchronizer.
// Must be a valid synchronizer id.
// Required
Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
// The ID of the target synchronizer.
// Must be a valid synchronizer id.
// Required
Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
// The ID from the unassigned event.
// For correlation capabilities.
// Must be a valid LedgerString (as described in “value.proto“).
// Required
ReassignmentId string `protobuf:"bytes,3,opt,name=reassignment_id,json=reassignmentId,proto3" json:"reassignment_id,omitempty"`
// Party on whose behalf the assign command was executed.
// Empty if the assignment happened offline via the repair service.
// Must be a valid PartyIdString (as described in “value.proto“).
// Optional
Submitter string `protobuf:"bytes,4,opt,name=submitter,proto3" json:"submitter,omitempty"`
// Each corresponding assigned and unassigned event has the same reassignment_counter. This strictly increases
// with each unassign command for the same contract. Creation of the contract corresponds to reassignment_counter
// equals zero.
// Required
ReassignmentCounter uint64 `protobuf:"varint,5,opt,name=reassignment_counter,json=reassignmentCounter,proto3" json:"reassignment_counter,omitempty"`
// Required
// The offset of this event refers to the offset of the assignment,
// while the node_id is the index of within the batch.
CreatedEvent *CreatedEvent `protobuf:"bytes,6,opt,name=created_event,json=createdEvent,proto3" json:"created_event,omitempty"`
// contains filtered or unexported fields
}
Records that a contract has been assigned, and it can be used on the target synchronizer.
func (*AssignedEvent) Descriptor
deprecated
func (*AssignedEvent) Descriptor() ([]byte, []int)
Deprecated: Use AssignedEvent.ProtoReflect.Descriptor instead.
func (*AssignedEvent) GetCreatedEvent ¶
func (x *AssignedEvent) GetCreatedEvent() *CreatedEvent
func (*AssignedEvent) GetReassignmentCounter ¶
func (x *AssignedEvent) GetReassignmentCounter() uint64
func (*AssignedEvent) GetReassignmentId ¶
func (x *AssignedEvent) GetReassignmentId() string
func (*AssignedEvent) GetSource ¶
func (x *AssignedEvent) GetSource() string
func (*AssignedEvent) GetSubmitter ¶
func (x *AssignedEvent) GetSubmitter() string
func (*AssignedEvent) GetTarget ¶
func (x *AssignedEvent) GetTarget() string
func (*AssignedEvent) ProtoMessage ¶
func (*AssignedEvent) ProtoMessage()
func (*AssignedEvent) ProtoReflect ¶
func (x *AssignedEvent) ProtoReflect() protoreflect.Message
func (*AssignedEvent) Reset ¶
func (x *AssignedEvent) Reset()
func (*AssignedEvent) String ¶
func (x *AssignedEvent) String() string
type Command ¶
type Command struct {
// Types that are valid to be assigned to Command:
//
// *Command_Create
// *Command_Exercise
// *Command_ExerciseByKey
// *Command_CreateAndExercise
Command isCommand_Command `protobuf_oneof:"command"`
// contains filtered or unexported fields
}
A command can either create a new contract or exercise a choice on an existing contract.
func (*Command) Descriptor
deprecated
func (*Command) GetCommand ¶
func (x *Command) GetCommand() isCommand_Command
func (*Command) GetCreate ¶
func (x *Command) GetCreate() *CreateCommand
func (*Command) GetCreateAndExercise ¶
func (x *Command) GetCreateAndExercise() *CreateAndExerciseCommand
func (*Command) GetExercise ¶
func (x *Command) GetExercise() *ExerciseCommand
func (*Command) GetExerciseByKey ¶
func (x *Command) GetExerciseByKey() *ExerciseByKeyCommand
func (*Command) ProtoMessage ¶
func (*Command) ProtoMessage()
func (*Command) ProtoReflect ¶
func (x *Command) ProtoReflect() protoreflect.Message
type CommandCompletionServiceClient ¶
type CommandCompletionServiceClient interface {
// Subscribe to command completion events.
CompletionStream(ctx context.Context, in *CompletionStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[CompletionStreamResponse], error)
}
CommandCompletionServiceClient is the client API for CommandCompletionService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
Allows clients to observe the status of their submissions. Commands may be submitted via the Command Submission Service. The on-ledger effects of their submissions are disclosed by the Update Service.
Commands may fail in 2 distinct manners:
1. Failure communicated synchronously in the gRPC error of the submission. 2. Failure communicated asynchronously in a Completion, see “completion.proto“.
Note that not only successfully submitted commands MAY produce a completion event. For example, the participant MAY choose to produce a completion event for a rejection of a duplicate command.
Clients that do not receive a successful completion about their submission MUST NOT assume that it was successful. Clients SHOULD subscribe to the CompletionStream before starting to submit commands to prevent race conditions.
func NewCommandCompletionServiceClient ¶
func NewCommandCompletionServiceClient(cc grpc.ClientConnInterface) CommandCompletionServiceClient
type CommandCompletionServiceServer ¶
type CommandCompletionServiceServer interface {
// Subscribe to command completion events.
CompletionStream(*CompletionStreamRequest, grpc.ServerStreamingServer[CompletionStreamResponse]) error
// contains filtered or unexported methods
}
CommandCompletionServiceServer is the server API for CommandCompletionService service. All implementations must embed UnimplementedCommandCompletionServiceServer for forward compatibility.
Allows clients to observe the status of their submissions. Commands may be submitted via the Command Submission Service. The on-ledger effects of their submissions are disclosed by the Update Service.
Commands may fail in 2 distinct manners:
1. Failure communicated synchronously in the gRPC error of the submission. 2. Failure communicated asynchronously in a Completion, see “completion.proto“.
Note that not only successfully submitted commands MAY produce a completion event. For example, the participant MAY choose to produce a completion event for a rejection of a duplicate command.
Clients that do not receive a successful completion about their submission MUST NOT assume that it was successful. Clients SHOULD subscribe to the CompletionStream before starting to submit commands to prevent race conditions.
type CommandCompletionService_CompletionStreamClient ¶
type CommandCompletionService_CompletionStreamClient = grpc.ServerStreamingClient[CompletionStreamResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type CommandCompletionService_CompletionStreamServer ¶
type CommandCompletionService_CompletionStreamServer = grpc.ServerStreamingServer[CompletionStreamResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type CommandServiceClient ¶
type CommandServiceClient interface {
// Submits a single composite command and waits for its result.
// Propagates the gRPC error of failed submissions including Daml interpretation errors.
SubmitAndWait(ctx context.Context, in *SubmitAndWaitRequest, opts ...grpc.CallOption) (*SubmitAndWaitResponse, error)
// Submits a single composite command, waits for its result, and returns the transaction.
// Propagates the gRPC error of failed submissions including Daml interpretation errors.
SubmitAndWaitForTransaction(ctx context.Context, in *SubmitAndWaitForTransactionRequest, opts ...grpc.CallOption) (*SubmitAndWaitForTransactionResponse, error)
// Submits a single composite reassignment command, waits for its result, and returns the reassignment.
// Propagates the gRPC error of failed submission.
SubmitAndWaitForReassignment(ctx context.Context, in *SubmitAndWaitForReassignmentRequest, opts ...grpc.CallOption) (*SubmitAndWaitForReassignmentResponse, error)
}
CommandServiceClient is the client API for CommandService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
Command Service is able to correlate submitted commands with completion data, identify timeouts, and return contextual information with each tracking result. This supports the implementation of stateless clients.
Note that submitted commands generally produce completion events as well, even in case a command gets rejected. For example, the participant SHOULD produce a completion event for a rejection of a duplicate command.
func NewCommandServiceClient ¶
func NewCommandServiceClient(cc grpc.ClientConnInterface) CommandServiceClient
type CommandServiceServer ¶
type CommandServiceServer interface {
// Submits a single composite command and waits for its result.
// Propagates the gRPC error of failed submissions including Daml interpretation errors.
SubmitAndWait(context.Context, *SubmitAndWaitRequest) (*SubmitAndWaitResponse, error)
// Submits a single composite command, waits for its result, and returns the transaction.
// Propagates the gRPC error of failed submissions including Daml interpretation errors.
SubmitAndWaitForTransaction(context.Context, *SubmitAndWaitForTransactionRequest) (*SubmitAndWaitForTransactionResponse, error)
// Submits a single composite reassignment command, waits for its result, and returns the reassignment.
// Propagates the gRPC error of failed submission.
SubmitAndWaitForReassignment(context.Context, *SubmitAndWaitForReassignmentRequest) (*SubmitAndWaitForReassignmentResponse, error)
// contains filtered or unexported methods
}
CommandServiceServer is the server API for CommandService service. All implementations must embed UnimplementedCommandServiceServer for forward compatibility.
Command Service is able to correlate submitted commands with completion data, identify timeouts, and return contextual information with each tracking result. This supports the implementation of stateless clients.
Note that submitted commands generally produce completion events as well, even in case a command gets rejected. For example, the participant SHOULD produce a completion event for a rejection of a duplicate command.
type CommandSubmissionServiceClient ¶
type CommandSubmissionServiceClient interface {
// Submit a single composite command.
Submit(ctx context.Context, in *SubmitRequest, opts ...grpc.CallOption) (*SubmitResponse, error)
// Submit a single reassignment.
SubmitReassignment(ctx context.Context, in *SubmitReassignmentRequest, opts ...grpc.CallOption) (*SubmitReassignmentResponse, error)
}
CommandSubmissionServiceClient is the client API for CommandSubmissionService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
Allows clients to attempt advancing the ledger's state by submitting commands. The final states of their submissions are disclosed by the Command Completion Service. The on-ledger effects of their submissions are disclosed by the Update Service.
Commands may fail in 2 distinct manners:
1. Failure communicated synchronously in the gRPC error of the submission. 2. Failure communicated asynchronously in a Completion, see “completion.proto“.
Note that not only successfully submitted commands MAY produce a completion event. For example, the participant MAY choose to produce a completion event for a rejection of a duplicate command.
Clients that do not receive a successful completion about their submission MUST NOT assume that it was successful. Clients SHOULD subscribe to the CompletionStream before starting to submit commands to prevent race conditions.
func NewCommandSubmissionServiceClient ¶
func NewCommandSubmissionServiceClient(cc grpc.ClientConnInterface) CommandSubmissionServiceClient
type CommandSubmissionServiceServer ¶
type CommandSubmissionServiceServer interface {
// Submit a single composite command.
Submit(context.Context, *SubmitRequest) (*SubmitResponse, error)
// Submit a single reassignment.
SubmitReassignment(context.Context, *SubmitReassignmentRequest) (*SubmitReassignmentResponse, error)
// contains filtered or unexported methods
}
CommandSubmissionServiceServer is the server API for CommandSubmissionService service. All implementations must embed UnimplementedCommandSubmissionServiceServer for forward compatibility.
Allows clients to attempt advancing the ledger's state by submitting commands. The final states of their submissions are disclosed by the Command Completion Service. The on-ledger effects of their submissions are disclosed by the Update Service.
Commands may fail in 2 distinct manners:
1. Failure communicated synchronously in the gRPC error of the submission. 2. Failure communicated asynchronously in a Completion, see “completion.proto“.
Note that not only successfully submitted commands MAY produce a completion event. For example, the participant MAY choose to produce a completion event for a rejection of a duplicate command.
Clients that do not receive a successful completion about their submission MUST NOT assume that it was successful. Clients SHOULD subscribe to the CompletionStream before starting to submit commands to prevent race conditions.
type Command_Create ¶
type Command_Create struct {
Create *CreateCommand `protobuf:"bytes,1,opt,name=create,proto3,oneof"`
}
type Command_CreateAndExercise ¶
type Command_CreateAndExercise struct {
CreateAndExercise *CreateAndExerciseCommand `protobuf:"bytes,3,opt,name=create_and_exercise,json=createAndExercise,proto3,oneof"`
}
type Command_Exercise ¶
type Command_Exercise struct {
Exercise *ExerciseCommand `protobuf:"bytes,2,opt,name=exercise,proto3,oneof"`
}
type Command_ExerciseByKey ¶
type Command_ExerciseByKey struct {
ExerciseByKey *ExerciseByKeyCommand `protobuf:"bytes,4,opt,name=exercise_by_key,json=exerciseByKey,proto3,oneof"`
}
type Commands ¶
type Commands struct {
// Identifier of the on-ledger workflow that this command is a part of.
// Must be a valid LedgerString (as described in “value.proto“).
// Optional
WorkflowId string `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
// Uniquely identifies the participant user that issued the command.
// Must be a valid UserIdString (as described in “value.proto“).
// Required unless authentication is used with a user token.
// In that case, the token's user-id will be used for the request's user_id.
UserId string `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
// Uniquely identifies the command.
// The triple (user_id, act_as, command_id) constitutes the change ID for the intended ledger change,
// where act_as is interpreted as a set of party names.
// The change ID can be used for matching the intended ledger changes with all their completions.
// Must be a valid LedgerString (as described in “value.proto“).
// Required
CommandId string `protobuf:"bytes,3,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
// Individual elements of this atomic command. Must be non-empty.
// Required
Commands []*Command `protobuf:"bytes,4,rep,name=commands,proto3" json:"commands,omitempty"`
// Specifies the deduplication period for the change ID.
// If omitted, the participant will assume the configured maximum deduplication time.
//
// Types that are valid to be assigned to DeduplicationPeriod:
//
// *Commands_DeduplicationDuration
// *Commands_DeduplicationOffset
DeduplicationPeriod isCommands_DeduplicationPeriod `protobuf_oneof:"deduplication_period"`
// Lower bound for the ledger time assigned to the resulting transaction.
// Note: The ledger time of a transaction is assigned as part of command interpretation.
// Use this property if you expect that command interpretation will take a considerate amount of time, such that by
// the time the resulting transaction is sequenced, its assigned ledger time is not valid anymore.
// Must not be set at the same time as min_ledger_time_rel.
// Optional
MinLedgerTimeAbs *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=min_ledger_time_abs,json=minLedgerTimeAbs,proto3" json:"min_ledger_time_abs,omitempty"`
// Same as min_ledger_time_abs, but specified as a duration, starting from the time the command is received by the server.
// Must not be set at the same time as min_ledger_time_abs.
// Optional
MinLedgerTimeRel *durationpb.Duration `protobuf:"bytes,8,opt,name=min_ledger_time_rel,json=minLedgerTimeRel,proto3" json:"min_ledger_time_rel,omitempty"`
// Set of parties on whose behalf the command should be executed.
// If ledger API authorization is enabled, then the authorization metadata must authorize the sender of the request
// to act on behalf of each of the given parties.
// Each element must be a valid PartyIdString (as described in “value.proto“).
// Required, must be non-empty.
ActAs []string `protobuf:"bytes,9,rep,name=act_as,json=actAs,proto3" json:"act_as,omitempty"`
// Set of parties on whose behalf (in addition to all parties listed in “act_as“) contracts can be retrieved.
// This affects Daml operations such as “fetch“, “fetchByKey“, “lookupByKey“, “exercise“, and “exerciseByKey“.
// Note: A participant node of a Daml network can host multiple parties. Each contract present on the participant
// node is only visible to a subset of these parties. A command can only use contracts that are visible to at least
// one of the parties in “act_as“ or “read_as“. This visibility check is independent from the Daml authorization
// rules for fetch operations.
// If ledger API authorization is enabled, then the authorization metadata must authorize the sender of the request
// to read contract data on behalf of each of the given parties.
// Optional
ReadAs []string `protobuf:"bytes,10,rep,name=read_as,json=readAs,proto3" json:"read_as,omitempty"`
// A unique identifier to distinguish completions for different submissions with the same change ID.
// Typically a random UUID. Applications are expected to use a different UUID for each retry of a submission
// with the same change ID.
// Must be a valid LedgerString (as described in “value.proto“).
//
// If omitted, the participant or the committer may set a value of their choice.
// Optional
SubmissionId string `protobuf:"bytes,11,opt,name=submission_id,json=submissionId,proto3" json:"submission_id,omitempty"`
// Additional contracts used to resolve contract & contract key lookups.
// Optional
DisclosedContracts []*DisclosedContract `protobuf:"bytes,12,rep,name=disclosed_contracts,json=disclosedContracts,proto3" json:"disclosed_contracts,omitempty"`
// Must be a valid synchronizer id
// Optional
SynchronizerId string `protobuf:"bytes,13,opt,name=synchronizer_id,json=synchronizerId,proto3" json:"synchronizer_id,omitempty"`
// The package-id selection preference of the client for resolving
// package names and interface instances in command submission and interpretation
PackageIdSelectionPreference []string `` /* 150-byte string literal not displayed */
// Fetches the contract keys into the caches to speed up the command processing.
// Should only contain contract keys that are expected to be resolved during interpretation of the commands.
// Keys of disclosed contracts do not need prefetching.
//
// Optional
PrefetchContractKeys []*PrefetchContractKey `protobuf:"bytes,15,rep,name=prefetch_contract_keys,json=prefetchContractKeys,proto3" json:"prefetch_contract_keys,omitempty"`
// contains filtered or unexported fields
}
A composite command that groups multiple commands together.
func (*Commands) Descriptor
deprecated
func (*Commands) GetCommandId ¶
func (*Commands) GetCommands ¶
func (*Commands) GetDeduplicationDuration ¶
func (x *Commands) GetDeduplicationDuration() *durationpb.Duration
func (*Commands) GetDeduplicationOffset ¶
func (*Commands) GetDeduplicationPeriod ¶
func (x *Commands) GetDeduplicationPeriod() isCommands_DeduplicationPeriod
func (*Commands) GetDisclosedContracts ¶
func (x *Commands) GetDisclosedContracts() []*DisclosedContract
func (*Commands) GetMinLedgerTimeAbs ¶
func (x *Commands) GetMinLedgerTimeAbs() *timestamppb.Timestamp
func (*Commands) GetMinLedgerTimeRel ¶
func (x *Commands) GetMinLedgerTimeRel() *durationpb.Duration
func (*Commands) GetPackageIdSelectionPreference ¶
func (*Commands) GetPrefetchContractKeys ¶
func (x *Commands) GetPrefetchContractKeys() []*PrefetchContractKey
func (*Commands) GetSubmissionId ¶
func (*Commands) GetSynchronizerId ¶
func (*Commands) GetWorkflowId ¶
func (*Commands) ProtoMessage ¶
func (*Commands) ProtoMessage()
func (*Commands) ProtoReflect ¶
func (x *Commands) ProtoReflect() protoreflect.Message
type Commands_DeduplicationDuration ¶
type Commands_DeduplicationDuration struct {
// Specifies the length of the deduplication period.
// It is interpreted relative to the local clock at some point during the submission's processing.
// Must be non-negative. Must not exceed the maximum deduplication time.
DeduplicationDuration *durationpb.Duration `protobuf:"bytes,5,opt,name=deduplication_duration,json=deduplicationDuration,proto3,oneof"`
}
type Commands_DeduplicationOffset ¶
type Commands_DeduplicationOffset struct {
// Specifies the start of the deduplication period by a completion stream offset (exclusive).
// Must be a valid absolute offset (positive integer) or participant begin (zero).
DeduplicationOffset int64 `protobuf:"varint,6,opt,name=deduplication_offset,json=deduplicationOffset,proto3,oneof"`
}
type Completion ¶
type Completion struct {
// The ID of the succeeded or failed command.
// Must be a valid LedgerString (as described in “value.proto“).
// Required
CommandId string `protobuf:"bytes,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
// Identifies the exact type of the error.
// It uses the same format of conveying error details as it is used for the RPC responses of the APIs.
// Optional
Status *status.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
// The update_id of the transaction or reassignment that resulted from the command with command_id.
// Only set for successfully executed commands.
// Must be a valid LedgerString (as described in “value.proto“).
UpdateId string `protobuf:"bytes,3,opt,name=update_id,json=updateId,proto3" json:"update_id,omitempty"`
// The user-id that was used for the submission, as described in “commands.proto“.
// Must be a valid UserIdString (as described in “value.proto“).
// Optional for historic completions where this data is not available.
UserId string `protobuf:"bytes,4,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
// The set of parties on whose behalf the commands were executed.
// Contains the “act_as“ parties from “commands.proto“
// filtered to the requesting parties in CompletionStreamRequest.
// The order of the parties need not be the same as in the submission.
// Each element must be a valid PartyIdString (as described in “value.proto“).
// Optional for historic completions where this data is not available.
ActAs []string `protobuf:"bytes,5,rep,name=act_as,json=actAs,proto3" json:"act_as,omitempty"`
// The submission ID this completion refers to, as described in “commands.proto“.
// Must be a valid LedgerString (as described in “value.proto“).
// Optional
SubmissionId string `protobuf:"bytes,6,opt,name=submission_id,json=submissionId,proto3" json:"submission_id,omitempty"`
// The actual deduplication window used for the submission, which is derived from
// “Commands.deduplication_period“. The ledger may convert the deduplication period into other
// descriptions and extend the period in implementation-specified ways.
//
// Used to audit the deduplication guarantee described in “commands.proto“.
//
// Optional; the deduplication guarantee applies even if the completion omits this field.
//
// Types that are valid to be assigned to DeduplicationPeriod:
//
// *Completion_DeduplicationOffset
// *Completion_DeduplicationDuration
DeduplicationPeriod isCompletion_DeduplicationPeriod `protobuf_oneof:"deduplication_period"`
// Optional; ledger API trace context
//
// The trace context transported in this message corresponds to the trace context supplied
// by the client application in a HTTP2 header of the original command submission.
// We typically use a header to transfer this type of information. Here we use message
// body, because it is used in gRPC streams which do not support per message headers.
// This field will be populated with the trace context contained in the original submission.
// If that was not provided, a unique ledger-api-server generated trace context will be used
// instead.
TraceContext *TraceContext `protobuf:"bytes,9,opt,name=trace_context,json=traceContext,proto3" json:"trace_context,omitempty"`
// May be used in a subsequent CompletionStreamRequest to resume the consumption of this stream at a later time.
// Required, must be a valid absolute offset (positive integer).
Offset int64 `protobuf:"varint,10,opt,name=offset,proto3" json:"offset,omitempty"`
// The synchronizer along with its record time.
// The synchronizer id provided, in case of
//
// - successful/failed transactions: identifies the synchronizer of the transaction
// - for successful/failed unassign commands: identifies the source synchronizer
// - for successful/failed assign commands: identifies the target synchronizer
//
// Required
SynchronizerTime *SynchronizerTime `protobuf:"bytes,11,opt,name=synchronizer_time,json=synchronizerTime,proto3" json:"synchronizer_time,omitempty"`
// contains filtered or unexported fields
}
A completion represents the status of a submitted command on the ledger: it can be successful or failed.
func (*Completion) Descriptor
deprecated
func (*Completion) Descriptor() ([]byte, []int)
Deprecated: Use Completion.ProtoReflect.Descriptor instead.
func (*Completion) GetActAs ¶
func (x *Completion) GetActAs() []string
func (*Completion) GetCommandId ¶
func (x *Completion) GetCommandId() string
func (*Completion) GetDeduplicationDuration ¶
func (x *Completion) GetDeduplicationDuration() *durationpb.Duration
func (*Completion) GetDeduplicationOffset ¶
func (x *Completion) GetDeduplicationOffset() int64
func (*Completion) GetDeduplicationPeriod ¶
func (x *Completion) GetDeduplicationPeriod() isCompletion_DeduplicationPeriod
func (*Completion) GetOffset ¶
func (x *Completion) GetOffset() int64
func (*Completion) GetStatus ¶
func (x *Completion) GetStatus() *status.Status
func (*Completion) GetSubmissionId ¶
func (x *Completion) GetSubmissionId() string
func (*Completion) GetSynchronizerTime ¶
func (x *Completion) GetSynchronizerTime() *SynchronizerTime
func (*Completion) GetTraceContext ¶
func (x *Completion) GetTraceContext() *TraceContext
func (*Completion) GetUpdateId ¶
func (x *Completion) GetUpdateId() string
func (*Completion) GetUserId ¶
func (x *Completion) GetUserId() string
func (*Completion) ProtoMessage ¶
func (*Completion) ProtoMessage()
func (*Completion) ProtoReflect ¶
func (x *Completion) ProtoReflect() protoreflect.Message
func (*Completion) Reset ¶
func (x *Completion) Reset()
func (*Completion) String ¶
func (x *Completion) String() string
type CompletionStreamRequest ¶
type CompletionStreamRequest struct {
// Only completions of commands submitted with the same user_id will be visible in the stream.
// Must be a valid UserIdString (as described in “value.proto“).
// Required unless authentication is used with a user token.
// In that case, the token's user-id will be used for the request's user_id.
UserId string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
// Non-empty list of parties whose data should be included.
// The stream shows only completions of commands for which at least one of the “act_as“ parties is in the given set of parties.
// Must be a valid PartyIdString (as described in “value.proto“).
// Required
Parties []string `protobuf:"bytes,2,rep,name=parties,proto3" json:"parties,omitempty"`
// This optional field indicates the minimum offset for completions. This can be used to resume an earlier completion stream.
// If not set the ledger uses the ledger begin offset instead.
// If specified, it must be a valid absolute offset (positive integer) or zero (ledger begin offset).
// If the ledger has been pruned, this parameter must be specified and greater than the pruning offset.
BeginExclusive int64 `protobuf:"varint,3,opt,name=begin_exclusive,json=beginExclusive,proto3" json:"begin_exclusive,omitempty"`
// contains filtered or unexported fields
}
func (*CompletionStreamRequest) Descriptor
deprecated
func (*CompletionStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use CompletionStreamRequest.ProtoReflect.Descriptor instead.
func (*CompletionStreamRequest) GetBeginExclusive ¶
func (x *CompletionStreamRequest) GetBeginExclusive() int64
func (*CompletionStreamRequest) GetParties ¶
func (x *CompletionStreamRequest) GetParties() []string
func (*CompletionStreamRequest) GetUserId ¶
func (x *CompletionStreamRequest) GetUserId() string
func (*CompletionStreamRequest) ProtoMessage ¶
func (*CompletionStreamRequest) ProtoMessage()
func (*CompletionStreamRequest) ProtoReflect ¶
func (x *CompletionStreamRequest) ProtoReflect() protoreflect.Message
func (*CompletionStreamRequest) Reset ¶
func (x *CompletionStreamRequest) Reset()
func (*CompletionStreamRequest) String ¶
func (x *CompletionStreamRequest) String() string
type CompletionStreamResponse ¶
type CompletionStreamResponse struct {
// Types that are valid to be assigned to CompletionResponse:
//
// *CompletionStreamResponse_Completion
// *CompletionStreamResponse_OffsetCheckpoint
CompletionResponse isCompletionStreamResponse_CompletionResponse `protobuf_oneof:"completion_response"`
// contains filtered or unexported fields
}
func (*CompletionStreamResponse) Descriptor
deprecated
func (*CompletionStreamResponse) Descriptor() ([]byte, []int)
Deprecated: Use CompletionStreamResponse.ProtoReflect.Descriptor instead.
func (*CompletionStreamResponse) GetCompletion ¶
func (x *CompletionStreamResponse) GetCompletion() *Completion
func (*CompletionStreamResponse) GetCompletionResponse ¶
func (x *CompletionStreamResponse) GetCompletionResponse() isCompletionStreamResponse_CompletionResponse
func (*CompletionStreamResponse) GetOffsetCheckpoint ¶
func (x *CompletionStreamResponse) GetOffsetCheckpoint() *OffsetCheckpoint
func (*CompletionStreamResponse) ProtoMessage ¶
func (*CompletionStreamResponse) ProtoMessage()
func (*CompletionStreamResponse) ProtoReflect ¶
func (x *CompletionStreamResponse) ProtoReflect() protoreflect.Message
func (*CompletionStreamResponse) Reset ¶
func (x *CompletionStreamResponse) Reset()
func (*CompletionStreamResponse) String ¶
func (x *CompletionStreamResponse) String() string
type CompletionStreamResponse_Completion ¶
type CompletionStreamResponse_Completion struct {
Completion *Completion `protobuf:"bytes,1,opt,name=completion,proto3,oneof"`
}
type CompletionStreamResponse_OffsetCheckpoint ¶
type CompletionStreamResponse_OffsetCheckpoint struct {
OffsetCheckpoint *OffsetCheckpoint `protobuf:"bytes,2,opt,name=offset_checkpoint,json=offsetCheckpoint,proto3,oneof"`
}
type Completion_DeduplicationDuration ¶
type Completion_DeduplicationDuration struct {
// Specifies the length of the deduplication period.
// It is measured in record time of completions.
//
// Must be non-negative.
DeduplicationDuration *durationpb.Duration `protobuf:"bytes,8,opt,name=deduplication_duration,json=deduplicationDuration,proto3,oneof"`
}
type Completion_DeduplicationOffset ¶
type Completion_DeduplicationOffset struct {
// Specifies the start of the deduplication period by a completion stream offset (exclusive).
//
// Must be a valid absolute offset (positive integer) or participant begin (zero).
DeduplicationOffset int64 `protobuf:"varint,7,opt,name=deduplication_offset,json=deduplicationOffset,proto3,oneof"`
}
type CreateAndExerciseCommand ¶
type CreateAndExerciseCommand struct {
// The template of the contract the client wants to create.
// Both package-name and package-id reference identifier formats for the template-id are supported.
// Note: The package-id reference identifier format is deprecated. We plan to end support for this format in version 3.4.
//
// Required
TemplateId *Identifier `protobuf:"bytes,1,opt,name=template_id,json=templateId,proto3" json:"template_id,omitempty"`
// The arguments required for creating a contract from this template.
// Required
CreateArguments *Record `protobuf:"bytes,2,opt,name=create_arguments,json=createArguments,proto3" json:"create_arguments,omitempty"`
// The name of the choice the client wants to exercise.
// Must be a valid NameString (as described in “value.proto“).
// Required
Choice string `protobuf:"bytes,3,opt,name=choice,proto3" json:"choice,omitempty"`
// The argument for this choice.
// Required
ChoiceArgument *Value `protobuf:"bytes,4,opt,name=choice_argument,json=choiceArgument,proto3" json:"choice_argument,omitempty"`
// contains filtered or unexported fields
}
Create a contract and exercise a choice on it in the same transaction.
func (*CreateAndExerciseCommand) Descriptor
deprecated
func (*CreateAndExerciseCommand) Descriptor() ([]byte, []int)
Deprecated: Use CreateAndExerciseCommand.ProtoReflect.Descriptor instead.
func (*CreateAndExerciseCommand) GetChoice ¶
func (x *CreateAndExerciseCommand) GetChoice() string
func (*CreateAndExerciseCommand) GetChoiceArgument ¶
func (x *CreateAndExerciseCommand) GetChoiceArgument() *Value
func (*CreateAndExerciseCommand) GetCreateArguments ¶
func (x *CreateAndExerciseCommand) GetCreateArguments() *Record
func (*CreateAndExerciseCommand) GetTemplateId ¶
func (x *CreateAndExerciseCommand) GetTemplateId() *Identifier
func (*CreateAndExerciseCommand) ProtoMessage ¶
func (*CreateAndExerciseCommand) ProtoMessage()
func (*CreateAndExerciseCommand) ProtoReflect ¶
func (x *CreateAndExerciseCommand) ProtoReflect() protoreflect.Message
func (*CreateAndExerciseCommand) Reset ¶
func (x *CreateAndExerciseCommand) Reset()
func (*CreateAndExerciseCommand) String ¶
func (x *CreateAndExerciseCommand) String() string
type CreateCommand ¶
type CreateCommand struct {
// The template of contract the client wants to create.
// Both package-name and package-id reference identifier formats for the template-id are supported.
// Note: The package-id reference identifier format is deprecated. We plan to end support for this format in version 3.4.
//
// Required
TemplateId *Identifier `protobuf:"bytes,1,opt,name=template_id,json=templateId,proto3" json:"template_id,omitempty"`
// The arguments required for creating a contract from this template.
// Required
CreateArguments *Record `protobuf:"bytes,2,opt,name=create_arguments,json=createArguments,proto3" json:"create_arguments,omitempty"`
// contains filtered or unexported fields
}
Create a new contract instance based on a template.
func (*CreateCommand) Descriptor
deprecated
func (*CreateCommand) Descriptor() ([]byte, []int)
Deprecated: Use CreateCommand.ProtoReflect.Descriptor instead.
func (*CreateCommand) GetCreateArguments ¶
func (x *CreateCommand) GetCreateArguments() *Record
func (*CreateCommand) GetTemplateId ¶
func (x *CreateCommand) GetTemplateId() *Identifier
func (*CreateCommand) ProtoMessage ¶
func (*CreateCommand) ProtoMessage()
func (*CreateCommand) ProtoReflect ¶
func (x *CreateCommand) ProtoReflect() protoreflect.Message
func (*CreateCommand) Reset ¶
func (x *CreateCommand) Reset()
func (*CreateCommand) String ¶
func (x *CreateCommand) String() string
type Created ¶
type Created struct {
// Required
// The event as it appeared in the context of its original update (i.e. daml transaction or
// reassignment) on this participant node. You can use its offset and node_id to find the
// corresponding update and the node within it.
CreatedEvent *CreatedEvent `protobuf:"bytes,1,opt,name=created_event,json=createdEvent,proto3" json:"created_event,omitempty"`
// The synchronizer which sequenced the creation of the contract
// Required
SynchronizerId string `protobuf:"bytes,2,opt,name=synchronizer_id,json=synchronizerId,proto3" json:"synchronizer_id,omitempty"`
// contains filtered or unexported fields
}
func (*Created) Descriptor
deprecated
func (*Created) GetCreatedEvent ¶
func (x *Created) GetCreatedEvent() *CreatedEvent
func (*Created) GetSynchronizerId ¶
func (*Created) ProtoMessage ¶
func (*Created) ProtoMessage()
func (*Created) ProtoReflect ¶
func (x *Created) ProtoReflect() protoreflect.Message
type CreatedEvent ¶
type CreatedEvent struct {
// The offset of origin, which has contextual meaning, please see description at messages that include a CreatedEvent.
// Offsets are managed by the participant nodes.
// Transactions can thus NOT be assumed to have the same offsets on different participant nodes.
// Required, it is a valid absolute offset (positive integer)
Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
// The position of this event in the originating transaction or reassignment.
// The origin has contextual meaning, please see description at messages that include a CreatedEvent.
// Node IDs are not necessarily equal across participants,
// as these may see different projections/parts of transactions.
// Required, must be valid node ID (non-negative integer)
NodeId int32 `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
// The ID of the created contract.
// Must be a valid LedgerString (as described in “value.proto“).
// Required
ContractId string `protobuf:"bytes,3,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
// The template of the created contract.
// The identifier uses the package-id reference format.
//
// Required
TemplateId *Identifier `protobuf:"bytes,4,opt,name=template_id,json=templateId,proto3" json:"template_id,omitempty"`
// The key of the created contract.
// This will be set if and only if “template_id“ defines a contract key.
// Optional
ContractKey *Value `protobuf:"bytes,5,opt,name=contract_key,json=contractKey,proto3" json:"contract_key,omitempty"`
// The arguments that have been used to create the contract.
//
// Required
CreateArguments *Record `protobuf:"bytes,6,opt,name=create_arguments,json=createArguments,proto3" json:"create_arguments,omitempty"`
// Opaque representation of contract create event payload intended for forwarding
// to an API server as a contract disclosed as part of a command
// submission.
// Optional
CreatedEventBlob []byte `protobuf:"bytes,7,opt,name=created_event_blob,json=createdEventBlob,proto3" json:"created_event_blob,omitempty"`
// Interface views specified in the transaction filter.
// Includes an “InterfaceView“ for each interface for which there is a “InterfaceFilter“ with
//
// - its party in the “witness_parties“ of this event,
// - and which is implemented by the template of this event,
// - and which has “include_interface_view“ set.
//
// Optional
InterfaceViews []*InterfaceView `protobuf:"bytes,8,rep,name=interface_views,json=interfaceViews,proto3" json:"interface_views,omitempty"`
// The parties that are notified of this event. When a “CreatedEvent“
// is returned as part of a transaction tree or ledger-effects transaction, this will include all
// the parties specified in the “TransactionFilter“ that are witnesses of the event
// (the stakeholders of the contract and all informees of all the ancestors
// of this create action that this participant knows about).
// If served as part of a ACS delta transaction those will
// be limited to all parties specified in the “TransactionFilter“ that
// are stakeholders of the contract (i.e. either signatories or observers).
// If the “CreatedEvent“ is returned as part of an AssignedEvent,
// ActiveContract or IncompleteUnassigned (so the event is related to
// an assignment or unassignment): this will include all parties of the
// “TransactionFilter“ that are stakeholders of the contract.
//
// The behavior of reading create events visible to parties not hosted
// on the participant node serving the Ledger API is undefined. Concretely,
// there is neither a guarantee that the participant node will serve all their
// create events on the ACS stream, nor is there a guarantee that matching archive
// events are delivered for such create events.
//
// For most clients this is not a problem, as they only read events for parties
// that are hosted on the participant node. If you need to read events
// for parties that may not be hosted at all times on the participant node,
// subscribe to the “TopologyEvent“s for that party by setting a corresponding
// “UpdateFormat“. Using these events, query the ACS as-of an offset where the
// party is hosted on the participant node, and ignore create events at offsets
// where the party is not hosted on the participant node.
// Required
WitnessParties []string `protobuf:"bytes,9,rep,name=witness_parties,json=witnessParties,proto3" json:"witness_parties,omitempty"`
// The signatories for this contract as specified by the template.
// Required
Signatories []string `protobuf:"bytes,10,rep,name=signatories,proto3" json:"signatories,omitempty"`
// The observers for this contract as specified explicitly by the template or implicitly as choice controllers.
// This field never contains parties that are signatories.
// Required
Observers []string `protobuf:"bytes,11,rep,name=observers,proto3" json:"observers,omitempty"`
// Ledger effective time of the transaction that created the contract.
// Required
CreatedAt *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
// The package name of the created contract.
// Required
PackageName string `protobuf:"bytes,13,opt,name=package_name,json=packageName,proto3" json:"package_name,omitempty"`
// Whether this event would be part of respective ACS_DELTA shaped stream,
// and should therefore considered when tracking contract activeness on the client-side.
// Required
AcsDelta bool `protobuf:"varint,14,opt,name=acs_delta,json=acsDelta,proto3" json:"acs_delta,omitempty"`
// A package-id present in the participant package store that typechecks the contract's argument.
// This may differ from the package-id of the template used to create the contract.
// For contracts created before Canton 3.4, this field matches the contract's creation package-id.
//
// NOTE: Experimental, server internal concept, not for client consumption. Subject to change without notice.
//
// Required
RepresentativePackageId string `` /* 133-byte string literal not displayed */
// contains filtered or unexported fields
}
Records that a contract has been created, and choices may now be exercised on it.
func (*CreatedEvent) Descriptor
deprecated
func (*CreatedEvent) Descriptor() ([]byte, []int)
Deprecated: Use CreatedEvent.ProtoReflect.Descriptor instead.
func (*CreatedEvent) GetAcsDelta ¶
func (x *CreatedEvent) GetAcsDelta() bool
func (*CreatedEvent) GetContractId ¶
func (x *CreatedEvent) GetContractId() string
func (*CreatedEvent) GetContractKey ¶
func (x *CreatedEvent) GetContractKey() *Value
func (*CreatedEvent) GetCreateArguments ¶
func (x *CreatedEvent) GetCreateArguments() *Record
func (*CreatedEvent) GetCreatedAt ¶
func (x *CreatedEvent) GetCreatedAt() *timestamppb.Timestamp
func (*CreatedEvent) GetCreatedEventBlob ¶
func (x *CreatedEvent) GetCreatedEventBlob() []byte
func (*CreatedEvent) GetInterfaceViews ¶
func (x *CreatedEvent) GetInterfaceViews() []*InterfaceView
func (*CreatedEvent) GetNodeId ¶
func (x *CreatedEvent) GetNodeId() int32
func (*CreatedEvent) GetObservers ¶
func (x *CreatedEvent) GetObservers() []string
func (*CreatedEvent) GetOffset ¶
func (x *CreatedEvent) GetOffset() int64
func (*CreatedEvent) GetPackageName ¶
func (x *CreatedEvent) GetPackageName() string
func (*CreatedEvent) GetRepresentativePackageId ¶
func (x *CreatedEvent) GetRepresentativePackageId() string
func (*CreatedEvent) GetSignatories ¶
func (x *CreatedEvent) GetSignatories() []string
func (*CreatedEvent) GetTemplateId ¶
func (x *CreatedEvent) GetTemplateId() *Identifier
func (*CreatedEvent) GetWitnessParties ¶
func (x *CreatedEvent) GetWitnessParties() []string
func (*CreatedEvent) ProtoMessage ¶
func (*CreatedEvent) ProtoMessage()
func (*CreatedEvent) ProtoReflect ¶
func (x *CreatedEvent) ProtoReflect() protoreflect.Message
func (*CreatedEvent) Reset ¶
func (x *CreatedEvent) Reset()
func (*CreatedEvent) String ¶
func (x *CreatedEvent) String() string
type CryptoKeyFormat ¶
type CryptoKeyFormat int32
Serialization format for crypto keys and signatures
const ( CryptoKeyFormat_CRYPTO_KEY_FORMAT_UNSPECIFIED CryptoKeyFormat = 0 // ASN.1 + DER encoding // Legacy format no longer used, except for migrations CryptoKeyFormat_CRYPTO_KEY_FORMAT_DER CryptoKeyFormat = 1 // Raw encoding of a key CryptoKeyFormat_CRYPTO_KEY_FORMAT_RAW CryptoKeyFormat = 2 // ASN.1 + DER-encoding of X.509 SubjectPublicKeyInfo structure: https://datatracker.ietf.org/doc/html/rfc5280#section-4.1 CryptoKeyFormat_CRYPTO_KEY_FORMAT_DER_X509_SUBJECT_PUBLIC_KEY_INFO CryptoKeyFormat = 3 )
func (CryptoKeyFormat) Descriptor ¶
func (CryptoKeyFormat) Descriptor() protoreflect.EnumDescriptor
func (CryptoKeyFormat) Enum ¶
func (x CryptoKeyFormat) Enum() *CryptoKeyFormat
func (CryptoKeyFormat) EnumDescriptor
deprecated
func (CryptoKeyFormat) EnumDescriptor() ([]byte, []int)
Deprecated: Use CryptoKeyFormat.Descriptor instead.
func (CryptoKeyFormat) Number ¶
func (x CryptoKeyFormat) Number() protoreflect.EnumNumber
func (CryptoKeyFormat) String ¶
func (x CryptoKeyFormat) String() string
func (CryptoKeyFormat) Type ¶
func (CryptoKeyFormat) Type() protoreflect.EnumType
type CumulativeFilter ¶
type CumulativeFilter struct {
// Types that are valid to be assigned to IdentifierFilter:
//
// *CumulativeFilter_WildcardFilter
// *CumulativeFilter_InterfaceFilter
// *CumulativeFilter_TemplateFilter
IdentifierFilter isCumulativeFilter_IdentifierFilter `protobuf_oneof:"identifier_filter"`
// contains filtered or unexported fields
}
A filter that matches all contracts that are either an instance of one of the “template_filters“ or that match one of the “interface_filters“.
func (*CumulativeFilter) Descriptor
deprecated
func (*CumulativeFilter) Descriptor() ([]byte, []int)
Deprecated: Use CumulativeFilter.ProtoReflect.Descriptor instead.
func (*CumulativeFilter) GetIdentifierFilter ¶
func (x *CumulativeFilter) GetIdentifierFilter() isCumulativeFilter_IdentifierFilter
func (*CumulativeFilter) GetInterfaceFilter ¶
func (x *CumulativeFilter) GetInterfaceFilter() *InterfaceFilter
func (*CumulativeFilter) GetTemplateFilter ¶
func (x *CumulativeFilter) GetTemplateFilter() *TemplateFilter
func (*CumulativeFilter) GetWildcardFilter ¶
func (x *CumulativeFilter) GetWildcardFilter() *WildcardFilter
func (*CumulativeFilter) ProtoMessage ¶
func (*CumulativeFilter) ProtoMessage()
func (*CumulativeFilter) ProtoReflect ¶
func (x *CumulativeFilter) ProtoReflect() protoreflect.Message
func (*CumulativeFilter) Reset ¶
func (x *CumulativeFilter) Reset()
func (*CumulativeFilter) String ¶
func (x *CumulativeFilter) String() string
type CumulativeFilter_InterfaceFilter ¶
type CumulativeFilter_InterfaceFilter struct {
// Include an “InterfaceView“ for every “InterfaceFilter“ matching a contract.
// The “InterfaceFilter“ instances MUST each use a unique “interface_id“.
// Optional
InterfaceFilter *InterfaceFilter `protobuf:"bytes,2,opt,name=interface_filter,json=interfaceFilter,proto3,oneof"`
}
type CumulativeFilter_TemplateFilter ¶
type CumulativeFilter_TemplateFilter struct {
// A template for which the data will be included in the
// “create_arguments“ of a matching “CreatedEvent“.
// If a contract is simultaneously selected by a template filter and one or more interface filters,
// the corresponding “include_created_event_blob“ are consolidated using an OR operation.
// Optional
TemplateFilter *TemplateFilter `protobuf:"bytes,3,opt,name=template_filter,json=templateFilter,proto3,oneof"`
}
type CumulativeFilter_WildcardFilter ¶
type CumulativeFilter_WildcardFilter struct {
// A wildcard filter that matches all templates
// Optional
WildcardFilter *WildcardFilter `protobuf:"bytes,1,opt,name=wildcard_filter,json=wildcardFilter,proto3,oneof"`
}
type DisclosedContract ¶
type DisclosedContract struct {
// The template id of the contract.
// The identifier uses the package-id reference format.
//
// If provided, used to validate the template id of the contract serialized in the created_event_blob.
// Optional
TemplateId *Identifier `protobuf:"bytes,1,opt,name=template_id,json=templateId,proto3" json:"template_id,omitempty"`
// The contract id
//
// If provided, used to validate the contract id of the contract serialized in the created_event_blob.
// Optional
ContractId string `protobuf:"bytes,2,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
// Opaque byte string containing the complete payload required by the Daml engine
// to reconstruct a contract not known to the receiving participant.
// Required
CreatedEventBlob []byte `protobuf:"bytes,3,opt,name=created_event_blob,json=createdEventBlob,proto3" json:"created_event_blob,omitempty"`
// The ID of the synchronizer where the contract is currently assigned
// Optional
SynchronizerId string `protobuf:"bytes,4,opt,name=synchronizer_id,json=synchronizerId,proto3" json:"synchronizer_id,omitempty"`
// contains filtered or unexported fields
}
An additional contract that is used to resolve contract & contract key lookups.
func (*DisclosedContract) Descriptor
deprecated
func (*DisclosedContract) Descriptor() ([]byte, []int)
Deprecated: Use DisclosedContract.ProtoReflect.Descriptor instead.
func (*DisclosedContract) GetContractId ¶
func (x *DisclosedContract) GetContractId() string
func (*DisclosedContract) GetCreatedEventBlob ¶
func (x *DisclosedContract) GetCreatedEventBlob() []byte
func (*DisclosedContract) GetSynchronizerId ¶
func (x *DisclosedContract) GetSynchronizerId() string
func (*DisclosedContract) GetTemplateId ¶
func (x *DisclosedContract) GetTemplateId() *Identifier
func (*DisclosedContract) ProtoMessage ¶
func (*DisclosedContract) ProtoMessage()
func (*DisclosedContract) ProtoReflect ¶
func (x *DisclosedContract) ProtoReflect() protoreflect.Message
func (*DisclosedContract) Reset ¶
func (x *DisclosedContract) Reset()
func (*DisclosedContract) String ¶
func (x *DisclosedContract) String() string
type Enum ¶
type Enum struct {
// Omitted from the transaction stream when verbose streaming is not enabled.
// Optional when submitting commands.
EnumId *Identifier `protobuf:"bytes,1,opt,name=enum_id,json=enumId,proto3" json:"enum_id,omitempty"`
// Determines which of the Variant's alternatives is encoded in this message.
// Must be a valid NameString.
// Required
Constructor string `protobuf:"bytes,2,opt,name=constructor,proto3" json:"constructor,omitempty"`
// contains filtered or unexported fields
}
A value with finite set of alternative representations.
func (*Enum) Descriptor
deprecated
func (*Enum) GetConstructor ¶
func (*Enum) GetEnumId ¶
func (x *Enum) GetEnumId() *Identifier
func (*Enum) ProtoMessage ¶
func (*Enum) ProtoMessage()
func (*Enum) ProtoReflect ¶
func (x *Enum) ProtoReflect() protoreflect.Message
type Event ¶
type Event struct {
// Types that are valid to be assigned to Event:
//
// *Event_Created
// *Event_Archived
// *Event_Exercised
Event isEvent_Event `protobuf_oneof:"event"`
// contains filtered or unexported fields
}
Events in transactions can have two primary shapes:
- ACS delta: events can be CreatedEvent or ArchivedEvent - ledger effects: events can be CreatedEvent or ExercisedEvent
In the update service the events are restricted to the events visible for the parties specified in the transaction filter. Each event message type below contains a “witness_parties“ field which indicates the subset of the requested parties that can see the event in question.
func (*Event) Descriptor
deprecated
func (*Event) GetArchived ¶
func (x *Event) GetArchived() *ArchivedEvent
func (*Event) GetCreated ¶
func (x *Event) GetCreated() *CreatedEvent
func (*Event) GetExercised ¶
func (x *Event) GetExercised() *ExercisedEvent
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
type EventFormat ¶
type EventFormat struct {
// Each key must be a valid PartyIdString (as described in “value.proto“).
// The interpretation of the filter depends on the transaction-shape being filtered:
//
// 1. For **ledger-effects** create and exercise events are returned, for which the witnesses include at least one of
// the listed parties and match the per-party filter.
// 2. For **transaction and active-contract-set streams** create and archive events are returned for all contracts whose
// stakeholders include at least one of the listed parties and match the per-party filter.
//
// Optional
FiltersByParty map[string]*Filters `` /* 179-byte string literal not displayed */
// Wildcard filters that apply to all the parties existing on the participant. The interpretation of the filters is the same
// with the per-party filter as described above.
// Optional
FiltersForAnyParty *Filters `protobuf:"bytes,2,opt,name=filters_for_any_party,json=filtersForAnyParty,proto3" json:"filters_for_any_party,omitempty"`
// If enabled, values served over the API will contain more information than strictly necessary to interpret the data.
// In particular, setting the verbose flag to true triggers the ledger to include labels for record fields.
// Optional
Verbose bool `protobuf:"varint,3,opt,name=verbose,proto3" json:"verbose,omitempty"`
// contains filtered or unexported fields
}
A format for events which defines both which events should be included and what data should be computed and included for them.
Note that some of the filtering behavior depends on the `TransactionShape`, which is expected to be specified alongside usages of `EventFormat`.
func (*EventFormat) Descriptor
deprecated
func (*EventFormat) Descriptor() ([]byte, []int)
Deprecated: Use EventFormat.ProtoReflect.Descriptor instead.
func (*EventFormat) GetFiltersByParty ¶
func (x *EventFormat) GetFiltersByParty() map[string]*Filters
func (*EventFormat) GetFiltersForAnyParty ¶
func (x *EventFormat) GetFiltersForAnyParty() *Filters
func (*EventFormat) GetVerbose ¶
func (x *EventFormat) GetVerbose() bool
func (*EventFormat) ProtoMessage ¶
func (*EventFormat) ProtoMessage()
func (*EventFormat) ProtoReflect ¶
func (x *EventFormat) ProtoReflect() protoreflect.Message
func (*EventFormat) Reset ¶
func (x *EventFormat) Reset()
func (*EventFormat) String ¶
func (x *EventFormat) String() string
type EventQueryServiceClient ¶
type EventQueryServiceClient interface {
// Get the create and the consuming exercise event for the contract with the provided ID.
// No events will be returned for contracts that have been pruned because they
// have already been archived before the latest pruning offset.
// If the contract cannot be found for the request, or all the contract-events are filtered, a CONTRACT_EVENTS_NOT_FOUND error will be raised.
GetEventsByContractId(ctx context.Context, in *GetEventsByContractIdRequest, opts ...grpc.CallOption) (*GetEventsByContractIdResponse, error)
}
EventQueryServiceClient is the client API for EventQueryService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
Query events by contract id.
Note that querying by contract key is not (yet) supported, as contract keys are not supported (yet) in multi-synchronizer scenarios.
func NewEventQueryServiceClient ¶
func NewEventQueryServiceClient(cc grpc.ClientConnInterface) EventQueryServiceClient
type EventQueryServiceServer ¶
type EventQueryServiceServer interface {
// Get the create and the consuming exercise event for the contract with the provided ID.
// No events will be returned for contracts that have been pruned because they
// have already been archived before the latest pruning offset.
// If the contract cannot be found for the request, or all the contract-events are filtered, a CONTRACT_EVENTS_NOT_FOUND error will be raised.
GetEventsByContractId(context.Context, *GetEventsByContractIdRequest) (*GetEventsByContractIdResponse, error)
// contains filtered or unexported methods
}
EventQueryServiceServer is the server API for EventQueryService service. All implementations must embed UnimplementedEventQueryServiceServer for forward compatibility.
Query events by contract id.
Note that querying by contract key is not (yet) supported, as contract keys are not supported (yet) in multi-synchronizer scenarios.
type Event_Archived ¶
type Event_Archived struct {
Archived *ArchivedEvent `protobuf:"bytes,2,opt,name=archived,proto3,oneof"`
}
type Event_Created ¶
type Event_Created struct {
// The event as it appeared in the context of its original daml transaction on this participant node.
// In particular, the offset, node_id pair of the daml transaction are preserved.
Created *CreatedEvent `protobuf:"bytes,1,opt,name=created,proto3,oneof"`
}
type Event_Exercised ¶
type Event_Exercised struct {
Exercised *ExercisedEvent `protobuf:"bytes,3,opt,name=exercised,proto3,oneof"`
}
type ExerciseByKeyCommand ¶
type ExerciseByKeyCommand struct {
// The template of contract the client wants to exercise.
// Both package-name and package-id reference identifier formats for the template-id are supported.
// Note: The package-id reference identifier format is deprecated. We plan to end support for this format in version 3.4.
//
// Required
TemplateId *Identifier `protobuf:"bytes,1,opt,name=template_id,json=templateId,proto3" json:"template_id,omitempty"`
// The key of the contract the client wants to exercise upon.
// Required
ContractKey *Value `protobuf:"bytes,2,opt,name=contract_key,json=contractKey,proto3" json:"contract_key,omitempty"`
// The name of the choice the client wants to exercise.
// Must be a valid NameString (as described in “value.proto“)
// Required
Choice string `protobuf:"bytes,3,opt,name=choice,proto3" json:"choice,omitempty"`
// The argument for this choice.
// Required
ChoiceArgument *Value `protobuf:"bytes,4,opt,name=choice_argument,json=choiceArgument,proto3" json:"choice_argument,omitempty"`
// contains filtered or unexported fields
}
Exercise a choice on an existing contract specified by its key.
func (*ExerciseByKeyCommand) Descriptor
deprecated
func (*ExerciseByKeyCommand) Descriptor() ([]byte, []int)
Deprecated: Use ExerciseByKeyCommand.ProtoReflect.Descriptor instead.
func (*ExerciseByKeyCommand) GetChoice ¶
func (x *ExerciseByKeyCommand) GetChoice() string
func (*ExerciseByKeyCommand) GetChoiceArgument ¶
func (x *ExerciseByKeyCommand) GetChoiceArgument() *Value
func (*ExerciseByKeyCommand) GetContractKey ¶
func (x *ExerciseByKeyCommand) GetContractKey() *Value
func (*ExerciseByKeyCommand) GetTemplateId ¶
func (x *ExerciseByKeyCommand) GetTemplateId() *Identifier
func (*ExerciseByKeyCommand) ProtoMessage ¶
func (*ExerciseByKeyCommand) ProtoMessage()
func (*ExerciseByKeyCommand) ProtoReflect ¶
func (x *ExerciseByKeyCommand) ProtoReflect() protoreflect.Message
func (*ExerciseByKeyCommand) Reset ¶
func (x *ExerciseByKeyCommand) Reset()
func (*ExerciseByKeyCommand) String ¶
func (x *ExerciseByKeyCommand) String() string
type ExerciseCommand ¶
type ExerciseCommand struct {
// The template or interface of the contract the client wants to exercise.
// Both package-name and package-id reference identifier formats for the template-id are supported.
// Note: The package-id reference identifier format is deprecated. We plan to end support for this format in version 3.4.
// To exercise a choice on an interface, specify the interface identifier in the template_id field.
//
// Required
TemplateId *Identifier `protobuf:"bytes,1,opt,name=template_id,json=templateId,proto3" json:"template_id,omitempty"`
// The ID of the contract the client wants to exercise upon.
// Must be a valid LedgerString (as described in “value.proto“).
// Required
ContractId string `protobuf:"bytes,2,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
// The name of the choice the client wants to exercise.
// Must be a valid NameString (as described in “value.proto“)
// Required
Choice string `protobuf:"bytes,3,opt,name=choice,proto3" json:"choice,omitempty"`
// The argument for this choice.
// Required
ChoiceArgument *Value `protobuf:"bytes,4,opt,name=choice_argument,json=choiceArgument,proto3" json:"choice_argument,omitempty"`
// contains filtered or unexported fields
}
Exercise a choice on an existing contract.
func (*ExerciseCommand) Descriptor
deprecated
func (*ExerciseCommand) Descriptor() ([]byte, []int)
Deprecated: Use ExerciseCommand.ProtoReflect.Descriptor instead.
func (*ExerciseCommand) GetChoice ¶
func (x *ExerciseCommand) GetChoice() string
func (*ExerciseCommand) GetChoiceArgument ¶
func (x *ExerciseCommand) GetChoiceArgument() *Value
func (*ExerciseCommand) GetContractId ¶
func (x *ExerciseCommand) GetContractId() string
func (*ExerciseCommand) GetTemplateId ¶
func (x *ExerciseCommand) GetTemplateId() *Identifier
func (*ExerciseCommand) ProtoMessage ¶
func (*ExerciseCommand) ProtoMessage()
func (*ExerciseCommand) ProtoReflect ¶
func (x *ExerciseCommand) ProtoReflect() protoreflect.Message
func (*ExerciseCommand) Reset ¶
func (x *ExerciseCommand) Reset()
func (*ExerciseCommand) String ¶
func (x *ExerciseCommand) String() string
type ExercisedEvent ¶
type ExercisedEvent struct {
// The offset of origin.
// Offsets are managed by the participant nodes.
// Transactions can thus NOT be assumed to have the same offsets on different participant nodes.
// Required, it is a valid absolute offset (positive integer)
Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
// The position of this event in the originating transaction or reassignment.
// Node IDs are not necessarily equal across participants,
// as these may see different projections/parts of transactions.
// Required, must be valid node ID (non-negative integer)
NodeId int32 `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
// The ID of the target contract.
// Must be a valid LedgerString (as described in “value.proto“).
// Required
ContractId string `protobuf:"bytes,3,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
// Identifies the template that defines the executed choice.
// This template's package-id may differ from the target contract's package-id
// if the target contract has been upgraded or downgraded.
//
// The identifier uses the package-id reference format.
//
// Required
TemplateId *Identifier `protobuf:"bytes,4,opt,name=template_id,json=templateId,proto3" json:"template_id,omitempty"`
// The interface where the choice is defined, if inherited.
// If defined, the identifier uses the package-id reference format.
//
// Optional
InterfaceId *Identifier `protobuf:"bytes,5,opt,name=interface_id,json=interfaceId,proto3" json:"interface_id,omitempty"`
// The choice that was exercised on the target contract.
// Must be a valid NameString (as described in “value.proto“).
// Required
Choice string `protobuf:"bytes,6,opt,name=choice,proto3" json:"choice,omitempty"`
// The argument of the exercised choice.
// Required
ChoiceArgument *Value `protobuf:"bytes,7,opt,name=choice_argument,json=choiceArgument,proto3" json:"choice_argument,omitempty"`
// The parties that exercised the choice.
// Each element must be a valid PartyIdString (as described in “value.proto“).
// Required
ActingParties []string `protobuf:"bytes,8,rep,name=acting_parties,json=actingParties,proto3" json:"acting_parties,omitempty"`
// If true, the target contract may no longer be exercised.
// Required
Consuming bool `protobuf:"varint,9,opt,name=consuming,proto3" json:"consuming,omitempty"`
// The parties that are notified of this event. The witnesses of an exercise
// node will depend on whether the exercise was consuming or not.
// If consuming, the witnesses are the union of the stakeholders,
// the actors and all informees of all the ancestors of this event this
// participant knows about.
// If not consuming, the witnesses are the union of the signatories,
// the actors and all informees of all the ancestors of this event this
// participant knows about.
// In both cases the witnesses are limited to the querying parties, or not
// limited in case anyParty filters are used.
// Note that the actors might not necessarily be observers
// and thus stakeholders. This is the case when the controllers of a
// choice are specified using "flexible controllers", using the
// “choice ... controller“ syntax, and said controllers are not
// explicitly marked as observers.
// Each element must be a valid PartyIdString (as described in “value.proto“).
// Required
WitnessParties []string `protobuf:"bytes,10,rep,name=witness_parties,json=witnessParties,proto3" json:"witness_parties,omitempty"`
// Specifies the upper boundary of the node ids of the events in the same transaction that appeared as a result of
// this “ExercisedEvent“. This allows unambiguous identification of all the members of the subtree rooted at this
// node. A full subtree can be constructed when all descendant nodes are present in the stream. If nodes are heavily
// filtered, it is only possible to determine if a node is in a consequent subtree or not.
// Required
LastDescendantNodeId int32 `` /* 127-byte string literal not displayed */
// The result of exercising the choice.
// Required
ExerciseResult *Value `protobuf:"bytes,12,opt,name=exercise_result,json=exerciseResult,proto3" json:"exercise_result,omitempty"`
// The package name of the contract.
// Required
PackageName string `protobuf:"bytes,13,opt,name=package_name,json=packageName,proto3" json:"package_name,omitempty"`
// If the event is consuming, the interfaces implemented by the target template that have been
// matched from the interface filter query.
// Populated only in case interface filters with include_interface_view set.
//
// The identifier uses the package-id reference format.
//
// Optional
ImplementedInterfaces []*Identifier `protobuf:"bytes,14,rep,name=implemented_interfaces,json=implementedInterfaces,proto3" json:"implemented_interfaces,omitempty"`
// Whether this event would be part of respective ACS_DELTA shaped stream,
// and should therefore considered when tracking contract activeness on the client-side.
// Required
AcsDelta bool `protobuf:"varint,15,opt,name=acs_delta,json=acsDelta,proto3" json:"acs_delta,omitempty"`
// contains filtered or unexported fields
}
Records that a choice has been exercised on a target contract.
func (*ExercisedEvent) Descriptor
deprecated
func (*ExercisedEvent) Descriptor() ([]byte, []int)
Deprecated: Use ExercisedEvent.ProtoReflect.Descriptor instead.
func (*ExercisedEvent) GetAcsDelta ¶
func (x *ExercisedEvent) GetAcsDelta() bool
func (*ExercisedEvent) GetActingParties ¶
func (x *ExercisedEvent) GetActingParties() []string
func (*ExercisedEvent) GetChoice ¶
func (x *ExercisedEvent) GetChoice() string
func (*ExercisedEvent) GetChoiceArgument ¶
func (x *ExercisedEvent) GetChoiceArgument() *Value
func (*ExercisedEvent) GetConsuming ¶
func (x *ExercisedEvent) GetConsuming() bool
func (*ExercisedEvent) GetContractId ¶
func (x *ExercisedEvent) GetContractId() string
func (*ExercisedEvent) GetExerciseResult ¶
func (x *ExercisedEvent) GetExerciseResult() *Value
func (*ExercisedEvent) GetImplementedInterfaces ¶
func (x *ExercisedEvent) GetImplementedInterfaces() []*Identifier
func (*ExercisedEvent) GetInterfaceId ¶
func (x *ExercisedEvent) GetInterfaceId() *Identifier
func (*ExercisedEvent) GetLastDescendantNodeId ¶
func (x *ExercisedEvent) GetLastDescendantNodeId() int32
func (*ExercisedEvent) GetNodeId ¶
func (x *ExercisedEvent) GetNodeId() int32
func (*ExercisedEvent) GetOffset ¶
func (x *ExercisedEvent) GetOffset() int64
func (*ExercisedEvent) GetPackageName ¶
func (x *ExercisedEvent) GetPackageName() string
func (*ExercisedEvent) GetTemplateId ¶
func (x *ExercisedEvent) GetTemplateId() *Identifier
func (*ExercisedEvent) GetWitnessParties ¶
func (x *ExercisedEvent) GetWitnessParties() []string
func (*ExercisedEvent) ProtoMessage ¶
func (*ExercisedEvent) ProtoMessage()
func (*ExercisedEvent) ProtoReflect ¶
func (x *ExercisedEvent) ProtoReflect() protoreflect.Message
func (*ExercisedEvent) Reset ¶
func (x *ExercisedEvent) Reset()
func (*ExercisedEvent) String ¶
func (x *ExercisedEvent) String() string
type ExperimentalCommandInspectionService ¶
type ExperimentalCommandInspectionService struct {
Supported bool `protobuf:"varint,1,opt,name=supported,proto3" json:"supported,omitempty"`
// contains filtered or unexported fields
}
Whether the Ledger API supports command inspection service
func (*ExperimentalCommandInspectionService) Descriptor
deprecated
func (*ExperimentalCommandInspectionService) Descriptor() ([]byte, []int)
Deprecated: Use ExperimentalCommandInspectionService.ProtoReflect.Descriptor instead.
func (*ExperimentalCommandInspectionService) GetSupported ¶
func (x *ExperimentalCommandInspectionService) GetSupported() bool
func (*ExperimentalCommandInspectionService) ProtoMessage ¶
func (*ExperimentalCommandInspectionService) ProtoMessage()
func (*ExperimentalCommandInspectionService) ProtoReflect ¶
func (x *ExperimentalCommandInspectionService) ProtoReflect() protoreflect.Message
func (*ExperimentalCommandInspectionService) Reset ¶
func (x *ExperimentalCommandInspectionService) Reset()
func (*ExperimentalCommandInspectionService) String ¶
func (x *ExperimentalCommandInspectionService) String() string
type ExperimentalFeatures ¶
type ExperimentalFeatures struct {
StaticTime *ExperimentalStaticTime `protobuf:"bytes,1,opt,name=static_time,json=staticTime,proto3" json:"static_time,omitempty"`
CommandInspectionService *ExperimentalCommandInspectionService `` /* 135-byte string literal not displayed */
// contains filtered or unexported fields
}
See the feature message definitions for descriptions.
func (*ExperimentalFeatures) Descriptor
deprecated
func (*ExperimentalFeatures) Descriptor() ([]byte, []int)
Deprecated: Use ExperimentalFeatures.ProtoReflect.Descriptor instead.
func (*ExperimentalFeatures) GetCommandInspectionService ¶
func (x *ExperimentalFeatures) GetCommandInspectionService() *ExperimentalCommandInspectionService
func (*ExperimentalFeatures) GetStaticTime ¶
func (x *ExperimentalFeatures) GetStaticTime() *ExperimentalStaticTime
func (*ExperimentalFeatures) ProtoMessage ¶
func (*ExperimentalFeatures) ProtoMessage()
func (*ExperimentalFeatures) ProtoReflect ¶
func (x *ExperimentalFeatures) ProtoReflect() protoreflect.Message
func (*ExperimentalFeatures) Reset ¶
func (x *ExperimentalFeatures) Reset()
func (*ExperimentalFeatures) String ¶
func (x *ExperimentalFeatures) String() string
type ExperimentalPartyTopologyEvents ¶
type ExperimentalPartyTopologyEvents struct {
Supported bool `protobuf:"varint,1,opt,name=supported,proto3" json:"supported,omitempty"`
// contains filtered or unexported fields
}
Whether the Ledger API supports party events
func (*ExperimentalPartyTopologyEvents) Descriptor
deprecated
func (*ExperimentalPartyTopologyEvents) Descriptor() ([]byte, []int)
Deprecated: Use ExperimentalPartyTopologyEvents.ProtoReflect.Descriptor instead.
func (*ExperimentalPartyTopologyEvents) GetSupported ¶
func (x *ExperimentalPartyTopologyEvents) GetSupported() bool
func (*ExperimentalPartyTopologyEvents) ProtoMessage ¶
func (*ExperimentalPartyTopologyEvents) ProtoMessage()
func (*ExperimentalPartyTopologyEvents) ProtoReflect ¶
func (x *ExperimentalPartyTopologyEvents) ProtoReflect() protoreflect.Message
func (*ExperimentalPartyTopologyEvents) Reset ¶
func (x *ExperimentalPartyTopologyEvents) Reset()
func (*ExperimentalPartyTopologyEvents) String ¶
func (x *ExperimentalPartyTopologyEvents) String() string
type ExperimentalStaticTime ¶
type ExperimentalStaticTime struct {
Supported bool `protobuf:"varint,1,opt,name=supported,proto3" json:"supported,omitempty"`
// contains filtered or unexported fields
}
Ledger is in the static time mode and exposes a time service.
func (*ExperimentalStaticTime) Descriptor
deprecated
func (*ExperimentalStaticTime) Descriptor() ([]byte, []int)
Deprecated: Use ExperimentalStaticTime.ProtoReflect.Descriptor instead.
func (*ExperimentalStaticTime) GetSupported ¶
func (x *ExperimentalStaticTime) GetSupported() bool
func (*ExperimentalStaticTime) ProtoMessage ¶
func (*ExperimentalStaticTime) ProtoMessage()
func (*ExperimentalStaticTime) ProtoReflect ¶
func (x *ExperimentalStaticTime) ProtoReflect() protoreflect.Message
func (*ExperimentalStaticTime) Reset ¶
func (x *ExperimentalStaticTime) Reset()
func (*ExperimentalStaticTime) String ¶
func (x *ExperimentalStaticTime) String() string
type FeaturesDescriptor ¶
type FeaturesDescriptor struct {
// Features under development or features that are used
// for ledger implementation testing purposes only.
//
// Daml applications SHOULD not depend on these in production.
Experimental *ExperimentalFeatures `protobuf:"bytes,1,opt,name=experimental,proto3" json:"experimental,omitempty"`
// If set, then the Ledger API server supports user management.
// It is recommended that clients query this field to gracefully adjust their behavior for
// ledgers that do not support user management.
UserManagement *UserManagementFeature `protobuf:"bytes,2,opt,name=user_management,json=userManagement,proto3" json:"user_management,omitempty"`
// If set, then the Ledger API server supports party management configurability.
// It is recommended that clients query this field to gracefully adjust their behavior to
// maximum party page size.
PartyManagement *PartyManagementFeature `protobuf:"bytes,3,opt,name=party_management,json=partyManagement,proto3" json:"party_management,omitempty"`
// It contains the timeouts related to the periodic offset checkpoint emission
OffsetCheckpoint *OffsetCheckpointFeature `protobuf:"bytes,4,opt,name=offset_checkpoint,json=offsetCheckpoint,proto3" json:"offset_checkpoint,omitempty"`
// If set, then the Ledger API server supports package listing
// configurability. It is recommended that clients query this field to
// gracefully adjust their behavior to maximum package listing page size.
PackageFeature *PackageFeature `protobuf:"bytes,5,opt,name=package_feature,json=packageFeature,proto3" json:"package_feature,omitempty"`
// contains filtered or unexported fields
}
func (*FeaturesDescriptor) Descriptor
deprecated
func (*FeaturesDescriptor) Descriptor() ([]byte, []int)
Deprecated: Use FeaturesDescriptor.ProtoReflect.Descriptor instead.
func (*FeaturesDescriptor) GetExperimental ¶
func (x *FeaturesDescriptor) GetExperimental() *ExperimentalFeatures
func (*FeaturesDescriptor) GetOffsetCheckpoint ¶
func (x *FeaturesDescriptor) GetOffsetCheckpoint() *OffsetCheckpointFeature
func (*FeaturesDescriptor) GetPackageFeature ¶
func (x *FeaturesDescriptor) GetPackageFeature() *PackageFeature
func (*FeaturesDescriptor) GetPartyManagement ¶
func (x *FeaturesDescriptor) GetPartyManagement() *PartyManagementFeature
func (*FeaturesDescriptor) GetUserManagement ¶
func (x *FeaturesDescriptor) GetUserManagement() *UserManagementFeature
func (*FeaturesDescriptor) ProtoMessage ¶
func (*FeaturesDescriptor) ProtoMessage()
func (*FeaturesDescriptor) ProtoReflect ¶
func (x *FeaturesDescriptor) ProtoReflect() protoreflect.Message
func (*FeaturesDescriptor) Reset ¶
func (x *FeaturesDescriptor) Reset()
func (*FeaturesDescriptor) String ¶
func (x *FeaturesDescriptor) String() string
type Filters ¶
type Filters struct {
// Every filter in the cumulative list expands the scope of the resulting stream. Each interface,
// template or wildcard filter means additional events that will match the query.
// The impact of include_interface_view and include_created_event_blob fields in the filters will
// also be accumulated.
// A template or an interface SHOULD NOT appear twice in the accumulative field.
// A wildcard filter SHOULD NOT be defined more than once in the accumulative field.
// Optional, if no “CumulativeFilter“ defined, the default of a single “WildcardFilter“ with
// include_created_event_blob unset is used.
Cumulative []*CumulativeFilter `protobuf:"bytes,1,rep,name=cumulative,proto3" json:"cumulative,omitempty"`
// contains filtered or unexported fields
}
The union of a set of template filters, interface filters, or a wildcard.
func (*Filters) Descriptor
deprecated
func (*Filters) GetCumulative ¶
func (x *Filters) GetCumulative() []*CumulativeFilter
func (*Filters) ProtoMessage ¶
func (*Filters) ProtoMessage()
func (*Filters) ProtoReflect ¶
func (x *Filters) ProtoReflect() protoreflect.Message
type GenMap ¶
type GenMap struct {
Entries []*GenMap_Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
// contains filtered or unexported fields
}
func (*GenMap) Descriptor
deprecated
func (*GenMap) GetEntries ¶
func (x *GenMap) GetEntries() []*GenMap_Entry
func (*GenMap) ProtoMessage ¶
func (*GenMap) ProtoMessage()
func (*GenMap) ProtoReflect ¶
func (x *GenMap) ProtoReflect() protoreflect.Message
type GenMap_Entry ¶
type GenMap_Entry struct {
Key *Value `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
Value *Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
func (*GenMap_Entry) Descriptor
deprecated
func (*GenMap_Entry) Descriptor() ([]byte, []int)
Deprecated: Use GenMap_Entry.ProtoReflect.Descriptor instead.
func (*GenMap_Entry) GetKey ¶
func (x *GenMap_Entry) GetKey() *Value
func (*GenMap_Entry) GetValue ¶
func (x *GenMap_Entry) GetValue() *Value
func (*GenMap_Entry) ProtoMessage ¶
func (*GenMap_Entry) ProtoMessage()
func (*GenMap_Entry) ProtoReflect ¶
func (x *GenMap_Entry) ProtoReflect() protoreflect.Message
func (*GenMap_Entry) Reset ¶
func (x *GenMap_Entry) Reset()
func (*GenMap_Entry) String ¶
func (x *GenMap_Entry) String() string
type GetActiveContractsRequest ¶
type GetActiveContractsRequest struct {
// The offset at which the snapshot of the active contracts will be computed.
// Must be no greater than the current ledger end offset.
// Must be greater than or equal to the last pruning offset.
// Required, must be a valid absolute offset (positive integer) or ledger begin offset (zero).
// If zero, the empty set will be returned.
ActiveAtOffset int64 `protobuf:"varint,3,opt,name=active_at_offset,json=activeAtOffset,proto3" json:"active_at_offset,omitempty"`
// Format of the contract_entries in the result. In case of CreatedEvent the presentation will be of
// TRANSACTION_SHAPE_ACS_DELTA.
// Optional for backwards compatibility, defaults to an EventFormat where:
//
// - filters_by_party is the filter.filters_by_party from this request
// - filters_for_any_party is the filter.filters_for_any_party from this request
// - verbose is the verbose field from this request
EventFormat *EventFormat `protobuf:"bytes,4,opt,name=event_format,json=eventFormat,proto3" json:"event_format,omitempty"`
// contains filtered or unexported fields
}
If the given offset is different than the ledger end, and there are (un)assignments in-flight at the given offset, the snapshot may fail with "FAILED_PRECONDITION/PARTICIPANT_PRUNED_DATA_ACCESSED". Note that it is ok to request acs snapshots for party migration with offsets other than ledger end, because party migration is not concerned with incomplete (un)assignments.
func (*GetActiveContractsRequest) Descriptor
deprecated
func (*GetActiveContractsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetActiveContractsRequest.ProtoReflect.Descriptor instead.
func (*GetActiveContractsRequest) GetActiveAtOffset ¶
func (x *GetActiveContractsRequest) GetActiveAtOffset() int64
func (*GetActiveContractsRequest) GetEventFormat ¶
func (x *GetActiveContractsRequest) GetEventFormat() *EventFormat
func (*GetActiveContractsRequest) ProtoMessage ¶
func (*GetActiveContractsRequest) ProtoMessage()
func (*GetActiveContractsRequest) ProtoReflect ¶
func (x *GetActiveContractsRequest) ProtoReflect() protoreflect.Message
func (*GetActiveContractsRequest) Reset ¶
func (x *GetActiveContractsRequest) Reset()
func (*GetActiveContractsRequest) String ¶
func (x *GetActiveContractsRequest) String() string
type GetActiveContractsResponse ¶
type GetActiveContractsResponse struct {
// The workflow ID used in command submission which corresponds to the contract_entry. Only set if
// the “workflow_id“ for the command was set.
// Must be a valid LedgerString (as described in “value.proto“).
// Optional
WorkflowId string `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
// For a contract there could be multiple contract_entry-s in the entire snapshot. These together define
// the state of one contract in the snapshot.
// A contract_entry is included in the result, if and only if there is at least one stakeholder party of the contract
// that is hosted on the synchronizer at the time of the event and the party satisfies the
// “TransactionFilter“ in the query.
//
// Types that are valid to be assigned to ContractEntry:
//
// *GetActiveContractsResponse_ActiveContract
// *GetActiveContractsResponse_IncompleteUnassigned
// *GetActiveContractsResponse_IncompleteAssigned
ContractEntry isGetActiveContractsResponse_ContractEntry `protobuf_oneof:"contract_entry"`
// contains filtered or unexported fields
}
func (*GetActiveContractsResponse) Descriptor
deprecated
func (*GetActiveContractsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetActiveContractsResponse.ProtoReflect.Descriptor instead.
func (*GetActiveContractsResponse) GetActiveContract ¶
func (x *GetActiveContractsResponse) GetActiveContract() *ActiveContract
func (*GetActiveContractsResponse) GetContractEntry ¶
func (x *GetActiveContractsResponse) GetContractEntry() isGetActiveContractsResponse_ContractEntry
func (*GetActiveContractsResponse) GetIncompleteAssigned ¶
func (x *GetActiveContractsResponse) GetIncompleteAssigned() *IncompleteAssigned
func (*GetActiveContractsResponse) GetIncompleteUnassigned ¶
func (x *GetActiveContractsResponse) GetIncompleteUnassigned() *IncompleteUnassigned
func (*GetActiveContractsResponse) GetWorkflowId ¶
func (x *GetActiveContractsResponse) GetWorkflowId() string
func (*GetActiveContractsResponse) ProtoMessage ¶
func (*GetActiveContractsResponse) ProtoMessage()
func (*GetActiveContractsResponse) ProtoReflect ¶
func (x *GetActiveContractsResponse) ProtoReflect() protoreflect.Message
func (*GetActiveContractsResponse) Reset ¶
func (x *GetActiveContractsResponse) Reset()
func (*GetActiveContractsResponse) String ¶
func (x *GetActiveContractsResponse) String() string
type GetActiveContractsResponse_ActiveContract ¶
type GetActiveContractsResponse_ActiveContract struct {
// The contract is active on the assigned synchronizer, meaning: there was an activation event on the given synchronizer (
// created, assigned), which is not followed by a deactivation event (archived, unassigned) on the same
// synchronizer, until the active_at_offset.
// Since activeness is defined as a per synchronizer concept, it is possible, that a contract is active on one
// synchronizer, but already archived on another.
// There will be one such message for each synchronizer the contract is active on.
ActiveContract *ActiveContract `protobuf:"bytes,2,opt,name=active_contract,json=activeContract,proto3,oneof"`
}
type GetActiveContractsResponse_IncompleteAssigned ¶
type GetActiveContractsResponse_IncompleteAssigned struct {
// Important: this message is not indicating that the contract is active on the target synchronizer!
// Included iff the assigned event was before or at the active_at_offset, but there was no corresponding
// unassigned event before or at the active_at_offset.
IncompleteAssigned *IncompleteAssigned `protobuf:"bytes,4,opt,name=incomplete_assigned,json=incompleteAssigned,proto3,oneof"`
}
type GetActiveContractsResponse_IncompleteUnassigned ¶
type GetActiveContractsResponse_IncompleteUnassigned struct {
// Included iff the unassigned event was before or at the active_at_offset, but there was no corresponding
// assigned event before or at the active_at_offset.
IncompleteUnassigned *IncompleteUnassigned `protobuf:"bytes,3,opt,name=incomplete_unassigned,json=incompleteUnassigned,proto3,oneof"`
}
type GetConnectedSynchronizersRequest ¶
type GetConnectedSynchronizersRequest struct {
// The party of interest
// Must be a valid PartyIdString (as described in “value.proto“).
// If empty, all synchronizers this node is connected to will be returned
// Optional
Party string `protobuf:"bytes,1,opt,name=party,proto3" json:"party,omitempty"`
// The id of a participant whose mapping of a party to connected synchronizers is requested.
// Must be a valid participant-id retrieved through a prior call to getParticipantId.
// Defaults to the participant id of the host participant.
// Optional
ParticipantId string `protobuf:"bytes,2,opt,name=participant_id,json=participantId,proto3" json:"participant_id,omitempty"`
// The ID of the identity provider configured by “Identity Provider Config“
// Optional, if not set, assume the user is managed by the default identity provider.
IdentityProviderId string `protobuf:"bytes,3,opt,name=identity_provider_id,json=identityProviderId,proto3" json:"identity_provider_id,omitempty"`
// contains filtered or unexported fields
}
func (*GetConnectedSynchronizersRequest) Descriptor
deprecated
func (*GetConnectedSynchronizersRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetConnectedSynchronizersRequest.ProtoReflect.Descriptor instead.
func (*GetConnectedSynchronizersRequest) GetIdentityProviderId ¶
func (x *GetConnectedSynchronizersRequest) GetIdentityProviderId() string
func (*GetConnectedSynchronizersRequest) GetParticipantId ¶
func (x *GetConnectedSynchronizersRequest) GetParticipantId() string
func (*GetConnectedSynchronizersRequest) GetParty ¶
func (x *GetConnectedSynchronizersRequest) GetParty() string
func (*GetConnectedSynchronizersRequest) ProtoMessage ¶
func (*GetConnectedSynchronizersRequest) ProtoMessage()
func (*GetConnectedSynchronizersRequest) ProtoReflect ¶
func (x *GetConnectedSynchronizersRequest) ProtoReflect() protoreflect.Message
func (*GetConnectedSynchronizersRequest) Reset ¶
func (x *GetConnectedSynchronizersRequest) Reset()
func (*GetConnectedSynchronizersRequest) String ¶
func (x *GetConnectedSynchronizersRequest) String() string
type GetConnectedSynchronizersResponse ¶
type GetConnectedSynchronizersResponse struct {
ConnectedSynchronizers []*GetConnectedSynchronizersResponse_ConnectedSynchronizer `` /* 127-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*GetConnectedSynchronizersResponse) Descriptor
deprecated
func (*GetConnectedSynchronizersResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetConnectedSynchronizersResponse.ProtoReflect.Descriptor instead.
func (*GetConnectedSynchronizersResponse) GetConnectedSynchronizers ¶
func (x *GetConnectedSynchronizersResponse) GetConnectedSynchronizers() []*GetConnectedSynchronizersResponse_ConnectedSynchronizer
func (*GetConnectedSynchronizersResponse) ProtoMessage ¶
func (*GetConnectedSynchronizersResponse) ProtoMessage()
func (*GetConnectedSynchronizersResponse) ProtoReflect ¶
func (x *GetConnectedSynchronizersResponse) ProtoReflect() protoreflect.Message
func (*GetConnectedSynchronizersResponse) Reset ¶
func (x *GetConnectedSynchronizersResponse) Reset()
func (*GetConnectedSynchronizersResponse) String ¶
func (x *GetConnectedSynchronizersResponse) String() string
type GetConnectedSynchronizersResponse_ConnectedSynchronizer ¶
type GetConnectedSynchronizersResponse_ConnectedSynchronizer struct {
// The alias of the synchronizer
// Required
SynchronizerAlias string `protobuf:"bytes,1,opt,name=synchronizer_alias,json=synchronizerAlias,proto3" json:"synchronizer_alias,omitempty"`
// The ID of the synchronizer
// Required
SynchronizerId string `protobuf:"bytes,2,opt,name=synchronizer_id,json=synchronizerId,proto3" json:"synchronizer_id,omitempty"`
// The permission on the synchronizer
// Set if a party was used in the request, otherwise unspecified.
// Optional
Permission ParticipantPermission `protobuf:"varint,3,opt,name=permission,proto3,enum=com.daml.ledger.api.v2.ParticipantPermission" json:"permission,omitempty"`
// contains filtered or unexported fields
}
func (*GetConnectedSynchronizersResponse_ConnectedSynchronizer) Descriptor
deprecated
func (*GetConnectedSynchronizersResponse_ConnectedSynchronizer) Descriptor() ([]byte, []int)
Deprecated: Use GetConnectedSynchronizersResponse_ConnectedSynchronizer.ProtoReflect.Descriptor instead.
func (*GetConnectedSynchronizersResponse_ConnectedSynchronizer) GetPermission ¶
func (x *GetConnectedSynchronizersResponse_ConnectedSynchronizer) GetPermission() ParticipantPermission
func (*GetConnectedSynchronizersResponse_ConnectedSynchronizer) GetSynchronizerAlias ¶
func (x *GetConnectedSynchronizersResponse_ConnectedSynchronizer) GetSynchronizerAlias() string
func (*GetConnectedSynchronizersResponse_ConnectedSynchronizer) GetSynchronizerId ¶
func (x *GetConnectedSynchronizersResponse_ConnectedSynchronizer) GetSynchronizerId() string
func (*GetConnectedSynchronizersResponse_ConnectedSynchronizer) ProtoMessage ¶
func (*GetConnectedSynchronizersResponse_ConnectedSynchronizer) ProtoMessage()
func (*GetConnectedSynchronizersResponse_ConnectedSynchronizer) ProtoReflect ¶
func (x *GetConnectedSynchronizersResponse_ConnectedSynchronizer) ProtoReflect() protoreflect.Message
func (*GetConnectedSynchronizersResponse_ConnectedSynchronizer) Reset ¶
func (x *GetConnectedSynchronizersResponse_ConnectedSynchronizer) Reset()
func (*GetConnectedSynchronizersResponse_ConnectedSynchronizer) String ¶
func (x *GetConnectedSynchronizersResponse_ConnectedSynchronizer) String() string
type GetEventsByContractIdRequest ¶
type GetEventsByContractIdRequest struct {
// The contract id being queried.
// Required
ContractId string `protobuf:"bytes,1,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
// Format of the events in the result, the presentation will be of TRANSACTION_SHAPE_ACS_DELTA.
// Required
EventFormat *EventFormat `protobuf:"bytes,2,opt,name=event_format,json=eventFormat,proto3" json:"event_format,omitempty"`
// contains filtered or unexported fields
}
func (*GetEventsByContractIdRequest) Descriptor
deprecated
func (*GetEventsByContractIdRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetEventsByContractIdRequest.ProtoReflect.Descriptor instead.
func (*GetEventsByContractIdRequest) GetContractId ¶
func (x *GetEventsByContractIdRequest) GetContractId() string
func (*GetEventsByContractIdRequest) GetEventFormat ¶
func (x *GetEventsByContractIdRequest) GetEventFormat() *EventFormat
func (*GetEventsByContractIdRequest) ProtoMessage ¶
func (*GetEventsByContractIdRequest) ProtoMessage()
func (*GetEventsByContractIdRequest) ProtoReflect ¶
func (x *GetEventsByContractIdRequest) ProtoReflect() protoreflect.Message
func (*GetEventsByContractIdRequest) Reset ¶
func (x *GetEventsByContractIdRequest) Reset()
func (*GetEventsByContractIdRequest) String ¶
func (x *GetEventsByContractIdRequest) String() string
type GetEventsByContractIdResponse ¶
type GetEventsByContractIdResponse struct {
// The create event for the contract with the “contract_id“ given in the request
// provided it exists and has not yet been pruned.
// Optional
Created *Created `protobuf:"bytes,1,opt,name=created,proto3" json:"created,omitempty"`
// The archive event for the contract with the “contract_id“ given in the request
// provided such an archive event exists and it has not yet been pruned.
// Optional
Archived *Archived `protobuf:"bytes,2,opt,name=archived,proto3" json:"archived,omitempty"`
// contains filtered or unexported fields
}
func (*GetEventsByContractIdResponse) Descriptor
deprecated
func (*GetEventsByContractIdResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetEventsByContractIdResponse.ProtoReflect.Descriptor instead.
func (*GetEventsByContractIdResponse) GetArchived ¶
func (x *GetEventsByContractIdResponse) GetArchived() *Archived
func (*GetEventsByContractIdResponse) GetCreated ¶
func (x *GetEventsByContractIdResponse) GetCreated() *Created
func (*GetEventsByContractIdResponse) ProtoMessage ¶
func (*GetEventsByContractIdResponse) ProtoMessage()
func (*GetEventsByContractIdResponse) ProtoReflect ¶
func (x *GetEventsByContractIdResponse) ProtoReflect() protoreflect.Message
func (*GetEventsByContractIdResponse) Reset ¶
func (x *GetEventsByContractIdResponse) Reset()
func (*GetEventsByContractIdResponse) String ¶
func (x *GetEventsByContractIdResponse) String() string
type GetLatestPrunedOffsetsRequest ¶
type GetLatestPrunedOffsetsRequest struct {
// contains filtered or unexported fields
}
func (*GetLatestPrunedOffsetsRequest) Descriptor
deprecated
func (*GetLatestPrunedOffsetsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetLatestPrunedOffsetsRequest.ProtoReflect.Descriptor instead.
func (*GetLatestPrunedOffsetsRequest) ProtoMessage ¶
func (*GetLatestPrunedOffsetsRequest) ProtoMessage()
func (*GetLatestPrunedOffsetsRequest) ProtoReflect ¶
func (x *GetLatestPrunedOffsetsRequest) ProtoReflect() protoreflect.Message
func (*GetLatestPrunedOffsetsRequest) Reset ¶
func (x *GetLatestPrunedOffsetsRequest) Reset()
func (*GetLatestPrunedOffsetsRequest) String ¶
func (x *GetLatestPrunedOffsetsRequest) String() string
type GetLatestPrunedOffsetsResponse ¶
type GetLatestPrunedOffsetsResponse struct {
// It will always be a non-negative integer.
// If positive, the absolute offset up to which the ledger has been pruned,
// disregarding the state of all divulged contracts pruning.
// If zero, the ledger has not been pruned yet.
ParticipantPrunedUpToInclusive int64 `` /* 158-byte string literal not displayed */
// It will always be a non-negative integer.
// If positive, the absolute offset up to which all divulged events have been pruned on the ledger.
// It can be at or before the “participant_pruned_up_to_inclusive“ offset.
// For more details about all divulged events pruning,
// see “PruneRequest.prune_all_divulged_contracts“ in “participant_pruning_service.proto“.
// If zero, the divulged events have not been pruned yet.
AllDivulgedContractsPrunedUpToInclusive int64 `` /* 189-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*GetLatestPrunedOffsetsResponse) Descriptor
deprecated
func (*GetLatestPrunedOffsetsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetLatestPrunedOffsetsResponse.ProtoReflect.Descriptor instead.
func (*GetLatestPrunedOffsetsResponse) GetAllDivulgedContractsPrunedUpToInclusive ¶
func (x *GetLatestPrunedOffsetsResponse) GetAllDivulgedContractsPrunedUpToInclusive() int64
func (*GetLatestPrunedOffsetsResponse) GetParticipantPrunedUpToInclusive ¶
func (x *GetLatestPrunedOffsetsResponse) GetParticipantPrunedUpToInclusive() int64
func (*GetLatestPrunedOffsetsResponse) ProtoMessage ¶
func (*GetLatestPrunedOffsetsResponse) ProtoMessage()
func (*GetLatestPrunedOffsetsResponse) ProtoReflect ¶
func (x *GetLatestPrunedOffsetsResponse) ProtoReflect() protoreflect.Message
func (*GetLatestPrunedOffsetsResponse) Reset ¶
func (x *GetLatestPrunedOffsetsResponse) Reset()
func (*GetLatestPrunedOffsetsResponse) String ¶
func (x *GetLatestPrunedOffsetsResponse) String() string
type GetLedgerApiVersionRequest ¶
type GetLedgerApiVersionRequest struct {
// contains filtered or unexported fields
}
func (*GetLedgerApiVersionRequest) Descriptor
deprecated
func (*GetLedgerApiVersionRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetLedgerApiVersionRequest.ProtoReflect.Descriptor instead.
func (*GetLedgerApiVersionRequest) ProtoMessage ¶
func (*GetLedgerApiVersionRequest) ProtoMessage()
func (*GetLedgerApiVersionRequest) ProtoReflect ¶
func (x *GetLedgerApiVersionRequest) ProtoReflect() protoreflect.Message
func (*GetLedgerApiVersionRequest) Reset ¶
func (x *GetLedgerApiVersionRequest) Reset()
func (*GetLedgerApiVersionRequest) String ¶
func (x *GetLedgerApiVersionRequest) String() string
type GetLedgerApiVersionResponse ¶
type GetLedgerApiVersionResponse struct {
// The version of the ledger API.
Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
// The features supported by this Ledger API endpoint.
//
// Daml applications CAN use the feature descriptor on top of
// version constraints on the Ledger API version to determine
// whether a given Ledger API endpoint supports the features
// required to run the application.
//
// See the feature descriptions themselves for the relation between
// Ledger API versions and feature presence.
Features *FeaturesDescriptor `protobuf:"bytes,2,opt,name=features,proto3" json:"features,omitempty"`
// contains filtered or unexported fields
}
func (*GetLedgerApiVersionResponse) Descriptor
deprecated
func (*GetLedgerApiVersionResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetLedgerApiVersionResponse.ProtoReflect.Descriptor instead.
func (*GetLedgerApiVersionResponse) GetFeatures ¶
func (x *GetLedgerApiVersionResponse) GetFeatures() *FeaturesDescriptor
func (*GetLedgerApiVersionResponse) GetVersion ¶
func (x *GetLedgerApiVersionResponse) GetVersion() string
func (*GetLedgerApiVersionResponse) ProtoMessage ¶
func (*GetLedgerApiVersionResponse) ProtoMessage()
func (*GetLedgerApiVersionResponse) ProtoReflect ¶
func (x *GetLedgerApiVersionResponse) ProtoReflect() protoreflect.Message
func (*GetLedgerApiVersionResponse) Reset ¶
func (x *GetLedgerApiVersionResponse) Reset()
func (*GetLedgerApiVersionResponse) String ¶
func (x *GetLedgerApiVersionResponse) String() string
type GetLedgerEndRequest ¶
type GetLedgerEndRequest struct {
// contains filtered or unexported fields
}
func (*GetLedgerEndRequest) Descriptor
deprecated
func (*GetLedgerEndRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetLedgerEndRequest.ProtoReflect.Descriptor instead.
func (*GetLedgerEndRequest) ProtoMessage ¶
func (*GetLedgerEndRequest) ProtoMessage()
func (*GetLedgerEndRequest) ProtoReflect ¶
func (x *GetLedgerEndRequest) ProtoReflect() protoreflect.Message
func (*GetLedgerEndRequest) Reset ¶
func (x *GetLedgerEndRequest) Reset()
func (*GetLedgerEndRequest) String ¶
func (x *GetLedgerEndRequest) String() string
type GetLedgerEndResponse ¶
type GetLedgerEndResponse struct {
// It will always be a non-negative integer.
// If zero, the participant view of the ledger is empty.
// If positive, the absolute offset of the ledger as viewed by the participant.
Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
// contains filtered or unexported fields
}
func (*GetLedgerEndResponse) Descriptor
deprecated
func (*GetLedgerEndResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetLedgerEndResponse.ProtoReflect.Descriptor instead.
func (*GetLedgerEndResponse) GetOffset ¶
func (x *GetLedgerEndResponse) GetOffset() int64
func (*GetLedgerEndResponse) ProtoMessage ¶
func (*GetLedgerEndResponse) ProtoMessage()
func (*GetLedgerEndResponse) ProtoReflect ¶
func (x *GetLedgerEndResponse) ProtoReflect() protoreflect.Message
func (*GetLedgerEndResponse) Reset ¶
func (x *GetLedgerEndResponse) Reset()
func (*GetLedgerEndResponse) String ¶
func (x *GetLedgerEndResponse) String() string
type GetPackageRequest ¶
type GetPackageRequest struct {
// The ID of the requested package.
// Must be a valid PackageIdString (as described in “value.proto“).
// Required
PackageId string `protobuf:"bytes,1,opt,name=package_id,json=packageId,proto3" json:"package_id,omitempty"`
// contains filtered or unexported fields
}
func (*GetPackageRequest) Descriptor
deprecated
func (*GetPackageRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetPackageRequest.ProtoReflect.Descriptor instead.
func (*GetPackageRequest) GetPackageId ¶
func (x *GetPackageRequest) GetPackageId() string
func (*GetPackageRequest) ProtoMessage ¶
func (*GetPackageRequest) ProtoMessage()
func (*GetPackageRequest) ProtoReflect ¶
func (x *GetPackageRequest) ProtoReflect() protoreflect.Message
func (*GetPackageRequest) Reset ¶
func (x *GetPackageRequest) Reset()
func (*GetPackageRequest) String ¶
func (x *GetPackageRequest) String() string
type GetPackageResponse ¶
type GetPackageResponse struct {
// The hash function we use to calculate the hash.
// Required
HashFunction HashFunction `` /* 139-byte string literal not displayed */
// Contains a “daml_lf“ ArchivePayload. See further details in “daml_lf.proto“.
// Required
ArchivePayload []byte `protobuf:"bytes,2,opt,name=archive_payload,json=archivePayload,proto3" json:"archive_payload,omitempty"`
// The hash of the archive payload, can also used as a “package_id“.
// Must be a valid PackageIdString (as described in “value.proto“).
// Required
Hash string `protobuf:"bytes,3,opt,name=hash,proto3" json:"hash,omitempty"`
// contains filtered or unexported fields
}
func (*GetPackageResponse) Descriptor
deprecated
func (*GetPackageResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetPackageResponse.ProtoReflect.Descriptor instead.
func (*GetPackageResponse) GetArchivePayload ¶
func (x *GetPackageResponse) GetArchivePayload() []byte
func (*GetPackageResponse) GetHash ¶
func (x *GetPackageResponse) GetHash() string
func (*GetPackageResponse) GetHashFunction ¶
func (x *GetPackageResponse) GetHashFunction() HashFunction
func (*GetPackageResponse) ProtoMessage ¶
func (*GetPackageResponse) ProtoMessage()
func (*GetPackageResponse) ProtoReflect ¶
func (x *GetPackageResponse) ProtoReflect() protoreflect.Message
func (*GetPackageResponse) Reset ¶
func (x *GetPackageResponse) Reset()
func (*GetPackageResponse) String ¶
func (x *GetPackageResponse) String() string
type GetPackageStatusRequest ¶
type GetPackageStatusRequest struct {
// The ID of the requested package.
// Must be a valid PackageIdString (as described in “value.proto“).
// Required
PackageId string `protobuf:"bytes,1,opt,name=package_id,json=packageId,proto3" json:"package_id,omitempty"`
// contains filtered or unexported fields
}
func (*GetPackageStatusRequest) Descriptor
deprecated
func (*GetPackageStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetPackageStatusRequest.ProtoReflect.Descriptor instead.
func (*GetPackageStatusRequest) GetPackageId ¶
func (x *GetPackageStatusRequest) GetPackageId() string
func (*GetPackageStatusRequest) ProtoMessage ¶
func (*GetPackageStatusRequest) ProtoMessage()
func (*GetPackageStatusRequest) ProtoReflect ¶
func (x *GetPackageStatusRequest) ProtoReflect() protoreflect.Message
func (*GetPackageStatusRequest) Reset ¶
func (x *GetPackageStatusRequest) Reset()
func (*GetPackageStatusRequest) String ¶
func (x *GetPackageStatusRequest) String() string
type GetPackageStatusResponse ¶
type GetPackageStatusResponse struct {
// The status of the package.
PackageStatus PackageStatus `` /* 143-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*GetPackageStatusResponse) Descriptor
deprecated
func (*GetPackageStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetPackageStatusResponse.ProtoReflect.Descriptor instead.
func (*GetPackageStatusResponse) GetPackageStatus ¶
func (x *GetPackageStatusResponse) GetPackageStatus() PackageStatus
func (*GetPackageStatusResponse) ProtoMessage ¶
func (*GetPackageStatusResponse) ProtoMessage()
func (*GetPackageStatusResponse) ProtoReflect ¶
func (x *GetPackageStatusResponse) ProtoReflect() protoreflect.Message
func (*GetPackageStatusResponse) Reset ¶
func (x *GetPackageStatusResponse) Reset()
func (*GetPackageStatusResponse) String ¶
func (x *GetPackageStatusResponse) String() string
type GetUpdateByIdRequest ¶
type GetUpdateByIdRequest struct {
// The ID of a particular update.
// Must be a valid LedgerString (as described in “value.proto“).
// Required
UpdateId string `protobuf:"bytes,1,opt,name=update_id,json=updateId,proto3" json:"update_id,omitempty"`
// The format for the update.
// Required
UpdateFormat *UpdateFormat `protobuf:"bytes,2,opt,name=update_format,json=updateFormat,proto3" json:"update_format,omitempty"`
// contains filtered or unexported fields
}
func (*GetUpdateByIdRequest) Descriptor
deprecated
func (*GetUpdateByIdRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetUpdateByIdRequest.ProtoReflect.Descriptor instead.
func (*GetUpdateByIdRequest) GetUpdateFormat ¶
func (x *GetUpdateByIdRequest) GetUpdateFormat() *UpdateFormat
func (*GetUpdateByIdRequest) GetUpdateId ¶
func (x *GetUpdateByIdRequest) GetUpdateId() string
func (*GetUpdateByIdRequest) ProtoMessage ¶
func (*GetUpdateByIdRequest) ProtoMessage()
func (*GetUpdateByIdRequest) ProtoReflect ¶
func (x *GetUpdateByIdRequest) ProtoReflect() protoreflect.Message
func (*GetUpdateByIdRequest) Reset ¶
func (x *GetUpdateByIdRequest) Reset()
func (*GetUpdateByIdRequest) String ¶
func (x *GetUpdateByIdRequest) String() string
type GetUpdateByOffsetRequest ¶
type GetUpdateByOffsetRequest struct {
// The offset of the update being looked up.
// Must be a valid absolute offset (positive integer).
// Required
Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
// The format for the update.
// Required
UpdateFormat *UpdateFormat `protobuf:"bytes,2,opt,name=update_format,json=updateFormat,proto3" json:"update_format,omitempty"`
// contains filtered or unexported fields
}
func (*GetUpdateByOffsetRequest) Descriptor
deprecated
func (*GetUpdateByOffsetRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetUpdateByOffsetRequest.ProtoReflect.Descriptor instead.
func (*GetUpdateByOffsetRequest) GetOffset ¶
func (x *GetUpdateByOffsetRequest) GetOffset() int64
func (*GetUpdateByOffsetRequest) GetUpdateFormat ¶
func (x *GetUpdateByOffsetRequest) GetUpdateFormat() *UpdateFormat
func (*GetUpdateByOffsetRequest) ProtoMessage ¶
func (*GetUpdateByOffsetRequest) ProtoMessage()
func (*GetUpdateByOffsetRequest) ProtoReflect ¶
func (x *GetUpdateByOffsetRequest) ProtoReflect() protoreflect.Message
func (*GetUpdateByOffsetRequest) Reset ¶
func (x *GetUpdateByOffsetRequest) Reset()
func (*GetUpdateByOffsetRequest) String ¶
func (x *GetUpdateByOffsetRequest) String() string
type GetUpdateResponse ¶
type GetUpdateResponse struct {
// The update that matches the filter in the request.
//
// Types that are valid to be assigned to Update:
//
// *GetUpdateResponse_Transaction
// *GetUpdateResponse_Reassignment
// *GetUpdateResponse_TopologyTransaction
Update isGetUpdateResponse_Update `protobuf_oneof:"update"`
// contains filtered or unexported fields
}
func (*GetUpdateResponse) Descriptor
deprecated
func (*GetUpdateResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetUpdateResponse.ProtoReflect.Descriptor instead.
func (*GetUpdateResponse) GetReassignment ¶
func (x *GetUpdateResponse) GetReassignment() *Reassignment
func (*GetUpdateResponse) GetTopologyTransaction ¶
func (x *GetUpdateResponse) GetTopologyTransaction() *TopologyTransaction
func (*GetUpdateResponse) GetTransaction ¶
func (x *GetUpdateResponse) GetTransaction() *Transaction
func (*GetUpdateResponse) GetUpdate ¶
func (x *GetUpdateResponse) GetUpdate() isGetUpdateResponse_Update
func (*GetUpdateResponse) ProtoMessage ¶
func (*GetUpdateResponse) ProtoMessage()
func (*GetUpdateResponse) ProtoReflect ¶
func (x *GetUpdateResponse) ProtoReflect() protoreflect.Message
func (*GetUpdateResponse) Reset ¶
func (x *GetUpdateResponse) Reset()
func (*GetUpdateResponse) String ¶
func (x *GetUpdateResponse) String() string
type GetUpdateResponse_Reassignment ¶
type GetUpdateResponse_Reassignment struct {
Reassignment *Reassignment `protobuf:"bytes,2,opt,name=reassignment,proto3,oneof"`
}
type GetUpdateResponse_TopologyTransaction ¶
type GetUpdateResponse_TopologyTransaction struct {
TopologyTransaction *TopologyTransaction `protobuf:"bytes,3,opt,name=topology_transaction,json=topologyTransaction,proto3,oneof"`
}
type GetUpdateResponse_Transaction ¶
type GetUpdateResponse_Transaction struct {
Transaction *Transaction `protobuf:"bytes,1,opt,name=transaction,proto3,oneof"`
}
type GetUpdatesRequest ¶
type GetUpdatesRequest struct {
// Beginning of the requested ledger section (non-negative integer).
// The response will only contain transactions whose offset is strictly greater than this.
// If zero, the stream will start from the beginning of the ledger.
// If positive, the streaming will start after this absolute offset.
// If the ledger has been pruned, this parameter must be specified and be greater than the pruning offset.
BeginExclusive int64 `protobuf:"varint,1,opt,name=begin_exclusive,json=beginExclusive,proto3" json:"begin_exclusive,omitempty"`
// End of the requested ledger section.
// The response will only contain transactions whose offset is less than or equal to this.
// Optional, if empty, the stream will not terminate.
// If specified, the stream will terminate after this absolute offset (positive integer) is reached.
EndInclusive *int64 `protobuf:"varint,2,opt,name=end_inclusive,json=endInclusive,proto3,oneof" json:"end_inclusive,omitempty"`
// Must be unset for GetUpdateTrees request.
// Optional for backwards compatibility for GetUpdates request: defaults to an UpdateFormat where:
//
// - include_transactions.event_format.filters_by_party = the filter.filters_by_party on this request
// - include_transactions.event_format.filters_for_any_party = the filter.filters_for_any_party on this request
// - include_transactions.event_format.verbose = the same flag specified on this request
// - include_transactions.transaction_shape = TRANSACTION_SHAPE_ACS_DELTA
// - include_reassignments.filter = the same filter specified on this request
// - include_reassignments.verbose = the same flag specified on this request
// - include_topology_events.include_participant_authorization_events.parties = all the parties specified in filter
UpdateFormat *UpdateFormat `protobuf:"bytes,5,opt,name=update_format,json=updateFormat,proto3" json:"update_format,omitempty"`
// contains filtered or unexported fields
}
func (*GetUpdatesRequest) Descriptor
deprecated
func (*GetUpdatesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetUpdatesRequest.ProtoReflect.Descriptor instead.
func (*GetUpdatesRequest) GetBeginExclusive ¶
func (x *GetUpdatesRequest) GetBeginExclusive() int64
func (*GetUpdatesRequest) GetEndInclusive ¶
func (x *GetUpdatesRequest) GetEndInclusive() int64
func (*GetUpdatesRequest) GetUpdateFormat ¶
func (x *GetUpdatesRequest) GetUpdateFormat() *UpdateFormat
func (*GetUpdatesRequest) ProtoMessage ¶
func (*GetUpdatesRequest) ProtoMessage()
func (*GetUpdatesRequest) ProtoReflect ¶
func (x *GetUpdatesRequest) ProtoReflect() protoreflect.Message
func (*GetUpdatesRequest) Reset ¶
func (x *GetUpdatesRequest) Reset()
func (*GetUpdatesRequest) String ¶
func (x *GetUpdatesRequest) String() string
type GetUpdatesResponse ¶
type GetUpdatesResponse struct {
// The update that matches the filter in the request.
//
// Types that are valid to be assigned to Update:
//
// *GetUpdatesResponse_Transaction
// *GetUpdatesResponse_Reassignment
// *GetUpdatesResponse_OffsetCheckpoint
// *GetUpdatesResponse_TopologyTransaction
Update isGetUpdatesResponse_Update `protobuf_oneof:"update"`
// contains filtered or unexported fields
}
func (*GetUpdatesResponse) Descriptor
deprecated
func (*GetUpdatesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetUpdatesResponse.ProtoReflect.Descriptor instead.
func (*GetUpdatesResponse) GetOffsetCheckpoint ¶
func (x *GetUpdatesResponse) GetOffsetCheckpoint() *OffsetCheckpoint
func (*GetUpdatesResponse) GetReassignment ¶
func (x *GetUpdatesResponse) GetReassignment() *Reassignment
func (*GetUpdatesResponse) GetTopologyTransaction ¶
func (x *GetUpdatesResponse) GetTopologyTransaction() *TopologyTransaction
func (*GetUpdatesResponse) GetTransaction ¶
func (x *GetUpdatesResponse) GetTransaction() *Transaction
func (*GetUpdatesResponse) GetUpdate ¶
func (x *GetUpdatesResponse) GetUpdate() isGetUpdatesResponse_Update
func (*GetUpdatesResponse) ProtoMessage ¶
func (*GetUpdatesResponse) ProtoMessage()
func (*GetUpdatesResponse) ProtoReflect ¶
func (x *GetUpdatesResponse) ProtoReflect() protoreflect.Message
func (*GetUpdatesResponse) Reset ¶
func (x *GetUpdatesResponse) Reset()
func (*GetUpdatesResponse) String ¶
func (x *GetUpdatesResponse) String() string
type GetUpdatesResponse_OffsetCheckpoint ¶
type GetUpdatesResponse_OffsetCheckpoint struct {
OffsetCheckpoint *OffsetCheckpoint `protobuf:"bytes,3,opt,name=offset_checkpoint,json=offsetCheckpoint,proto3,oneof"`
}
type GetUpdatesResponse_Reassignment ¶
type GetUpdatesResponse_Reassignment struct {
Reassignment *Reassignment `protobuf:"bytes,2,opt,name=reassignment,proto3,oneof"`
}
type GetUpdatesResponse_TopologyTransaction ¶
type GetUpdatesResponse_TopologyTransaction struct {
TopologyTransaction *TopologyTransaction `protobuf:"bytes,4,opt,name=topology_transaction,json=topologyTransaction,proto3,oneof"`
}
type GetUpdatesResponse_Transaction ¶
type GetUpdatesResponse_Transaction struct {
Transaction *Transaction `protobuf:"bytes,1,opt,name=transaction,proto3,oneof"`
}
type HashFunction ¶
type HashFunction int32
const (
HashFunction_HASH_FUNCTION_SHA256 HashFunction = 0
)
func (HashFunction) Descriptor ¶
func (HashFunction) Descriptor() protoreflect.EnumDescriptor
func (HashFunction) Enum ¶
func (x HashFunction) Enum() *HashFunction
func (HashFunction) EnumDescriptor
deprecated
func (HashFunction) EnumDescriptor() ([]byte, []int)
Deprecated: Use HashFunction.Descriptor instead.
func (HashFunction) Number ¶
func (x HashFunction) Number() protoreflect.EnumNumber
func (HashFunction) String ¶
func (x HashFunction) String() string
func (HashFunction) Type ¶
func (HashFunction) Type() protoreflect.EnumType
type Identifier ¶
type Identifier struct {
// Generally, the identifier of the Daml package that contains the entity.
// When encoding a package-id, it must be a valid PackageIdString.
//
// The field is overloaded to also be able to contain the package-name of the Daml package.
// This is supported if the entity referenced is either an interface or template.
// When representing the Daml package-name, the encoding is of form `#<package-name>`
// where `#` (not a valid package-id character)
// is used as a discriminator for signalling a package-name encoding.
//
// Required
PackageId string `protobuf:"bytes,1,opt,name=package_id,json=packageId,proto3" json:"package_id,omitempty"`
// The dot-separated module name of the identifier.
// Required
ModuleName string `protobuf:"bytes,2,opt,name=module_name,json=moduleName,proto3" json:"module_name,omitempty"`
// The dot-separated name of the entity (e.g. record, template, ...) within the module.
// Required
EntityName string `protobuf:"bytes,3,opt,name=entity_name,json=entityName,proto3" json:"entity_name,omitempty"`
// contains filtered or unexported fields
}
Unique identifier of an entity. Throughout this API, the following terminology is being used:
- if a Daml package-id is encoded in the package_id field, it is referred to as using a "package-id reference format"
- if a Daml package-name is encoded in the package_id field, it is referred to as using a "package-name reference format"
func (*Identifier) Descriptor
deprecated
func (*Identifier) Descriptor() ([]byte, []int)
Deprecated: Use Identifier.ProtoReflect.Descriptor instead.
func (*Identifier) GetEntityName ¶
func (x *Identifier) GetEntityName() string
func (*Identifier) GetModuleName ¶
func (x *Identifier) GetModuleName() string
func (*Identifier) GetPackageId ¶
func (x *Identifier) GetPackageId() string
func (*Identifier) ProtoMessage ¶
func (*Identifier) ProtoMessage()
func (*Identifier) ProtoReflect ¶
func (x *Identifier) ProtoReflect() protoreflect.Message
func (*Identifier) Reset ¶
func (x *Identifier) Reset()
func (*Identifier) String ¶
func (x *Identifier) String() string
type IncompleteAssigned ¶
type IncompleteAssigned struct {
// Required
AssignedEvent *AssignedEvent `protobuf:"bytes,1,opt,name=assigned_event,json=assignedEvent,proto3" json:"assigned_event,omitempty"`
// contains filtered or unexported fields
}
func (*IncompleteAssigned) Descriptor
deprecated
func (*IncompleteAssigned) Descriptor() ([]byte, []int)
Deprecated: Use IncompleteAssigned.ProtoReflect.Descriptor instead.
func (*IncompleteAssigned) GetAssignedEvent ¶
func (x *IncompleteAssigned) GetAssignedEvent() *AssignedEvent
func (*IncompleteAssigned) ProtoMessage ¶
func (*IncompleteAssigned) ProtoMessage()
func (*IncompleteAssigned) ProtoReflect ¶
func (x *IncompleteAssigned) ProtoReflect() protoreflect.Message
func (*IncompleteAssigned) Reset ¶
func (x *IncompleteAssigned) Reset()
func (*IncompleteAssigned) String ¶
func (x *IncompleteAssigned) String() string
type IncompleteUnassigned ¶
type IncompleteUnassigned struct {
// Required
// The event as it appeared in the context of its last activation update (i.e. daml transaction or
// reassignment). In particular, the last activation offset, node_id pair is preserved.
// The last activation update is the most recent update created or assigned this contract on synchronizer_id synchronizer before
// the unassigned_event.
// The offset of the CreatedEvent might point to an already pruned update, therefore it cannot necessarily be used
// for lookups.
CreatedEvent *CreatedEvent `protobuf:"bytes,1,opt,name=created_event,json=createdEvent,proto3" json:"created_event,omitempty"`
// Required
UnassignedEvent *UnassignedEvent `protobuf:"bytes,2,opt,name=unassigned_event,json=unassignedEvent,proto3" json:"unassigned_event,omitempty"`
// contains filtered or unexported fields
}
func (*IncompleteUnassigned) Descriptor
deprecated
func (*IncompleteUnassigned) Descriptor() ([]byte, []int)
Deprecated: Use IncompleteUnassigned.ProtoReflect.Descriptor instead.
func (*IncompleteUnassigned) GetCreatedEvent ¶
func (x *IncompleteUnassigned) GetCreatedEvent() *CreatedEvent
func (*IncompleteUnassigned) GetUnassignedEvent ¶
func (x *IncompleteUnassigned) GetUnassignedEvent() *UnassignedEvent
func (*IncompleteUnassigned) ProtoMessage ¶
func (*IncompleteUnassigned) ProtoMessage()
func (*IncompleteUnassigned) ProtoReflect ¶
func (x *IncompleteUnassigned) ProtoReflect() protoreflect.Message
func (*IncompleteUnassigned) Reset ¶
func (x *IncompleteUnassigned) Reset()
func (*IncompleteUnassigned) String ¶
func (x *IncompleteUnassigned) String() string
type InterfaceFilter ¶
type InterfaceFilter struct {
// The interface that a matching contract must implement.
// The “interface_id“ needs to be valid: corresponding interface should be defined in
// one of the available packages at the time of the query.
// Both package-name and package-id reference formats for the identifier are supported.
// Note: The package-id reference identifier format is deprecated. We plan to end support for this format in version 3.4.
//
// Required
InterfaceId *Identifier `protobuf:"bytes,1,opt,name=interface_id,json=interfaceId,proto3" json:"interface_id,omitempty"`
// Whether to include the interface view on the contract in the returned “CreatedEvent“.
// Use this to access contract data in a uniform manner in your API client.
// Optional
IncludeInterfaceView bool `protobuf:"varint,2,opt,name=include_interface_view,json=includeInterfaceView,proto3" json:"include_interface_view,omitempty"`
// Whether to include a “created_event_blob“ in the returned “CreatedEvent“.
// Use this to access the contract create event payload in your API client
// for submitting it as a disclosed contract with future commands.
// Optional
IncludeCreatedEventBlob bool `` /* 135-byte string literal not displayed */
// contains filtered or unexported fields
}
This filter matches contracts that implement a specific interface.
func (*InterfaceFilter) Descriptor
deprecated
func (*InterfaceFilter) Descriptor() ([]byte, []int)
Deprecated: Use InterfaceFilter.ProtoReflect.Descriptor instead.
func (*InterfaceFilter) GetIncludeCreatedEventBlob ¶
func (x *InterfaceFilter) GetIncludeCreatedEventBlob() bool
func (*InterfaceFilter) GetIncludeInterfaceView ¶
func (x *InterfaceFilter) GetIncludeInterfaceView() bool
func (*InterfaceFilter) GetInterfaceId ¶
func (x *InterfaceFilter) GetInterfaceId() *Identifier
func (*InterfaceFilter) ProtoMessage ¶
func (*InterfaceFilter) ProtoMessage()
func (*InterfaceFilter) ProtoReflect ¶
func (x *InterfaceFilter) ProtoReflect() protoreflect.Message
func (*InterfaceFilter) Reset ¶
func (x *InterfaceFilter) Reset()
func (*InterfaceFilter) String ¶
func (x *InterfaceFilter) String() string
type InterfaceView ¶
type InterfaceView struct {
// The interface implemented by the matched event.
// The identifier uses the package-id reference format.
//
// Required
InterfaceId *Identifier `protobuf:"bytes,1,opt,name=interface_id,json=interfaceId,proto3" json:"interface_id,omitempty"`
// Whether the view was successfully computed, and if not,
// the reason for the error. The error is reported using the same rules
// for error codes and messages as the errors returned for API requests.
// Required
ViewStatus *status.Status `protobuf:"bytes,2,opt,name=view_status,json=viewStatus,proto3" json:"view_status,omitempty"`
// The value of the interface's view method on this event.
// Set if it was requested in the “InterfaceFilter“ and it could be
// successfully computed.
// Optional
ViewValue *Record `protobuf:"bytes,3,opt,name=view_value,json=viewValue,proto3" json:"view_value,omitempty"`
// contains filtered or unexported fields
}
View of a create event matched by an interface filter.
func (*InterfaceView) Descriptor
deprecated
func (*InterfaceView) Descriptor() ([]byte, []int)
Deprecated: Use InterfaceView.ProtoReflect.Descriptor instead.
func (*InterfaceView) GetInterfaceId ¶
func (x *InterfaceView) GetInterfaceId() *Identifier
func (*InterfaceView) GetViewStatus ¶
func (x *InterfaceView) GetViewStatus() *status.Status
func (*InterfaceView) GetViewValue ¶
func (x *InterfaceView) GetViewValue() *Record
func (*InterfaceView) ProtoMessage ¶
func (*InterfaceView) ProtoMessage()
func (*InterfaceView) ProtoReflect ¶
func (x *InterfaceView) ProtoReflect() protoreflect.Message
func (*InterfaceView) Reset ¶
func (x *InterfaceView) Reset()
func (*InterfaceView) String ¶
func (x *InterfaceView) String() string
type List ¶
type List struct {
// The elements must all be of the same concrete value type.
// Optional
Elements []*Value `protobuf:"bytes,1,rep,name=elements,proto3" json:"elements,omitempty"`
// contains filtered or unexported fields
}
A homogenous collection of values.
func (*List) Descriptor
deprecated
func (*List) GetElements ¶
func (*List) ProtoMessage ¶
func (*List) ProtoMessage()
func (*List) ProtoReflect ¶
func (x *List) ProtoReflect() protoreflect.Message
type ListPackagesRequest ¶
type ListPackagesRequest struct {
// contains filtered or unexported fields
}
func (*ListPackagesRequest) Descriptor
deprecated
func (*ListPackagesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListPackagesRequest.ProtoReflect.Descriptor instead.
func (*ListPackagesRequest) ProtoMessage ¶
func (*ListPackagesRequest) ProtoMessage()
func (*ListPackagesRequest) ProtoReflect ¶
func (x *ListPackagesRequest) ProtoReflect() protoreflect.Message
func (*ListPackagesRequest) Reset ¶
func (x *ListPackagesRequest) Reset()
func (*ListPackagesRequest) String ¶
func (x *ListPackagesRequest) String() string
type ListPackagesResponse ¶
type ListPackagesResponse struct {
// The IDs of all Daml-LF packages supported by the server.
// Each element must be a valid PackageIdString (as described in “value.proto“).
// Required
PackageIds []string `protobuf:"bytes,1,rep,name=package_ids,json=packageIds,proto3" json:"package_ids,omitempty"`
// contains filtered or unexported fields
}
func (*ListPackagesResponse) Descriptor
deprecated
func (*ListPackagesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListPackagesResponse.ProtoReflect.Descriptor instead.
func (*ListPackagesResponse) GetPackageIds ¶
func (x *ListPackagesResponse) GetPackageIds() []string
func (*ListPackagesResponse) ProtoMessage ¶
func (*ListPackagesResponse) ProtoMessage()
func (*ListPackagesResponse) ProtoReflect ¶
func (x *ListPackagesResponse) ProtoReflect() protoreflect.Message
func (*ListPackagesResponse) Reset ¶
func (x *ListPackagesResponse) Reset()
func (*ListPackagesResponse) String ¶
func (x *ListPackagesResponse) String() string
type ListVettedPackagesRequest ¶
type ListVettedPackagesRequest struct {
// The package metadata filter the returned vetted packages set must satisfy.
// Optional
PackageMetadataFilter *PackageMetadataFilter `` /* 126-byte string literal not displayed */
// The topology filter the returned vetted packages set must satisfy.
// Optional
TopologyStateFilter *TopologyStateFilter `protobuf:"bytes,2,opt,name=topology_state_filter,json=topologyStateFilter,proto3" json:"topology_state_filter,omitempty"`
// Pagination token to determine the specific page to fetch. Using the token
// guarantees that “VettedPackages“ on a subsequent page are all greater
// (“VettedPackages“ are sorted by synchronizer ID then participant ID) than
// the last “VettedPackages“ on a previous page.
//
// The server does not store intermediate results between calls chained by a
// series of page tokens. As a consequence, if new vetted packages are being
// added and a page is requested twice using the same token, more packages can
// be returned on the second call.
//
// Leave unspecified (i.e. as empty string) to fetch the first page.
//
// Optional
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// Maximum number of “VettedPackages“ results to return in a single page.
//
// If the page_size is unspecified (i.e. left as 0), the server will decide
// the number of results to be returned.
//
// If the page_size exceeds the maximum supported by the server, an
// error will be returned.
//
// To obtain the server's maximum consult the PackageService descriptor
// available in the VersionService.
//
// Optional
PageSize uint32 `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// contains filtered or unexported fields
}
func (*ListVettedPackagesRequest) Descriptor
deprecated
func (*ListVettedPackagesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListVettedPackagesRequest.ProtoReflect.Descriptor instead.
func (*ListVettedPackagesRequest) GetPackageMetadataFilter ¶
func (x *ListVettedPackagesRequest) GetPackageMetadataFilter() *PackageMetadataFilter
func (*ListVettedPackagesRequest) GetPageSize ¶
func (x *ListVettedPackagesRequest) GetPageSize() uint32
func (*ListVettedPackagesRequest) GetPageToken ¶
func (x *ListVettedPackagesRequest) GetPageToken() string
func (*ListVettedPackagesRequest) GetTopologyStateFilter ¶
func (x *ListVettedPackagesRequest) GetTopologyStateFilter() *TopologyStateFilter
func (*ListVettedPackagesRequest) ProtoMessage ¶
func (*ListVettedPackagesRequest) ProtoMessage()
func (*ListVettedPackagesRequest) ProtoReflect ¶
func (x *ListVettedPackagesRequest) ProtoReflect() protoreflect.Message
func (*ListVettedPackagesRequest) Reset ¶
func (x *ListVettedPackagesRequest) Reset()
func (*ListVettedPackagesRequest) String ¶
func (x *ListVettedPackagesRequest) String() string
type ListVettedPackagesResponse ¶
type ListVettedPackagesResponse struct {
// All “VettedPackages“ that contain at least one “VettedPackage“ matching
// both a “PackageMetadataFilter“ and a “TopologyStateFilter“.
// Sorted by synchronizer_id then participant_id.
VettedPackages []*VettedPackages `protobuf:"bytes,1,rep,name=vetted_packages,json=vettedPackages,proto3" json:"vetted_packages,omitempty"`
// Pagination token to retrieve the next page.
// Empty string if there are no further results.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// contains filtered or unexported fields
}
func (*ListVettedPackagesResponse) Descriptor
deprecated
func (*ListVettedPackagesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListVettedPackagesResponse.ProtoReflect.Descriptor instead.
func (*ListVettedPackagesResponse) GetNextPageToken ¶
func (x *ListVettedPackagesResponse) GetNextPageToken() string
func (*ListVettedPackagesResponse) GetVettedPackages ¶
func (x *ListVettedPackagesResponse) GetVettedPackages() []*VettedPackages
func (*ListVettedPackagesResponse) ProtoMessage ¶
func (*ListVettedPackagesResponse) ProtoMessage()
func (*ListVettedPackagesResponse) ProtoReflect ¶
func (x *ListVettedPackagesResponse) ProtoReflect() protoreflect.Message
func (*ListVettedPackagesResponse) Reset ¶
func (x *ListVettedPackagesResponse) Reset()
func (*ListVettedPackagesResponse) String ¶
func (x *ListVettedPackagesResponse) String() string
type OffsetCheckpoint ¶
type OffsetCheckpoint struct {
// The participant's offset, the details of the offset field are described in “community/ledger-api/README.md“.
// Required, must be a valid absolute offset (positive integer).
Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
SynchronizerTimes []*SynchronizerTime `protobuf:"bytes,2,rep,name=synchronizer_times,json=synchronizerTimes,proto3" json:"synchronizer_times,omitempty"`
// contains filtered or unexported fields
}
OffsetCheckpoints may be used to:
- detect time out of commands. - provide an offset which can be used to restart consumption.
func (*OffsetCheckpoint) Descriptor
deprecated
func (*OffsetCheckpoint) Descriptor() ([]byte, []int)
Deprecated: Use OffsetCheckpoint.ProtoReflect.Descriptor instead.
func (*OffsetCheckpoint) GetOffset ¶
func (x *OffsetCheckpoint) GetOffset() int64
func (*OffsetCheckpoint) GetSynchronizerTimes ¶
func (x *OffsetCheckpoint) GetSynchronizerTimes() []*SynchronizerTime
func (*OffsetCheckpoint) ProtoMessage ¶
func (*OffsetCheckpoint) ProtoMessage()
func (*OffsetCheckpoint) ProtoReflect ¶
func (x *OffsetCheckpoint) ProtoReflect() protoreflect.Message
func (*OffsetCheckpoint) Reset ¶
func (x *OffsetCheckpoint) Reset()
func (*OffsetCheckpoint) String ¶
func (x *OffsetCheckpoint) String() string
type OffsetCheckpointFeature ¶
type OffsetCheckpointFeature struct {
// The maximum delay to emmit a new OffsetCheckpoint if it exists
MaxOffsetCheckpointEmissionDelay *durationpb.Duration `` /* 163-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*OffsetCheckpointFeature) Descriptor
deprecated
func (*OffsetCheckpointFeature) Descriptor() ([]byte, []int)
Deprecated: Use OffsetCheckpointFeature.ProtoReflect.Descriptor instead.
func (*OffsetCheckpointFeature) GetMaxOffsetCheckpointEmissionDelay ¶
func (x *OffsetCheckpointFeature) GetMaxOffsetCheckpointEmissionDelay() *durationpb.Duration
func (*OffsetCheckpointFeature) ProtoMessage ¶
func (*OffsetCheckpointFeature) ProtoMessage()
func (*OffsetCheckpointFeature) ProtoReflect ¶
func (x *OffsetCheckpointFeature) ProtoReflect() protoreflect.Message
func (*OffsetCheckpointFeature) Reset ¶
func (x *OffsetCheckpointFeature) Reset()
func (*OffsetCheckpointFeature) String ¶
func (x *OffsetCheckpointFeature) String() string
type Optional ¶
type Optional struct {
Value *Value `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // optional
// contains filtered or unexported fields
}
Corresponds to Java's Optional type, Scala's Option, and Haskell's Maybe. The reason why we need to wrap this in an additional “message“ is that we need to be able to encode the “None“ case in the “Value“ oneof.
func (*Optional) Descriptor
deprecated
func (*Optional) ProtoMessage ¶
func (*Optional) ProtoMessage()
func (*Optional) ProtoReflect ¶
func (x *Optional) ProtoReflect() protoreflect.Message
type PackageFeature ¶
type PackageFeature struct {
// The maximum number of vetted packages the server can return in a single
// response (page) when listing them.
MaxVettedPackagesPageSize int32 `` /* 143-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*PackageFeature) Descriptor
deprecated
func (*PackageFeature) Descriptor() ([]byte, []int)
Deprecated: Use PackageFeature.ProtoReflect.Descriptor instead.
func (*PackageFeature) GetMaxVettedPackagesPageSize ¶
func (x *PackageFeature) GetMaxVettedPackagesPageSize() int32
func (*PackageFeature) ProtoMessage ¶
func (*PackageFeature) ProtoMessage()
func (*PackageFeature) ProtoReflect ¶
func (x *PackageFeature) ProtoReflect() protoreflect.Message
func (*PackageFeature) Reset ¶
func (x *PackageFeature) Reset()
func (*PackageFeature) String ¶
func (x *PackageFeature) String() string
type PackageMetadataFilter ¶
type PackageMetadataFilter struct {
// If this list is non-empty, any vetted package with a package ID in this
// list will match the filter.
PackageIds []string `protobuf:"bytes,1,rep,name=package_ids,json=packageIds,proto3" json:"package_ids,omitempty"`
// If this list is non-empty, any vetted package with a name matching at least
// one prefix in this list will match the filter.
PackageNamePrefixes []string `protobuf:"bytes,2,rep,name=package_name_prefixes,json=packageNamePrefixes,proto3" json:"package_name_prefixes,omitempty"`
// contains filtered or unexported fields
}
Filter the VettedPackages by package metadata.
A PackageMetadataFilter without package_ids and without package_name_prefixes matches any vetted package.
Non-empty fields specify candidate values of which at least one must match. If both fields are set, then a candidate is returned if it matches one of the fields.
func (*PackageMetadataFilter) Descriptor
deprecated
func (*PackageMetadataFilter) Descriptor() ([]byte, []int)
Deprecated: Use PackageMetadataFilter.ProtoReflect.Descriptor instead.
func (*PackageMetadataFilter) GetPackageIds ¶
func (x *PackageMetadataFilter) GetPackageIds() []string
func (*PackageMetadataFilter) GetPackageNamePrefixes ¶
func (x *PackageMetadataFilter) GetPackageNamePrefixes() []string
func (*PackageMetadataFilter) ProtoMessage ¶
func (*PackageMetadataFilter) ProtoMessage()
func (*PackageMetadataFilter) ProtoReflect ¶
func (x *PackageMetadataFilter) ProtoReflect() protoreflect.Message
func (*PackageMetadataFilter) Reset ¶
func (x *PackageMetadataFilter) Reset()
func (*PackageMetadataFilter) String ¶
func (x *PackageMetadataFilter) String() string
type PackageReference ¶
type PackageReference struct {
// Required
PackageId string `protobuf:"bytes,1,opt,name=package_id,json=packageId,proto3" json:"package_id,omitempty"`
// Required
PackageName string `protobuf:"bytes,2,opt,name=package_name,json=packageName,proto3" json:"package_name,omitempty"`
// Required
PackageVersion string `protobuf:"bytes,3,opt,name=package_version,json=packageVersion,proto3" json:"package_version,omitempty"`
// contains filtered or unexported fields
}
func (*PackageReference) Descriptor
deprecated
func (*PackageReference) Descriptor() ([]byte, []int)
Deprecated: Use PackageReference.ProtoReflect.Descriptor instead.
func (*PackageReference) GetPackageId ¶
func (x *PackageReference) GetPackageId() string
func (*PackageReference) GetPackageName ¶
func (x *PackageReference) GetPackageName() string
func (*PackageReference) GetPackageVersion ¶
func (x *PackageReference) GetPackageVersion() string
func (*PackageReference) ProtoMessage ¶
func (*PackageReference) ProtoMessage()
func (*PackageReference) ProtoReflect ¶
func (x *PackageReference) ProtoReflect() protoreflect.Message
func (*PackageReference) Reset ¶
func (x *PackageReference) Reset()
func (*PackageReference) String ¶
func (x *PackageReference) String() string
type PackageServiceClient ¶
type PackageServiceClient interface {
// Returns the identifiers of all supported packages.
ListPackages(ctx context.Context, in *ListPackagesRequest, opts ...grpc.CallOption) (*ListPackagesResponse, error)
// Returns the contents of a single package.
GetPackage(ctx context.Context, in *GetPackageRequest, opts ...grpc.CallOption) (*GetPackageResponse, error)
// Returns the status of a single package.
GetPackageStatus(ctx context.Context, in *GetPackageStatusRequest, opts ...grpc.CallOption) (*GetPackageStatusResponse, error)
// Lists which participant node vetted what packages on which synchronizer.
// Can be called by any authenticated user.
ListVettedPackages(ctx context.Context, in *ListVettedPackagesRequest, opts ...grpc.CallOption) (*ListVettedPackagesResponse, error)
}
PackageServiceClient is the client API for PackageService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
Allows clients to query the Daml-LF packages that are supported by the server.
func NewPackageServiceClient ¶
func NewPackageServiceClient(cc grpc.ClientConnInterface) PackageServiceClient
type PackageServiceServer ¶
type PackageServiceServer interface {
// Returns the identifiers of all supported packages.
ListPackages(context.Context, *ListPackagesRequest) (*ListPackagesResponse, error)
// Returns the contents of a single package.
GetPackage(context.Context, *GetPackageRequest) (*GetPackageResponse, error)
// Returns the status of a single package.
GetPackageStatus(context.Context, *GetPackageStatusRequest) (*GetPackageStatusResponse, error)
// Lists which participant node vetted what packages on which synchronizer.
// Can be called by any authenticated user.
ListVettedPackages(context.Context, *ListVettedPackagesRequest) (*ListVettedPackagesResponse, error)
// contains filtered or unexported methods
}
PackageServiceServer is the server API for PackageService service. All implementations must embed UnimplementedPackageServiceServer for forward compatibility.
Allows clients to query the Daml-LF packages that are supported by the server.
type PackageStatus ¶
type PackageStatus int32
const ( // The server is not aware of such a package. PackageStatus_PACKAGE_STATUS_UNSPECIFIED PackageStatus = 0 // The server is able to execute Daml commands operating on this package. PackageStatus_PACKAGE_STATUS_REGISTERED PackageStatus = 1 )
func (PackageStatus) Descriptor ¶
func (PackageStatus) Descriptor() protoreflect.EnumDescriptor
func (PackageStatus) Enum ¶
func (x PackageStatus) Enum() *PackageStatus
func (PackageStatus) EnumDescriptor
deprecated
func (PackageStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use PackageStatus.Descriptor instead.
func (PackageStatus) Number ¶
func (x PackageStatus) Number() protoreflect.EnumNumber
func (PackageStatus) String ¶
func (x PackageStatus) String() string
func (PackageStatus) Type ¶
func (PackageStatus) Type() protoreflect.EnumType
type ParticipantAuthorizationAdded ¶
type ParticipantAuthorizationAdded struct {
// Required
PartyId string `protobuf:"bytes,1,opt,name=party_id,json=partyId,proto3" json:"party_id,omitempty"`
// Required
ParticipantId string `protobuf:"bytes,2,opt,name=participant_id,json=participantId,proto3" json:"participant_id,omitempty"`
// Required
ParticipantPermission ParticipantPermission `` /* 175-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*ParticipantAuthorizationAdded) Descriptor
deprecated
func (*ParticipantAuthorizationAdded) Descriptor() ([]byte, []int)
Deprecated: Use ParticipantAuthorizationAdded.ProtoReflect.Descriptor instead.
func (*ParticipantAuthorizationAdded) GetParticipantId ¶
func (x *ParticipantAuthorizationAdded) GetParticipantId() string
func (*ParticipantAuthorizationAdded) GetParticipantPermission ¶
func (x *ParticipantAuthorizationAdded) GetParticipantPermission() ParticipantPermission
func (*ParticipantAuthorizationAdded) GetPartyId ¶
func (x *ParticipantAuthorizationAdded) GetPartyId() string
func (*ParticipantAuthorizationAdded) ProtoMessage ¶
func (*ParticipantAuthorizationAdded) ProtoMessage()
func (*ParticipantAuthorizationAdded) ProtoReflect ¶
func (x *ParticipantAuthorizationAdded) ProtoReflect() protoreflect.Message
func (*ParticipantAuthorizationAdded) Reset ¶
func (x *ParticipantAuthorizationAdded) Reset()
func (*ParticipantAuthorizationAdded) String ¶
func (x *ParticipantAuthorizationAdded) String() string
type ParticipantAuthorizationChanged ¶
type ParticipantAuthorizationChanged struct {
// Required
PartyId string `protobuf:"bytes,1,opt,name=party_id,json=partyId,proto3" json:"party_id,omitempty"`
// Required
ParticipantId string `protobuf:"bytes,2,opt,name=participant_id,json=participantId,proto3" json:"participant_id,omitempty"`
// Required
ParticipantPermission ParticipantPermission `` /* 175-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*ParticipantAuthorizationChanged) Descriptor
deprecated
func (*ParticipantAuthorizationChanged) Descriptor() ([]byte, []int)
Deprecated: Use ParticipantAuthorizationChanged.ProtoReflect.Descriptor instead.
func (*ParticipantAuthorizationChanged) GetParticipantId ¶
func (x *ParticipantAuthorizationChanged) GetParticipantId() string
func (*ParticipantAuthorizationChanged) GetParticipantPermission ¶
func (x *ParticipantAuthorizationChanged) GetParticipantPermission() ParticipantPermission
func (*ParticipantAuthorizationChanged) GetPartyId ¶
func (x *ParticipantAuthorizationChanged) GetPartyId() string
func (*ParticipantAuthorizationChanged) ProtoMessage ¶
func (*ParticipantAuthorizationChanged) ProtoMessage()
func (*ParticipantAuthorizationChanged) ProtoReflect ¶
func (x *ParticipantAuthorizationChanged) ProtoReflect() protoreflect.Message
func (*ParticipantAuthorizationChanged) Reset ¶
func (x *ParticipantAuthorizationChanged) Reset()
func (*ParticipantAuthorizationChanged) String ¶
func (x *ParticipantAuthorizationChanged) String() string
type ParticipantAuthorizationRevoked ¶
type ParticipantAuthorizationRevoked struct {
// Required
PartyId string `protobuf:"bytes,1,opt,name=party_id,json=partyId,proto3" json:"party_id,omitempty"`
// Required
ParticipantId string `protobuf:"bytes,2,opt,name=participant_id,json=participantId,proto3" json:"participant_id,omitempty"`
// contains filtered or unexported fields
}
func (*ParticipantAuthorizationRevoked) Descriptor
deprecated
func (*ParticipantAuthorizationRevoked) Descriptor() ([]byte, []int)
Deprecated: Use ParticipantAuthorizationRevoked.ProtoReflect.Descriptor instead.
func (*ParticipantAuthorizationRevoked) GetParticipantId ¶
func (x *ParticipantAuthorizationRevoked) GetParticipantId() string
func (*ParticipantAuthorizationRevoked) GetPartyId ¶
func (x *ParticipantAuthorizationRevoked) GetPartyId() string
func (*ParticipantAuthorizationRevoked) ProtoMessage ¶
func (*ParticipantAuthorizationRevoked) ProtoMessage()
func (*ParticipantAuthorizationRevoked) ProtoReflect ¶
func (x *ParticipantAuthorizationRevoked) ProtoReflect() protoreflect.Message
func (*ParticipantAuthorizationRevoked) Reset ¶
func (x *ParticipantAuthorizationRevoked) Reset()
func (*ParticipantAuthorizationRevoked) String ¶
func (x *ParticipantAuthorizationRevoked) String() string
type ParticipantAuthorizationTopologyFormat ¶
type ParticipantAuthorizationTopologyFormat struct {
// List of parties for which the topology transactions should be sent.
// Empty means: for all parties.
Parties []string `protobuf:"bytes,1,rep,name=parties,proto3" json:"parties,omitempty"`
// contains filtered or unexported fields
}
A format specifying which participant authorization topology transactions to include and how to render them.
func (*ParticipantAuthorizationTopologyFormat) Descriptor
deprecated
func (*ParticipantAuthorizationTopologyFormat) Descriptor() ([]byte, []int)
Deprecated: Use ParticipantAuthorizationTopologyFormat.ProtoReflect.Descriptor instead.
func (*ParticipantAuthorizationTopologyFormat) GetParties ¶
func (x *ParticipantAuthorizationTopologyFormat) GetParties() []string
func (*ParticipantAuthorizationTopologyFormat) ProtoMessage ¶
func (*ParticipantAuthorizationTopologyFormat) ProtoMessage()
func (*ParticipantAuthorizationTopologyFormat) ProtoReflect ¶
func (x *ParticipantAuthorizationTopologyFormat) ProtoReflect() protoreflect.Message
func (*ParticipantAuthorizationTopologyFormat) Reset ¶
func (x *ParticipantAuthorizationTopologyFormat) Reset()
func (*ParticipantAuthorizationTopologyFormat) String ¶
func (x *ParticipantAuthorizationTopologyFormat) String() string
type ParticipantPermission ¶
type ParticipantPermission int32
Enum indicating the permission level that the participant has for the party whose connected synchronizers are being listed.
const ( ParticipantPermission_PARTICIPANT_PERMISSION_UNSPECIFIED ParticipantPermission = 0 ParticipantPermission_PARTICIPANT_PERMISSION_SUBMISSION ParticipantPermission = 1 // participant can only confirm transactions ParticipantPermission_PARTICIPANT_PERMISSION_CONFIRMATION ParticipantPermission = 2 // participant can only observe transactions ParticipantPermission_PARTICIPANT_PERMISSION_OBSERVATION ParticipantPermission = 3 )
func (ParticipantPermission) Descriptor ¶
func (ParticipantPermission) Descriptor() protoreflect.EnumDescriptor
func (ParticipantPermission) Enum ¶
func (x ParticipantPermission) Enum() *ParticipantPermission
func (ParticipantPermission) EnumDescriptor
deprecated
func (ParticipantPermission) EnumDescriptor() ([]byte, []int)
Deprecated: Use ParticipantPermission.Descriptor instead.
func (ParticipantPermission) Number ¶
func (x ParticipantPermission) Number() protoreflect.EnumNumber
func (ParticipantPermission) String ¶
func (x ParticipantPermission) String() string
func (ParticipantPermission) Type ¶
func (ParticipantPermission) Type() protoreflect.EnumType
type PartyManagementFeature ¶
type PartyManagementFeature struct {
// The maximum number of parties the server can return in a single response (page).
MaxPartiesPageSize int32 `protobuf:"varint,1,opt,name=max_parties_page_size,json=maxPartiesPageSize,proto3" json:"max_parties_page_size,omitempty"`
// contains filtered or unexported fields
}
func (*PartyManagementFeature) Descriptor
deprecated
func (*PartyManagementFeature) Descriptor() ([]byte, []int)
Deprecated: Use PartyManagementFeature.ProtoReflect.Descriptor instead.
func (*PartyManagementFeature) GetMaxPartiesPageSize ¶
func (x *PartyManagementFeature) GetMaxPartiesPageSize() int32
func (*PartyManagementFeature) ProtoMessage ¶
func (*PartyManagementFeature) ProtoMessage()
func (*PartyManagementFeature) ProtoReflect ¶
func (x *PartyManagementFeature) ProtoReflect() protoreflect.Message
func (*PartyManagementFeature) Reset ¶
func (x *PartyManagementFeature) Reset()
func (*PartyManagementFeature) String ¶
func (x *PartyManagementFeature) String() string
type PrefetchContractKey ¶
type PrefetchContractKey struct {
// The template of contract the client wants to prefetch.
// Both package-name and package-id reference identifier formats for the template-id are supported.
// Note: The package-id reference identifier format is deprecated. We plan to end support for this format in version 3.4.
//
// Required
TemplateId *Identifier `protobuf:"bytes,1,opt,name=template_id,json=templateId,proto3" json:"template_id,omitempty"`
// The key of the contract the client wants to prefetch.
// Required
ContractKey *Value `protobuf:"bytes,2,opt,name=contract_key,json=contractKey,proto3" json:"contract_key,omitempty"`
// contains filtered or unexported fields
}
Preload contracts
func (*PrefetchContractKey) Descriptor
deprecated
func (*PrefetchContractKey) Descriptor() ([]byte, []int)
Deprecated: Use PrefetchContractKey.ProtoReflect.Descriptor instead.
func (*PrefetchContractKey) GetContractKey ¶
func (x *PrefetchContractKey) GetContractKey() *Value
func (*PrefetchContractKey) GetTemplateId ¶
func (x *PrefetchContractKey) GetTemplateId() *Identifier
func (*PrefetchContractKey) ProtoMessage ¶
func (*PrefetchContractKey) ProtoMessage()
func (*PrefetchContractKey) ProtoReflect ¶
func (x *PrefetchContractKey) ProtoReflect() protoreflect.Message
func (*PrefetchContractKey) Reset ¶
func (x *PrefetchContractKey) Reset()
func (*PrefetchContractKey) String ¶
func (x *PrefetchContractKey) String() string
type PriorTopologySerial ¶
type PriorTopologySerial struct {
// Types that are valid to be assigned to Serial:
//
// *PriorTopologySerial_Prior
// *PriorTopologySerial_NoPrior
Serial isPriorTopologySerial_Serial `protobuf_oneof:"serial"`
// contains filtered or unexported fields
}
The serial of last “VettedPackages“ topology transaction on a given participant and synchronizer.
func (*PriorTopologySerial) Descriptor
deprecated
func (*PriorTopologySerial) Descriptor() ([]byte, []int)
Deprecated: Use PriorTopologySerial.ProtoReflect.Descriptor instead.
func (*PriorTopologySerial) GetNoPrior ¶
func (x *PriorTopologySerial) GetNoPrior() *emptypb.Empty
func (*PriorTopologySerial) GetPrior ¶
func (x *PriorTopologySerial) GetPrior() uint32
func (*PriorTopologySerial) GetSerial ¶
func (x *PriorTopologySerial) GetSerial() isPriorTopologySerial_Serial
func (*PriorTopologySerial) ProtoMessage ¶
func (*PriorTopologySerial) ProtoMessage()
func (*PriorTopologySerial) ProtoReflect ¶
func (x *PriorTopologySerial) ProtoReflect() protoreflect.Message
func (*PriorTopologySerial) Reset ¶
func (x *PriorTopologySerial) Reset()
func (*PriorTopologySerial) String ¶
func (x *PriorTopologySerial) String() string
type PriorTopologySerial_Prior ¶
type PriorTopologySerial_Prior struct {
// Previous transaction's serial.
Prior uint32 `protobuf:"varint,1,opt,name=prior,proto3,oneof"`
}
type Reassignment ¶
type Reassignment struct {
// Assigned by the server. Useful for correlating logs.
// Must be a valid LedgerString (as described in “value.proto“).
// Required
UpdateId string `protobuf:"bytes,1,opt,name=update_id,json=updateId,proto3" json:"update_id,omitempty"`
// The ID of the command which resulted in this reassignment. Missing for everyone except the submitting party on the submitting participant.
// Must be a valid LedgerString (as described in “value.proto“).
// Optional
CommandId string `protobuf:"bytes,2,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
// The workflow ID used in reassignment command submission. Only set if the “workflow_id“ for the command was set.
// Must be a valid LedgerString (as described in “value.proto“).
// Optional
WorkflowId string `protobuf:"bytes,3,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
// The participant's offset. The details of this field are described in “community/ledger-api/README.md“.
// Required, must be a valid absolute offset (positive integer).
Offset int64 `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
// The collection of reassignment events. Required.
Events []*ReassignmentEvent `protobuf:"bytes,5,rep,name=events,proto3" json:"events,omitempty"`
// Optional; ledger API trace context
//
// The trace context transported in this message corresponds to the trace context supplied
// by the client application in a HTTP2 header of the original command submission.
// We typically use a header to transfer this type of information. Here we use message
// body, because it is used in gRPC streams which do not support per message headers.
// This field will be populated with the trace context contained in the original submission.
// If that was not provided, a unique ledger-api-server generated trace context will be used
// instead.
TraceContext *TraceContext `protobuf:"bytes,6,opt,name=trace_context,json=traceContext,proto3" json:"trace_context,omitempty"`
// The time at which the reassignment was recorded. The record time refers to the source/target
// synchronizer for an unassign/assign event respectively.
// Required
RecordTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=record_time,json=recordTime,proto3" json:"record_time,omitempty"`
// A valid synchronizer id.
// Identifies the synchronizer that synchronized this Reassignment.
// Required
SynchronizerId string `protobuf:"bytes,8,opt,name=synchronizer_id,json=synchronizerId,proto3" json:"synchronizer_id,omitempty"`
// contains filtered or unexported fields
}
Complete view of an on-ledger reassignment.
func (*Reassignment) Descriptor
deprecated
func (*Reassignment) Descriptor() ([]byte, []int)
Deprecated: Use Reassignment.ProtoReflect.Descriptor instead.
func (*Reassignment) GetCommandId ¶
func (x *Reassignment) GetCommandId() string
func (*Reassignment) GetEvents ¶
func (x *Reassignment) GetEvents() []*ReassignmentEvent
func (*Reassignment) GetOffset ¶
func (x *Reassignment) GetOffset() int64
func (*Reassignment) GetRecordTime ¶
func (x *Reassignment) GetRecordTime() *timestamppb.Timestamp
func (*Reassignment) GetSynchronizerId ¶
func (x *Reassignment) GetSynchronizerId() string
func (*Reassignment) GetTraceContext ¶
func (x *Reassignment) GetTraceContext() *TraceContext
func (*Reassignment) GetUpdateId ¶
func (x *Reassignment) GetUpdateId() string
func (*Reassignment) GetWorkflowId ¶
func (x *Reassignment) GetWorkflowId() string
func (*Reassignment) ProtoMessage ¶
func (*Reassignment) ProtoMessage()
func (*Reassignment) ProtoReflect ¶
func (x *Reassignment) ProtoReflect() protoreflect.Message
func (*Reassignment) Reset ¶
func (x *Reassignment) Reset()
func (*Reassignment) String ¶
func (x *Reassignment) String() string
type ReassignmentCommand ¶
type ReassignmentCommand struct {
// Types that are valid to be assigned to Command:
//
// *ReassignmentCommand_UnassignCommand
// *ReassignmentCommand_AssignCommand
Command isReassignmentCommand_Command `protobuf_oneof:"command"`
// contains filtered or unexported fields
}
func (*ReassignmentCommand) Descriptor
deprecated
func (*ReassignmentCommand) Descriptor() ([]byte, []int)
Deprecated: Use ReassignmentCommand.ProtoReflect.Descriptor instead.
func (*ReassignmentCommand) GetAssignCommand ¶
func (x *ReassignmentCommand) GetAssignCommand() *AssignCommand
func (*ReassignmentCommand) GetCommand ¶
func (x *ReassignmentCommand) GetCommand() isReassignmentCommand_Command
func (*ReassignmentCommand) GetUnassignCommand ¶
func (x *ReassignmentCommand) GetUnassignCommand() *UnassignCommand
func (*ReassignmentCommand) ProtoMessage ¶
func (*ReassignmentCommand) ProtoMessage()
func (*ReassignmentCommand) ProtoReflect ¶
func (x *ReassignmentCommand) ProtoReflect() protoreflect.Message
func (*ReassignmentCommand) Reset ¶
func (x *ReassignmentCommand) Reset()
func (*ReassignmentCommand) String ¶
func (x *ReassignmentCommand) String() string
type ReassignmentCommand_AssignCommand ¶
type ReassignmentCommand_AssignCommand struct {
AssignCommand *AssignCommand `protobuf:"bytes,2,opt,name=assign_command,json=assignCommand,proto3,oneof"`
}
type ReassignmentCommand_UnassignCommand ¶
type ReassignmentCommand_UnassignCommand struct {
UnassignCommand *UnassignCommand `protobuf:"bytes,1,opt,name=unassign_command,json=unassignCommand,proto3,oneof"`
}
type ReassignmentCommands ¶
type ReassignmentCommands struct {
// Identifier of the on-ledger workflow that this command is a part of.
// Must be a valid LedgerString (as described in “value.proto“).
// Optional
WorkflowId string `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
// Uniquely identifies the participant user that issued the command.
// Must be a valid UserIdString (as described in “value.proto“).
// Required unless authentication is used with a user token.
// In that case, the token's user-id will be used for the request's user_id.
UserId string `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
// Uniquely identifies the command.
// The triple (user_id, submitter, command_id) constitutes the change ID for the intended ledger change.
// The change ID can be used for matching the intended ledger changes with all their completions.
// Must be a valid LedgerString (as described in “value.proto“).
// Required
CommandId string `protobuf:"bytes,3,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
// Party on whose behalf the command should be executed.
// If ledger API authorization is enabled, then the authorization metadata must authorize the sender of the request
// to act on behalf of the given party.
// Must be a valid PartyIdString (as described in “value.proto“).
// Required
Submitter string `protobuf:"bytes,4,opt,name=submitter,proto3" json:"submitter,omitempty"`
// A unique identifier to distinguish completions for different submissions with the same change ID.
// Typically a random UUID. Applications are expected to use a different UUID for each retry of a submission
// with the same change ID.
// Must be a valid LedgerString (as described in “value.proto“).
//
// If omitted, the participant or the committer may set a value of their choice.
// Optional
SubmissionId string `protobuf:"bytes,5,opt,name=submission_id,json=submissionId,proto3" json:"submission_id,omitempty"`
// Individual elements of this reassignment. Must be non-empty.
Commands []*ReassignmentCommand `protobuf:"bytes,6,rep,name=commands,proto3" json:"commands,omitempty"`
// contains filtered or unexported fields
}
func (*ReassignmentCommands) Descriptor
deprecated
func (*ReassignmentCommands) Descriptor() ([]byte, []int)
Deprecated: Use ReassignmentCommands.ProtoReflect.Descriptor instead.
func (*ReassignmentCommands) GetCommandId ¶
func (x *ReassignmentCommands) GetCommandId() string
func (*ReassignmentCommands) GetCommands ¶
func (x *ReassignmentCommands) GetCommands() []*ReassignmentCommand
func (*ReassignmentCommands) GetSubmissionId ¶
func (x *ReassignmentCommands) GetSubmissionId() string
func (*ReassignmentCommands) GetSubmitter ¶
func (x *ReassignmentCommands) GetSubmitter() string
func (*ReassignmentCommands) GetUserId ¶
func (x *ReassignmentCommands) GetUserId() string
func (*ReassignmentCommands) GetWorkflowId ¶
func (x *ReassignmentCommands) GetWorkflowId() string
func (*ReassignmentCommands) ProtoMessage ¶
func (*ReassignmentCommands) ProtoMessage()
func (*ReassignmentCommands) ProtoReflect ¶
func (x *ReassignmentCommands) ProtoReflect() protoreflect.Message
func (*ReassignmentCommands) Reset ¶
func (x *ReassignmentCommands) Reset()
func (*ReassignmentCommands) String ¶
func (x *ReassignmentCommands) String() string
type ReassignmentEvent ¶
type ReassignmentEvent struct {
// Types that are valid to be assigned to Event:
//
// *ReassignmentEvent_Unassigned
// *ReassignmentEvent_Assigned
Event isReassignmentEvent_Event `protobuf_oneof:"event"`
// contains filtered or unexported fields
}
func (*ReassignmentEvent) Descriptor
deprecated
func (*ReassignmentEvent) Descriptor() ([]byte, []int)
Deprecated: Use ReassignmentEvent.ProtoReflect.Descriptor instead.
func (*ReassignmentEvent) GetAssigned ¶
func (x *ReassignmentEvent) GetAssigned() *AssignedEvent
func (*ReassignmentEvent) GetEvent ¶
func (x *ReassignmentEvent) GetEvent() isReassignmentEvent_Event
func (*ReassignmentEvent) GetUnassigned ¶
func (x *ReassignmentEvent) GetUnassigned() *UnassignedEvent
func (*ReassignmentEvent) ProtoMessage ¶
func (*ReassignmentEvent) ProtoMessage()
func (*ReassignmentEvent) ProtoReflect ¶
func (x *ReassignmentEvent) ProtoReflect() protoreflect.Message
func (*ReassignmentEvent) Reset ¶
func (x *ReassignmentEvent) Reset()
func (*ReassignmentEvent) String ¶
func (x *ReassignmentEvent) String() string
type ReassignmentEvent_Assigned ¶
type ReassignmentEvent_Assigned struct {
Assigned *AssignedEvent `protobuf:"bytes,2,opt,name=assigned,proto3,oneof"`
}
type ReassignmentEvent_Unassigned ¶
type ReassignmentEvent_Unassigned struct {
Unassigned *UnassignedEvent `protobuf:"bytes,1,opt,name=unassigned,proto3,oneof"`
}
type Record ¶
type Record struct {
// Omitted from the transaction stream when verbose streaming is not enabled.
// Optional when submitting commands.
RecordId *Identifier `protobuf:"bytes,1,opt,name=record_id,json=recordId,proto3" json:"record_id,omitempty"`
// The nested values of the record.
// Required
Fields []*RecordField `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
// contains filtered or unexported fields
}
Contains nested values.
func (*Record) Descriptor
deprecated
func (*Record) GetFields ¶
func (x *Record) GetFields() []*RecordField
func (*Record) GetRecordId ¶
func (x *Record) GetRecordId() *Identifier
func (*Record) ProtoMessage ¶
func (*Record) ProtoMessage()
func (*Record) ProtoReflect ¶
func (x *Record) ProtoReflect() protoreflect.Message
type RecordField ¶
type RecordField struct {
// When reading a transaction stream, it's omitted if verbose streaming is not enabled.
// When submitting a command, it's optional:
//
// - if all keys within a single record are present, the order in which fields appear does not matter. however, each key must appear exactly once.
// - if any of the keys within a single record are omitted, the order of fields MUST match the order of declaration in the Daml template.
//
// Must be a valid NameString
Label string `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
// A nested value of a record.
// Required
Value *Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
A named nested value within a record.
func (*RecordField) Descriptor
deprecated
func (*RecordField) Descriptor() ([]byte, []int)
Deprecated: Use RecordField.ProtoReflect.Descriptor instead.
func (*RecordField) GetLabel ¶
func (x *RecordField) GetLabel() string
func (*RecordField) GetValue ¶
func (x *RecordField) GetValue() *Value
func (*RecordField) ProtoMessage ¶
func (*RecordField) ProtoMessage()
func (*RecordField) ProtoReflect ¶
func (x *RecordField) ProtoReflect() protoreflect.Message
func (*RecordField) Reset ¶
func (x *RecordField) Reset()
func (*RecordField) String ¶
func (x *RecordField) String() string
type Signature ¶
type Signature struct {
Format SignatureFormat `protobuf:"varint,1,opt,name=format,proto3,enum=com.daml.ledger.api.v2.SignatureFormat" json:"format,omitempty"`
Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
// The fingerprint/id of the keypair used to create this signature and needed to verify.
SignedBy string `protobuf:"bytes,3,opt,name=signed_by,json=signedBy,proto3" json:"signed_by,omitempty"`
// The signing algorithm specification used to produce this signature
SigningAlgorithmSpec SigningAlgorithmSpec `` /* 173-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*Signature) Descriptor
deprecated
func (*Signature) GetFormat ¶
func (x *Signature) GetFormat() SignatureFormat
func (*Signature) GetSignature ¶
func (*Signature) GetSignedBy ¶
func (*Signature) GetSigningAlgorithmSpec ¶
func (x *Signature) GetSigningAlgorithmSpec() SigningAlgorithmSpec
func (*Signature) ProtoMessage ¶
func (*Signature) ProtoMessage()
func (*Signature) ProtoReflect ¶
func (x *Signature) ProtoReflect() protoreflect.Message
type SignatureFormat ¶
type SignatureFormat int32
const ( SignatureFormat_SIGNATURE_FORMAT_UNSPECIFIED SignatureFormat = 0 // Signature scheme specific signature format // Legacy format no longer used, except for migrations SignatureFormat_SIGNATURE_FORMAT_RAW SignatureFormat = 1 // ASN.1 + DER-encoding of the `r` and `s` integers, as defined in https://datatracker.ietf.org/doc/html/rfc3279#section-2.2.3 // Used for ECDSA signatures SignatureFormat_SIGNATURE_FORMAT_DER SignatureFormat = 2 // Concatenation of the integers `r || s` in little-endian form, as defined in https://datatracker.ietf.org/doc/html/rfc8032#section-3.3 // Note that this is different from the format defined in IEEE P1363, which uses concatenation in big-endian form. // Used for EdDSA signatures SignatureFormat_SIGNATURE_FORMAT_CONCAT SignatureFormat = 3 // Symbolic crypto, must only be used for testing SignatureFormat_SIGNATURE_FORMAT_SYMBOLIC SignatureFormat = 10000 )
func (SignatureFormat) Descriptor ¶
func (SignatureFormat) Descriptor() protoreflect.EnumDescriptor
func (SignatureFormat) Enum ¶
func (x SignatureFormat) Enum() *SignatureFormat
func (SignatureFormat) EnumDescriptor
deprecated
func (SignatureFormat) EnumDescriptor() ([]byte, []int)
Deprecated: Use SignatureFormat.Descriptor instead.
func (SignatureFormat) Number ¶
func (x SignatureFormat) Number() protoreflect.EnumNumber
func (SignatureFormat) String ¶
func (x SignatureFormat) String() string
func (SignatureFormat) Type ¶
func (SignatureFormat) Type() protoreflect.EnumType
type SigningAlgorithmSpec ¶
type SigningAlgorithmSpec int32
const ( SigningAlgorithmSpec_SIGNING_ALGORITHM_SPEC_UNSPECIFIED SigningAlgorithmSpec = 0 // EdDSA Signature based on Curve25519 with SHA-512 // http://ed25519.cr.yp.to/ SigningAlgorithmSpec_SIGNING_ALGORITHM_SPEC_ED25519 SigningAlgorithmSpec = 1 // Elliptic Curve Digital Signature Algorithm with SHA256 SigningAlgorithmSpec_SIGNING_ALGORITHM_SPEC_EC_DSA_SHA_256 SigningAlgorithmSpec = 2 // Elliptic Curve Digital Signature Algorithm with SHA384 SigningAlgorithmSpec_SIGNING_ALGORITHM_SPEC_EC_DSA_SHA_384 SigningAlgorithmSpec = 3 )
func (SigningAlgorithmSpec) Descriptor ¶
func (SigningAlgorithmSpec) Descriptor() protoreflect.EnumDescriptor
func (SigningAlgorithmSpec) Enum ¶
func (x SigningAlgorithmSpec) Enum() *SigningAlgorithmSpec
func (SigningAlgorithmSpec) EnumDescriptor
deprecated
func (SigningAlgorithmSpec) EnumDescriptor() ([]byte, []int)
Deprecated: Use SigningAlgorithmSpec.Descriptor instead.
func (SigningAlgorithmSpec) Number ¶
func (x SigningAlgorithmSpec) Number() protoreflect.EnumNumber
func (SigningAlgorithmSpec) String ¶
func (x SigningAlgorithmSpec) String() string
func (SigningAlgorithmSpec) Type ¶
func (SigningAlgorithmSpec) Type() protoreflect.EnumType
type SigningKeySpec ¶
type SigningKeySpec int32
const ( SigningKeySpec_SIGNING_KEY_SPEC_UNSPECIFIED SigningKeySpec = 0 // Elliptic Curve Key from Curve25519 // as defined in http://ed25519.cr.yp.to/ SigningKeySpec_SIGNING_KEY_SPEC_EC_CURVE25519 SigningKeySpec = 1 // Elliptic Curve Key from the NIST P-256 curve (aka secp256r1) // as defined in https://doi.org/10.6028/NIST.FIPS.186-4 SigningKeySpec_SIGNING_KEY_SPEC_EC_P256 SigningKeySpec = 2 // Elliptic Curve Key from the NIST P-384 curve (aka secp384r1) // as defined in https://doi.org/10.6028/NIST.FIPS.186-4 SigningKeySpec_SIGNING_KEY_SPEC_EC_P384 SigningKeySpec = 3 // Elliptic Curve Key from SECG P256k1 curve (aka secp256k1) // commonly used in bitcoin and ethereum // as defined in https://www.secg.org/sec2-v2.pdf SigningKeySpec_SIGNING_KEY_SPEC_EC_SECP256K1 SigningKeySpec = 4 )
func (SigningKeySpec) Descriptor ¶
func (SigningKeySpec) Descriptor() protoreflect.EnumDescriptor
func (SigningKeySpec) Enum ¶
func (x SigningKeySpec) Enum() *SigningKeySpec
func (SigningKeySpec) EnumDescriptor
deprecated
func (SigningKeySpec) EnumDescriptor() ([]byte, []int)
Deprecated: Use SigningKeySpec.Descriptor instead.
func (SigningKeySpec) Number ¶
func (x SigningKeySpec) Number() protoreflect.EnumNumber
func (SigningKeySpec) String ¶
func (x SigningKeySpec) String() string
func (SigningKeySpec) Type ¶
func (SigningKeySpec) Type() protoreflect.EnumType
type SigningPublicKey ¶
type SigningPublicKey struct {
// The serialization format of the public key
Format CryptoKeyFormat `protobuf:"varint,1,opt,name=format,proto3,enum=com.daml.ledger.api.v2.CryptoKeyFormat" json:"format,omitempty"`
// Serialized public key in the format specified above
KeyData []byte `protobuf:"bytes,2,opt,name=key_data,json=keyData,proto3" json:"key_data,omitempty"`
// The key specification
KeySpec SigningKeySpec `` /* 126-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*SigningPublicKey) Descriptor
deprecated
func (*SigningPublicKey) Descriptor() ([]byte, []int)
Deprecated: Use SigningPublicKey.ProtoReflect.Descriptor instead.
func (*SigningPublicKey) GetFormat ¶
func (x *SigningPublicKey) GetFormat() CryptoKeyFormat
func (*SigningPublicKey) GetKeyData ¶
func (x *SigningPublicKey) GetKeyData() []byte
func (*SigningPublicKey) GetKeySpec ¶
func (x *SigningPublicKey) GetKeySpec() SigningKeySpec
func (*SigningPublicKey) ProtoMessage ¶
func (*SigningPublicKey) ProtoMessage()
func (*SigningPublicKey) ProtoReflect ¶
func (x *SigningPublicKey) ProtoReflect() protoreflect.Message
func (*SigningPublicKey) Reset ¶
func (x *SigningPublicKey) Reset()
func (*SigningPublicKey) String ¶
func (x *SigningPublicKey) String() string
type StateServiceClient ¶
type StateServiceClient interface {
// Returns a stream of the snapshot of the active contracts and incomplete (un)assignments at a ledger offset.
// Once the stream of GetActiveContractsResponses completes,
// the client SHOULD begin streaming updates from the update service,
// starting at the GetActiveContractsRequest.active_at_offset specified in this request.
// Clients SHOULD NOT assume that the set of active contracts they receive reflects the state at the ledger end.
GetActiveContracts(ctx context.Context, in *GetActiveContractsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetActiveContractsResponse], error)
// Get the list of connected synchronizers at the time of the query.
GetConnectedSynchronizers(ctx context.Context, in *GetConnectedSynchronizersRequest, opts ...grpc.CallOption) (*GetConnectedSynchronizersResponse, error)
// Get the current ledger end.
// Subscriptions started with the returned offset will serve events after this RPC was called.
GetLedgerEnd(ctx context.Context, in *GetLedgerEndRequest, opts ...grpc.CallOption) (*GetLedgerEndResponse, error)
// Get the latest successfully pruned ledger offsets
GetLatestPrunedOffsets(ctx context.Context, in *GetLatestPrunedOffsetsRequest, opts ...grpc.CallOption) (*GetLatestPrunedOffsetsResponse, error)
}
StateServiceClient is the client API for StateService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
Allows clients to get state from the ledger.
func NewStateServiceClient ¶
func NewStateServiceClient(cc grpc.ClientConnInterface) StateServiceClient
type StateServiceServer ¶
type StateServiceServer interface {
// Returns a stream of the snapshot of the active contracts and incomplete (un)assignments at a ledger offset.
// Once the stream of GetActiveContractsResponses completes,
// the client SHOULD begin streaming updates from the update service,
// starting at the GetActiveContractsRequest.active_at_offset specified in this request.
// Clients SHOULD NOT assume that the set of active contracts they receive reflects the state at the ledger end.
GetActiveContracts(*GetActiveContractsRequest, grpc.ServerStreamingServer[GetActiveContractsResponse]) error
// Get the list of connected synchronizers at the time of the query.
GetConnectedSynchronizers(context.Context, *GetConnectedSynchronizersRequest) (*GetConnectedSynchronizersResponse, error)
// Get the current ledger end.
// Subscriptions started with the returned offset will serve events after this RPC was called.
GetLedgerEnd(context.Context, *GetLedgerEndRequest) (*GetLedgerEndResponse, error)
// Get the latest successfully pruned ledger offsets
GetLatestPrunedOffsets(context.Context, *GetLatestPrunedOffsetsRequest) (*GetLatestPrunedOffsetsResponse, error)
// contains filtered or unexported methods
}
StateServiceServer is the server API for StateService service. All implementations must embed UnimplementedStateServiceServer for forward compatibility.
Allows clients to get state from the ledger.
type StateService_GetActiveContractsClient ¶
type StateService_GetActiveContractsClient = grpc.ServerStreamingClient[GetActiveContractsResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type StateService_GetActiveContractsServer ¶
type StateService_GetActiveContractsServer = grpc.ServerStreamingServer[GetActiveContractsResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type SubmitAndWaitForReassignmentRequest ¶
type SubmitAndWaitForReassignmentRequest struct {
// The reassignment commands to be submitted.
// Required
ReassignmentCommands *ReassignmentCommands `protobuf:"bytes,1,opt,name=reassignment_commands,json=reassignmentCommands,proto3" json:"reassignment_commands,omitempty"`
// Optional
// If no event_format provided, the result will contain no events.
// The events in the result, will take shape TRANSACTION_SHAPE_ACS_DELTA.
EventFormat *EventFormat `protobuf:"bytes,2,opt,name=event_format,json=eventFormat,proto3" json:"event_format,omitempty"`
// contains filtered or unexported fields
}
This reassignment is executed as a single atomic update.
func (*SubmitAndWaitForReassignmentRequest) Descriptor
deprecated
func (*SubmitAndWaitForReassignmentRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubmitAndWaitForReassignmentRequest.ProtoReflect.Descriptor instead.
func (*SubmitAndWaitForReassignmentRequest) GetEventFormat ¶
func (x *SubmitAndWaitForReassignmentRequest) GetEventFormat() *EventFormat
func (*SubmitAndWaitForReassignmentRequest) GetReassignmentCommands ¶
func (x *SubmitAndWaitForReassignmentRequest) GetReassignmentCommands() *ReassignmentCommands
func (*SubmitAndWaitForReassignmentRequest) ProtoMessage ¶
func (*SubmitAndWaitForReassignmentRequest) ProtoMessage()
func (*SubmitAndWaitForReassignmentRequest) ProtoReflect ¶
func (x *SubmitAndWaitForReassignmentRequest) ProtoReflect() protoreflect.Message
func (*SubmitAndWaitForReassignmentRequest) Reset ¶
func (x *SubmitAndWaitForReassignmentRequest) Reset()
func (*SubmitAndWaitForReassignmentRequest) String ¶
func (x *SubmitAndWaitForReassignmentRequest) String() string
type SubmitAndWaitForReassignmentResponse ¶
type SubmitAndWaitForReassignmentResponse struct {
// The reassignment that resulted from the submitted reassignment command.
// The reassignment might contain no events (request conditions result in filtering out all of them).
// Required
Reassignment *Reassignment `protobuf:"bytes,1,opt,name=reassignment,proto3" json:"reassignment,omitempty"`
// contains filtered or unexported fields
}
func (*SubmitAndWaitForReassignmentResponse) Descriptor
deprecated
func (*SubmitAndWaitForReassignmentResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubmitAndWaitForReassignmentResponse.ProtoReflect.Descriptor instead.
func (*SubmitAndWaitForReassignmentResponse) GetReassignment ¶
func (x *SubmitAndWaitForReassignmentResponse) GetReassignment() *Reassignment
func (*SubmitAndWaitForReassignmentResponse) ProtoMessage ¶
func (*SubmitAndWaitForReassignmentResponse) ProtoMessage()
func (*SubmitAndWaitForReassignmentResponse) ProtoReflect ¶
func (x *SubmitAndWaitForReassignmentResponse) ProtoReflect() protoreflect.Message
func (*SubmitAndWaitForReassignmentResponse) Reset ¶
func (x *SubmitAndWaitForReassignmentResponse) Reset()
func (*SubmitAndWaitForReassignmentResponse) String ¶
func (x *SubmitAndWaitForReassignmentResponse) String() string
type SubmitAndWaitForTransactionRequest ¶
type SubmitAndWaitForTransactionRequest struct {
// The commands to be submitted.
// Required
Commands *Commands `protobuf:"bytes,1,opt,name=commands,proto3" json:"commands,omitempty"`
// If no “transaction_format“ is provided, a default will be used where “transaction_shape“ is set to
// TRANSACTION_SHAPE_ACS_DELTA, “event_format“ is defined with “filters_by_party“ containing wildcard-template
// filter for all original “act_as“ and “read_as“ parties and the “verbose“ flag is set.
// Optional
TransactionFormat *TransactionFormat `protobuf:"bytes,2,opt,name=transaction_format,json=transactionFormat,proto3" json:"transaction_format,omitempty"`
// contains filtered or unexported fields
}
These commands are executed as a single atomic transaction.
func (*SubmitAndWaitForTransactionRequest) Descriptor
deprecated
func (*SubmitAndWaitForTransactionRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubmitAndWaitForTransactionRequest.ProtoReflect.Descriptor instead.
func (*SubmitAndWaitForTransactionRequest) GetCommands ¶
func (x *SubmitAndWaitForTransactionRequest) GetCommands() *Commands
func (*SubmitAndWaitForTransactionRequest) GetTransactionFormat ¶
func (x *SubmitAndWaitForTransactionRequest) GetTransactionFormat() *TransactionFormat
func (*SubmitAndWaitForTransactionRequest) ProtoMessage ¶
func (*SubmitAndWaitForTransactionRequest) ProtoMessage()
func (*SubmitAndWaitForTransactionRequest) ProtoReflect ¶
func (x *SubmitAndWaitForTransactionRequest) ProtoReflect() protoreflect.Message
func (*SubmitAndWaitForTransactionRequest) Reset ¶
func (x *SubmitAndWaitForTransactionRequest) Reset()
func (*SubmitAndWaitForTransactionRequest) String ¶
func (x *SubmitAndWaitForTransactionRequest) String() string
type SubmitAndWaitForTransactionResponse ¶
type SubmitAndWaitForTransactionResponse struct {
// The transaction that resulted from the submitted command.
// The transaction might contain no events (request conditions result in filtering out all of them).
// Required
Transaction *Transaction `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"`
// contains filtered or unexported fields
}
func (*SubmitAndWaitForTransactionResponse) Descriptor
deprecated
func (*SubmitAndWaitForTransactionResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubmitAndWaitForTransactionResponse.ProtoReflect.Descriptor instead.
func (*SubmitAndWaitForTransactionResponse) GetTransaction ¶
func (x *SubmitAndWaitForTransactionResponse) GetTransaction() *Transaction
func (*SubmitAndWaitForTransactionResponse) ProtoMessage ¶
func (*SubmitAndWaitForTransactionResponse) ProtoMessage()
func (*SubmitAndWaitForTransactionResponse) ProtoReflect ¶
func (x *SubmitAndWaitForTransactionResponse) ProtoReflect() protoreflect.Message
func (*SubmitAndWaitForTransactionResponse) Reset ¶
func (x *SubmitAndWaitForTransactionResponse) Reset()
func (*SubmitAndWaitForTransactionResponse) String ¶
func (x *SubmitAndWaitForTransactionResponse) String() string
type SubmitAndWaitRequest ¶
type SubmitAndWaitRequest struct {
// The commands to be submitted.
// Required
Commands *Commands `protobuf:"bytes,1,opt,name=commands,proto3" json:"commands,omitempty"`
// contains filtered or unexported fields
}
These commands are executed as a single atomic transaction.
func (*SubmitAndWaitRequest) Descriptor
deprecated
func (*SubmitAndWaitRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubmitAndWaitRequest.ProtoReflect.Descriptor instead.
func (*SubmitAndWaitRequest) GetCommands ¶
func (x *SubmitAndWaitRequest) GetCommands() *Commands
func (*SubmitAndWaitRequest) ProtoMessage ¶
func (*SubmitAndWaitRequest) ProtoMessage()
func (*SubmitAndWaitRequest) ProtoReflect ¶
func (x *SubmitAndWaitRequest) ProtoReflect() protoreflect.Message
func (*SubmitAndWaitRequest) Reset ¶
func (x *SubmitAndWaitRequest) Reset()
func (*SubmitAndWaitRequest) String ¶
func (x *SubmitAndWaitRequest) String() string
type SubmitAndWaitResponse ¶
type SubmitAndWaitResponse struct {
// The id of the transaction that resulted from the submitted command.
// Must be a valid LedgerString (as described in “value.proto“).
// Required
UpdateId string `protobuf:"bytes,1,opt,name=update_id,json=updateId,proto3" json:"update_id,omitempty"`
// The details of the offset field are described in “community/ledger-api/README.md“.
// Required
CompletionOffset int64 `protobuf:"varint,2,opt,name=completion_offset,json=completionOffset,proto3" json:"completion_offset,omitempty"`
// contains filtered or unexported fields
}
func (*SubmitAndWaitResponse) Descriptor
deprecated
func (*SubmitAndWaitResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubmitAndWaitResponse.ProtoReflect.Descriptor instead.
func (*SubmitAndWaitResponse) GetCompletionOffset ¶
func (x *SubmitAndWaitResponse) GetCompletionOffset() int64
func (*SubmitAndWaitResponse) GetUpdateId ¶
func (x *SubmitAndWaitResponse) GetUpdateId() string
func (*SubmitAndWaitResponse) ProtoMessage ¶
func (*SubmitAndWaitResponse) ProtoMessage()
func (*SubmitAndWaitResponse) ProtoReflect ¶
func (x *SubmitAndWaitResponse) ProtoReflect() protoreflect.Message
func (*SubmitAndWaitResponse) Reset ¶
func (x *SubmitAndWaitResponse) Reset()
func (*SubmitAndWaitResponse) String ¶
func (x *SubmitAndWaitResponse) String() string
type SubmitReassignmentRequest ¶
type SubmitReassignmentRequest struct {
// The reassignment command to be submitted.
// Required
ReassignmentCommands *ReassignmentCommands `protobuf:"bytes,1,opt,name=reassignment_commands,json=reassignmentCommands,proto3" json:"reassignment_commands,omitempty"`
// contains filtered or unexported fields
}
func (*SubmitReassignmentRequest) Descriptor
deprecated
func (*SubmitReassignmentRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubmitReassignmentRequest.ProtoReflect.Descriptor instead.
func (*SubmitReassignmentRequest) GetReassignmentCommands ¶
func (x *SubmitReassignmentRequest) GetReassignmentCommands() *ReassignmentCommands
func (*SubmitReassignmentRequest) ProtoMessage ¶
func (*SubmitReassignmentRequest) ProtoMessage()
func (*SubmitReassignmentRequest) ProtoReflect ¶
func (x *SubmitReassignmentRequest) ProtoReflect() protoreflect.Message
func (*SubmitReassignmentRequest) Reset ¶
func (x *SubmitReassignmentRequest) Reset()
func (*SubmitReassignmentRequest) String ¶
func (x *SubmitReassignmentRequest) String() string
type SubmitReassignmentResponse ¶
type SubmitReassignmentResponse struct {
// contains filtered or unexported fields
}
func (*SubmitReassignmentResponse) Descriptor
deprecated
func (*SubmitReassignmentResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubmitReassignmentResponse.ProtoReflect.Descriptor instead.
func (*SubmitReassignmentResponse) ProtoMessage ¶
func (*SubmitReassignmentResponse) ProtoMessage()
func (*SubmitReassignmentResponse) ProtoReflect ¶
func (x *SubmitReassignmentResponse) ProtoReflect() protoreflect.Message
func (*SubmitReassignmentResponse) Reset ¶
func (x *SubmitReassignmentResponse) Reset()
func (*SubmitReassignmentResponse) String ¶
func (x *SubmitReassignmentResponse) String() string
type SubmitRequest ¶
type SubmitRequest struct {
// The commands to be submitted in a single transaction.
// Required
Commands *Commands `protobuf:"bytes,1,opt,name=commands,proto3" json:"commands,omitempty"`
// contains filtered or unexported fields
}
The submitted commands will be processed atomically in a single transaction. Moreover, each “Command“ in “commands“ will be executed in the order specified by the request.
func (*SubmitRequest) Descriptor
deprecated
func (*SubmitRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubmitRequest.ProtoReflect.Descriptor instead.
func (*SubmitRequest) GetCommands ¶
func (x *SubmitRequest) GetCommands() *Commands
func (*SubmitRequest) ProtoMessage ¶
func (*SubmitRequest) ProtoMessage()
func (*SubmitRequest) ProtoReflect ¶
func (x *SubmitRequest) ProtoReflect() protoreflect.Message
func (*SubmitRequest) Reset ¶
func (x *SubmitRequest) Reset()
func (*SubmitRequest) String ¶
func (x *SubmitRequest) String() string
type SubmitResponse ¶
type SubmitResponse struct {
// contains filtered or unexported fields
}
func (*SubmitResponse) Descriptor
deprecated
func (*SubmitResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubmitResponse.ProtoReflect.Descriptor instead.
func (*SubmitResponse) ProtoMessage ¶
func (*SubmitResponse) ProtoMessage()
func (*SubmitResponse) ProtoReflect ¶
func (x *SubmitResponse) ProtoReflect() protoreflect.Message
func (*SubmitResponse) Reset ¶
func (x *SubmitResponse) Reset()
func (*SubmitResponse) String ¶
func (x *SubmitResponse) String() string
type SynchronizerTime ¶
type SynchronizerTime struct {
// The id of the synchronizer.
// Required
SynchronizerId string `protobuf:"bytes,1,opt,name=synchronizer_id,json=synchronizerId,proto3" json:"synchronizer_id,omitempty"`
// All commands with a maximum record time below this value MUST be considered lost if their completion has not arrived before this checkpoint.
// Required
RecordTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=record_time,json=recordTime,proto3" json:"record_time,omitempty"`
// contains filtered or unexported fields
}
func (*SynchronizerTime) Descriptor
deprecated
func (*SynchronizerTime) Descriptor() ([]byte, []int)
Deprecated: Use SynchronizerTime.ProtoReflect.Descriptor instead.
func (*SynchronizerTime) GetRecordTime ¶
func (x *SynchronizerTime) GetRecordTime() *timestamppb.Timestamp
func (*SynchronizerTime) GetSynchronizerId ¶
func (x *SynchronizerTime) GetSynchronizerId() string
func (*SynchronizerTime) ProtoMessage ¶
func (*SynchronizerTime) ProtoMessage()
func (*SynchronizerTime) ProtoReflect ¶
func (x *SynchronizerTime) ProtoReflect() protoreflect.Message
func (*SynchronizerTime) Reset ¶
func (x *SynchronizerTime) Reset()
func (*SynchronizerTime) String ¶
func (x *SynchronizerTime) String() string
type TemplateFilter ¶
type TemplateFilter struct {
// A template for which the payload should be included in the response.
// The “template_id“ needs to be valid: corresponding template should be defined in
// one of the available packages at the time of the query.
// Both package-name and package-id reference formats for the identifier are supported.
// Note: The package-id reference identifier format is deprecated. We plan to end support for this format in version 3.4.
//
// Required
TemplateId *Identifier `protobuf:"bytes,1,opt,name=template_id,json=templateId,proto3" json:"template_id,omitempty"`
// Whether to include a “created_event_blob“ in the returned “CreatedEvent“.
// Use this to access the contract event payload in your API client
// for submitting it as a disclosed contract with future commands.
// Optional
IncludeCreatedEventBlob bool `` /* 135-byte string literal not displayed */
// contains filtered or unexported fields
}
This filter matches contracts of a specific template.
func (*TemplateFilter) Descriptor
deprecated
func (*TemplateFilter) Descriptor() ([]byte, []int)
Deprecated: Use TemplateFilter.ProtoReflect.Descriptor instead.
func (*TemplateFilter) GetIncludeCreatedEventBlob ¶
func (x *TemplateFilter) GetIncludeCreatedEventBlob() bool
func (*TemplateFilter) GetTemplateId ¶
func (x *TemplateFilter) GetTemplateId() *Identifier
func (*TemplateFilter) ProtoMessage ¶
func (*TemplateFilter) ProtoMessage()
func (*TemplateFilter) ProtoReflect ¶
func (x *TemplateFilter) ProtoReflect() protoreflect.Message
func (*TemplateFilter) Reset ¶
func (x *TemplateFilter) Reset()
func (*TemplateFilter) String ¶
func (x *TemplateFilter) String() string
type TextMap ¶
type TextMap struct {
Entries []*TextMap_Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
// contains filtered or unexported fields
}
func (*TextMap) Descriptor
deprecated
func (*TextMap) GetEntries ¶
func (x *TextMap) GetEntries() []*TextMap_Entry
func (*TextMap) ProtoMessage ¶
func (*TextMap) ProtoMessage()
func (*TextMap) ProtoReflect ¶
func (x *TextMap) ProtoReflect() protoreflect.Message
type TextMap_Entry ¶
type TextMap_Entry struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
Value *Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
func (*TextMap_Entry) Descriptor
deprecated
func (*TextMap_Entry) Descriptor() ([]byte, []int)
Deprecated: Use TextMap_Entry.ProtoReflect.Descriptor instead.
func (*TextMap_Entry) GetKey ¶
func (x *TextMap_Entry) GetKey() string
func (*TextMap_Entry) GetValue ¶
func (x *TextMap_Entry) GetValue() *Value
func (*TextMap_Entry) ProtoMessage ¶
func (*TextMap_Entry) ProtoMessage()
func (*TextMap_Entry) ProtoReflect ¶
func (x *TextMap_Entry) ProtoReflect() protoreflect.Message
func (*TextMap_Entry) Reset ¶
func (x *TextMap_Entry) Reset()
func (*TextMap_Entry) String ¶
func (x *TextMap_Entry) String() string
type TopologyEvent ¶
type TopologyEvent struct {
// Types that are valid to be assigned to Event:
//
// *TopologyEvent_ParticipantAuthorizationChanged
// *TopologyEvent_ParticipantAuthorizationRevoked
// *TopologyEvent_ParticipantAuthorizationAdded
Event isTopologyEvent_Event `protobuf_oneof:"event"`
// contains filtered or unexported fields
}
func (*TopologyEvent) Descriptor
deprecated
func (*TopologyEvent) Descriptor() ([]byte, []int)
Deprecated: Use TopologyEvent.ProtoReflect.Descriptor instead.
func (*TopologyEvent) GetEvent ¶
func (x *TopologyEvent) GetEvent() isTopologyEvent_Event
func (*TopologyEvent) GetParticipantAuthorizationAdded ¶
func (x *TopologyEvent) GetParticipantAuthorizationAdded() *ParticipantAuthorizationAdded
func (*TopologyEvent) GetParticipantAuthorizationChanged ¶
func (x *TopologyEvent) GetParticipantAuthorizationChanged() *ParticipantAuthorizationChanged
func (*TopologyEvent) GetParticipantAuthorizationRevoked ¶
func (x *TopologyEvent) GetParticipantAuthorizationRevoked() *ParticipantAuthorizationRevoked
func (*TopologyEvent) ProtoMessage ¶
func (*TopologyEvent) ProtoMessage()
func (*TopologyEvent) ProtoReflect ¶
func (x *TopologyEvent) ProtoReflect() protoreflect.Message
func (*TopologyEvent) Reset ¶
func (x *TopologyEvent) Reset()
func (*TopologyEvent) String ¶
func (x *TopologyEvent) String() string
type TopologyEvent_ParticipantAuthorizationAdded ¶
type TopologyEvent_ParticipantAuthorizationAdded struct {
ParticipantAuthorizationAdded *ParticipantAuthorizationAdded `protobuf:"bytes,3,opt,name=participant_authorization_added,json=participantAuthorizationAdded,proto3,oneof"`
}
type TopologyEvent_ParticipantAuthorizationChanged ¶
type TopologyEvent_ParticipantAuthorizationChanged struct {
ParticipantAuthorizationChanged *ParticipantAuthorizationChanged `protobuf:"bytes,1,opt,name=participant_authorization_changed,json=participantAuthorizationChanged,proto3,oneof"`
}
type TopologyEvent_ParticipantAuthorizationRevoked ¶
type TopologyEvent_ParticipantAuthorizationRevoked struct {
ParticipantAuthorizationRevoked *ParticipantAuthorizationRevoked `protobuf:"bytes,2,opt,name=participant_authorization_revoked,json=participantAuthorizationRevoked,proto3,oneof"`
}
type TopologyFormat ¶
type TopologyFormat struct {
// Include participant authorization topology events in streams.
// Optional, if unset no participant authorization topology events are emitted in the stream.
IncludeParticipantAuthorizationEvents *ParticipantAuthorizationTopologyFormat `` /* 176-byte string literal not displayed */
// contains filtered or unexported fields
}
A format specifying which topology transactions to include and how to render them.
func (*TopologyFormat) Descriptor
deprecated
func (*TopologyFormat) Descriptor() ([]byte, []int)
Deprecated: Use TopologyFormat.ProtoReflect.Descriptor instead.
func (*TopologyFormat) GetIncludeParticipantAuthorizationEvents ¶
func (x *TopologyFormat) GetIncludeParticipantAuthorizationEvents() *ParticipantAuthorizationTopologyFormat
func (*TopologyFormat) ProtoMessage ¶
func (*TopologyFormat) ProtoMessage()
func (*TopologyFormat) ProtoReflect ¶
func (x *TopologyFormat) ProtoReflect() protoreflect.Message
func (*TopologyFormat) Reset ¶
func (x *TopologyFormat) Reset()
func (*TopologyFormat) String ¶
func (x *TopologyFormat) String() string
type TopologyStateFilter ¶
type TopologyStateFilter struct {
// If this list is non-empty, only vetted packages hosted on participants
// listed in this field match the filter.
// Query the current Ledger API's participant's ID via the public
// “GetParticipantId“ command in “PartyManagementService“.
ParticipantIds []string `protobuf:"bytes,1,rep,name=participant_ids,json=participantIds,proto3" json:"participant_ids,omitempty"`
// If this list is non-empty, only vetted packages from the topology state of
// the synchronizers in this list match the filter.
SynchronizerIds []string `protobuf:"bytes,2,rep,name=synchronizer_ids,json=synchronizerIds,proto3" json:"synchronizer_ids,omitempty"`
// contains filtered or unexported fields
}
Filter the vetted packages by the participant and synchronizer that they are hosted on.
Empty fields are ignored, such that a “TopologyStateFilter“ without participant_ids and without synchronizer_ids matches a vetted package hosted on any participant and synchronizer.
Non-empty fields specify candidate values of which at least one must match. If both fields are set then at least one candidate value must match from each field.
func (*TopologyStateFilter) Descriptor
deprecated
func (*TopologyStateFilter) Descriptor() ([]byte, []int)
Deprecated: Use TopologyStateFilter.ProtoReflect.Descriptor instead.
func (*TopologyStateFilter) GetParticipantIds ¶
func (x *TopologyStateFilter) GetParticipantIds() []string
func (*TopologyStateFilter) GetSynchronizerIds ¶
func (x *TopologyStateFilter) GetSynchronizerIds() []string
func (*TopologyStateFilter) ProtoMessage ¶
func (*TopologyStateFilter) ProtoMessage()
func (*TopologyStateFilter) ProtoReflect ¶
func (x *TopologyStateFilter) ProtoReflect() protoreflect.Message
func (*TopologyStateFilter) Reset ¶
func (x *TopologyStateFilter) Reset()
func (*TopologyStateFilter) String ¶
func (x *TopologyStateFilter) String() string
type TopologyTransaction ¶
type TopologyTransaction struct {
// Assigned by the server. Useful for correlating logs.
// Must be a valid LedgerString (as described in “value.proto“).
// Required
UpdateId string `protobuf:"bytes,1,opt,name=update_id,json=updateId,proto3" json:"update_id,omitempty"`
// The absolute offset. The details of this field are described in “community/ledger-api/README.md“.
// Required, it is a valid absolute offset (positive integer).
Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
// A valid synchronizer id.
// Identifies the synchronizer that synchronized the topology transaction.
// Required
SynchronizerId string `protobuf:"bytes,3,opt,name=synchronizer_id,json=synchronizerId,proto3" json:"synchronizer_id,omitempty"`
// The time at which the changes in the topology transaction become effective. There is a small delay between a
// topology transaction being sequenced and the changes it contains becoming effective. Topology transactions appear
// in order relative to a synchronizer based on their effective time rather than their sequencing time.
// Required
RecordTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=record_time,json=recordTime,proto3" json:"record_time,omitempty"`
// A non-empty list of topology events.
// Required
Events []*TopologyEvent `protobuf:"bytes,5,rep,name=events,proto3" json:"events,omitempty"`
// Optional; ledger API trace context
//
// The trace context transported in this message corresponds to the trace context supplied
// by the client application in a HTTP2 header of the original command submission.
// We typically use a header to transfer this type of information. Here we use message
// body, because it is used in gRPC streams which do not support per message headers.
// This field will be populated with the trace context contained in the original submission.
// If that was not provided, a unique ledger-api-server generated trace context will be used
// instead.
TraceContext *TraceContext `protobuf:"bytes,6,opt,name=trace_context,json=traceContext,proto3" json:"trace_context,omitempty"`
// contains filtered or unexported fields
}
func (*TopologyTransaction) Descriptor
deprecated
func (*TopologyTransaction) Descriptor() ([]byte, []int)
Deprecated: Use TopologyTransaction.ProtoReflect.Descriptor instead.
func (*TopologyTransaction) GetEvents ¶
func (x *TopologyTransaction) GetEvents() []*TopologyEvent
func (*TopologyTransaction) GetOffset ¶
func (x *TopologyTransaction) GetOffset() int64
func (*TopologyTransaction) GetRecordTime ¶
func (x *TopologyTransaction) GetRecordTime() *timestamppb.Timestamp
func (*TopologyTransaction) GetSynchronizerId ¶
func (x *TopologyTransaction) GetSynchronizerId() string
func (*TopologyTransaction) GetTraceContext ¶
func (x *TopologyTransaction) GetTraceContext() *TraceContext
func (*TopologyTransaction) GetUpdateId ¶
func (x *TopologyTransaction) GetUpdateId() string
func (*TopologyTransaction) ProtoMessage ¶
func (*TopologyTransaction) ProtoMessage()
func (*TopologyTransaction) ProtoReflect ¶
func (x *TopologyTransaction) ProtoReflect() protoreflect.Message
func (*TopologyTransaction) Reset ¶
func (x *TopologyTransaction) Reset()
func (*TopologyTransaction) String ¶
func (x *TopologyTransaction) String() string
type TraceContext ¶
type TraceContext struct {
// https://www.w3.org/TR/trace-context/
Traceparent *string `protobuf:"bytes,1,opt,name=traceparent,proto3,oneof" json:"traceparent,omitempty"`
Tracestate *string `protobuf:"bytes,2,opt,name=tracestate,proto3,oneof" json:"tracestate,omitempty"`
// contains filtered or unexported fields
}
func (*TraceContext) Descriptor
deprecated
func (*TraceContext) Descriptor() ([]byte, []int)
Deprecated: Use TraceContext.ProtoReflect.Descriptor instead.
func (*TraceContext) GetTraceparent ¶
func (x *TraceContext) GetTraceparent() string
func (*TraceContext) GetTracestate ¶
func (x *TraceContext) GetTracestate() string
func (*TraceContext) ProtoMessage ¶
func (*TraceContext) ProtoMessage()
func (*TraceContext) ProtoReflect ¶
func (x *TraceContext) ProtoReflect() protoreflect.Message
func (*TraceContext) Reset ¶
func (x *TraceContext) Reset()
func (*TraceContext) String ¶
func (x *TraceContext) String() string
type Transaction ¶
type Transaction struct {
// Assigned by the server. Useful for correlating logs.
// Must be a valid LedgerString (as described in “value.proto“).
// Required
UpdateId string `protobuf:"bytes,1,opt,name=update_id,json=updateId,proto3" json:"update_id,omitempty"`
// The ID of the command which resulted in this transaction. Missing for everyone except the submitting party.
// Must be a valid LedgerString (as described in “value.proto“).
// Optional
CommandId string `protobuf:"bytes,2,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
// The workflow ID used in command submission.
// Must be a valid LedgerString (as described in “value.proto“).
// Optional
WorkflowId string `protobuf:"bytes,3,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
// Ledger effective time.
// Required
EffectiveAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=effective_at,json=effectiveAt,proto3" json:"effective_at,omitempty"`
// The collection of events.
// Contains:
//
// - “CreatedEvent“ or “ArchivedEvent“ in case of ACS_DELTA transaction shape
// - “CreatedEvent“ or “ExercisedEvent“ in case of LEDGER_EFFECTS transaction shape
//
// Required
Events []*Event `protobuf:"bytes,5,rep,name=events,proto3" json:"events,omitempty"`
// The absolute offset. The details of this field are described in “community/ledger-api/README.md“.
// Required, it is a valid absolute offset (positive integer).
Offset int64 `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"`
// A valid synchronizer id.
// Identifies the synchronizer that synchronized the transaction.
// Required
SynchronizerId string `protobuf:"bytes,7,opt,name=synchronizer_id,json=synchronizerId,proto3" json:"synchronizer_id,omitempty"`
// Optional; ledger API trace context
//
// The trace context transported in this message corresponds to the trace context supplied
// by the client application in a HTTP2 header of the original command submission.
// We typically use a header to transfer this type of information. Here we use message
// body, because it is used in gRPC streams which do not support per message headers.
// This field will be populated with the trace context contained in the original submission.
// If that was not provided, a unique ledger-api-server generated trace context will be used
// instead.
TraceContext *TraceContext `protobuf:"bytes,8,opt,name=trace_context,json=traceContext,proto3" json:"trace_context,omitempty"`
// The time at which the transaction was recorded. The record time refers to the synchronizer
// which synchronized the transaction.
// Required
RecordTime *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=record_time,json=recordTime,proto3" json:"record_time,omitempty"`
// For transaction externally signed, contains the external transaction hash
// signed by the external party. Can be used to correlate an external submission with a committed transaction.
// Optional
ExternalTransactionHash []byte `` /* 139-byte string literal not displayed */
// contains filtered or unexported fields
}
Filtered view of an on-ledger transaction's create and archive events.
func (*Transaction) Descriptor
deprecated
func (*Transaction) Descriptor() ([]byte, []int)
Deprecated: Use Transaction.ProtoReflect.Descriptor instead.
func (*Transaction) GetCommandId ¶
func (x *Transaction) GetCommandId() string
func (*Transaction) GetEffectiveAt ¶
func (x *Transaction) GetEffectiveAt() *timestamppb.Timestamp
func (*Transaction) GetEvents ¶
func (x *Transaction) GetEvents() []*Event
func (*Transaction) GetExternalTransactionHash ¶
func (x *Transaction) GetExternalTransactionHash() []byte
func (*Transaction) GetOffset ¶
func (x *Transaction) GetOffset() int64
func (*Transaction) GetRecordTime ¶
func (x *Transaction) GetRecordTime() *timestamppb.Timestamp
func (*Transaction) GetSynchronizerId ¶
func (x *Transaction) GetSynchronizerId() string
func (*Transaction) GetTraceContext ¶
func (x *Transaction) GetTraceContext() *TraceContext
func (*Transaction) GetUpdateId ¶
func (x *Transaction) GetUpdateId() string
func (*Transaction) GetWorkflowId ¶
func (x *Transaction) GetWorkflowId() string
func (*Transaction) ProtoMessage ¶
func (*Transaction) ProtoMessage()
func (*Transaction) ProtoReflect ¶
func (x *Transaction) ProtoReflect() protoreflect.Message
func (*Transaction) Reset ¶
func (x *Transaction) Reset()
func (*Transaction) String ¶
func (x *Transaction) String() string
type TransactionFormat ¶
type TransactionFormat struct {
// Required
EventFormat *EventFormat `protobuf:"bytes,1,opt,name=event_format,json=eventFormat,proto3" json:"event_format,omitempty"`
// What transaction shape to use for interpreting the filters of the event format.
// Required
TransactionShape TransactionShape `` /* 155-byte string literal not displayed */
// contains filtered or unexported fields
}
A format that specifies what events to include in Daml transactions and what data to compute and include for them.
func (*TransactionFormat) Descriptor
deprecated
func (*TransactionFormat) Descriptor() ([]byte, []int)
Deprecated: Use TransactionFormat.ProtoReflect.Descriptor instead.
func (*TransactionFormat) GetEventFormat ¶
func (x *TransactionFormat) GetEventFormat() *EventFormat
func (*TransactionFormat) GetTransactionShape ¶
func (x *TransactionFormat) GetTransactionShape() TransactionShape
func (*TransactionFormat) ProtoMessage ¶
func (*TransactionFormat) ProtoMessage()
func (*TransactionFormat) ProtoReflect ¶
func (x *TransactionFormat) ProtoReflect() protoreflect.Message
func (*TransactionFormat) Reset ¶
func (x *TransactionFormat) Reset()
func (*TransactionFormat) String ¶
func (x *TransactionFormat) String() string
type TransactionShape ¶
type TransactionShape int32
Event shape for Transactions. Shapes are exclusive and only one of them can be defined in queries.
const ( // Following official proto3 convention, not intended for actual use. TransactionShape_TRANSACTION_SHAPE_UNSPECIFIED TransactionShape = 0 // Transaction shape that is sufficient to maintain an accurate ACS view. // The field witness_parties in events are populated as stakeholders, transaction filter will apply accordingly. // This translates to create and archive events. TransactionShape_TRANSACTION_SHAPE_ACS_DELTA TransactionShape = 1 // Transaction shape that allows maintaining an ACS and also conveys detailed information about // all exercises. // The field witness_parties in events are populated as cumulative informees, transaction filter will apply accordingly. // This translates to create, consuming exercise and non-consuming exercise. TransactionShape_TRANSACTION_SHAPE_LEDGER_EFFECTS TransactionShape = 2 )
func (TransactionShape) Descriptor ¶
func (TransactionShape) Descriptor() protoreflect.EnumDescriptor
func (TransactionShape) Enum ¶
func (x TransactionShape) Enum() *TransactionShape
func (TransactionShape) EnumDescriptor
deprecated
func (TransactionShape) EnumDescriptor() ([]byte, []int)
Deprecated: Use TransactionShape.Descriptor instead.
func (TransactionShape) Number ¶
func (x TransactionShape) Number() protoreflect.EnumNumber
func (TransactionShape) String ¶
func (x TransactionShape) String() string
func (TransactionShape) Type ¶
func (TransactionShape) Type() protoreflect.EnumType
type UnassignCommand ¶
type UnassignCommand struct {
// The ID of the contract the client wants to unassign.
// Must be a valid LedgerString (as described in “value.proto“).
// Required
ContractId string `protobuf:"bytes,1,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
// The ID of the source synchronizer
// Must be a valid synchronizer id
// Required
Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
// The ID of the target synchronizer
// Must be a valid synchronizer id
// Required
Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
// contains filtered or unexported fields
}
Unassign a contract
func (*UnassignCommand) Descriptor
deprecated
func (*UnassignCommand) Descriptor() ([]byte, []int)
Deprecated: Use UnassignCommand.ProtoReflect.Descriptor instead.
func (*UnassignCommand) GetContractId ¶
func (x *UnassignCommand) GetContractId() string
func (*UnassignCommand) GetSource ¶
func (x *UnassignCommand) GetSource() string
func (*UnassignCommand) GetTarget ¶
func (x *UnassignCommand) GetTarget() string
func (*UnassignCommand) ProtoMessage ¶
func (*UnassignCommand) ProtoMessage()
func (*UnassignCommand) ProtoReflect ¶
func (x *UnassignCommand) ProtoReflect() protoreflect.Message
func (*UnassignCommand) Reset ¶
func (x *UnassignCommand) Reset()
func (*UnassignCommand) String ¶
func (x *UnassignCommand) String() string
type UnassignedEvent ¶
type UnassignedEvent struct {
// The ID of the unassignment. This needs to be used as an input for a assign ReassignmentCommand.
// Must be a valid LedgerString (as described in “value.proto“).
// Required
ReassignmentId string `protobuf:"bytes,1,opt,name=reassignment_id,json=reassignmentId,proto3" json:"reassignment_id,omitempty"`
// The ID of the reassigned contract.
// Must be a valid LedgerString (as described in “value.proto“).
// Required
ContractId string `protobuf:"bytes,2,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
// The template of the reassigned contract.
// The identifier uses the package-id reference format.
//
// Required
TemplateId *Identifier `protobuf:"bytes,3,opt,name=template_id,json=templateId,proto3" json:"template_id,omitempty"`
// The ID of the source synchronizer
// Must be a valid synchronizer id
// Required
Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
// The ID of the target synchronizer
// Must be a valid synchronizer id
// Required
Target string `protobuf:"bytes,5,opt,name=target,proto3" json:"target,omitempty"`
// Party on whose behalf the unassign command was executed.
// Empty if the unassignment happened offline via the repair service.
// Must be a valid PartyIdString (as described in “value.proto“).
// Optional
Submitter string `protobuf:"bytes,6,opt,name=submitter,proto3" json:"submitter,omitempty"`
// Each corresponding assigned and unassigned event has the same reassignment_counter. This strictly increases
// with each unassign command for the same contract. Creation of the contract corresponds to reassignment_counter
// equals zero.
// Required
ReassignmentCounter uint64 `protobuf:"varint,7,opt,name=reassignment_counter,json=reassignmentCounter,proto3" json:"reassignment_counter,omitempty"`
// Assignment exclusivity
// Before this time (measured on the target synchronizer), only the submitter of the unassignment can initiate the assignment
// Defined for reassigning participants.
// Optional
AssignmentExclusivity *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=assignment_exclusivity,json=assignmentExclusivity,proto3" json:"assignment_exclusivity,omitempty"`
// The parties that are notified of this event.
// Required
WitnessParties []string `protobuf:"bytes,9,rep,name=witness_parties,json=witnessParties,proto3" json:"witness_parties,omitempty"`
// The package name of the contract.
// Required
PackageName string `protobuf:"bytes,10,opt,name=package_name,json=packageName,proto3" json:"package_name,omitempty"`
// The offset of origin.
// Offsets are managed by the participant nodes.
// Reassignments can thus NOT be assumed to have the same offsets on different participant nodes.
// Required, it is a valid absolute offset (positive integer)
Offset int64 `protobuf:"varint,11,opt,name=offset,proto3" json:"offset,omitempty"`
// The position of this event in the originating reassignment.
// Node IDs are not necessarily equal across participants,
// as these may see different projections/parts of reassignments.
// Required, must be valid node ID (non-negative integer)
NodeId int32 `protobuf:"varint,12,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
// contains filtered or unexported fields
}
Records that a contract has been unassigned, and it becomes unusable on the source synchronizer
func (*UnassignedEvent) Descriptor
deprecated
func (*UnassignedEvent) Descriptor() ([]byte, []int)
Deprecated: Use UnassignedEvent.ProtoReflect.Descriptor instead.
func (*UnassignedEvent) GetAssignmentExclusivity ¶
func (x *UnassignedEvent) GetAssignmentExclusivity() *timestamppb.Timestamp
func (*UnassignedEvent) GetContractId ¶
func (x *UnassignedEvent) GetContractId() string
func (*UnassignedEvent) GetNodeId ¶
func (x *UnassignedEvent) GetNodeId() int32
func (*UnassignedEvent) GetOffset ¶
func (x *UnassignedEvent) GetOffset() int64
func (*UnassignedEvent) GetPackageName ¶
func (x *UnassignedEvent) GetPackageName() string
func (*UnassignedEvent) GetReassignmentCounter ¶
func (x *UnassignedEvent) GetReassignmentCounter() uint64
func (*UnassignedEvent) GetReassignmentId ¶
func (x *UnassignedEvent) GetReassignmentId() string
func (*UnassignedEvent) GetSource ¶
func (x *UnassignedEvent) GetSource() string
func (*UnassignedEvent) GetSubmitter ¶
func (x *UnassignedEvent) GetSubmitter() string
func (*UnassignedEvent) GetTarget ¶
func (x *UnassignedEvent) GetTarget() string
func (*UnassignedEvent) GetTemplateId ¶
func (x *UnassignedEvent) GetTemplateId() *Identifier
func (*UnassignedEvent) GetWitnessParties ¶
func (x *UnassignedEvent) GetWitnessParties() []string
func (*UnassignedEvent) ProtoMessage ¶
func (*UnassignedEvent) ProtoMessage()
func (*UnassignedEvent) ProtoReflect ¶
func (x *UnassignedEvent) ProtoReflect() protoreflect.Message
func (*UnassignedEvent) Reset ¶
func (x *UnassignedEvent) Reset()
func (*UnassignedEvent) String ¶
func (x *UnassignedEvent) String() string
type UnimplementedCommandCompletionServiceServer ¶
type UnimplementedCommandCompletionServiceServer struct{}
UnimplementedCommandCompletionServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedCommandCompletionServiceServer) CompletionStream ¶
func (UnimplementedCommandCompletionServiceServer) CompletionStream(*CompletionStreamRequest, grpc.ServerStreamingServer[CompletionStreamResponse]) error
type UnimplementedCommandServiceServer ¶
type UnimplementedCommandServiceServer struct{}
UnimplementedCommandServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedCommandServiceServer) SubmitAndWait ¶
func (UnimplementedCommandServiceServer) SubmitAndWait(context.Context, *SubmitAndWaitRequest) (*SubmitAndWaitResponse, error)
func (UnimplementedCommandServiceServer) SubmitAndWaitForReassignment ¶
func (UnimplementedCommandServiceServer) SubmitAndWaitForReassignment(context.Context, *SubmitAndWaitForReassignmentRequest) (*SubmitAndWaitForReassignmentResponse, error)
func (UnimplementedCommandServiceServer) SubmitAndWaitForTransaction ¶
func (UnimplementedCommandServiceServer) SubmitAndWaitForTransaction(context.Context, *SubmitAndWaitForTransactionRequest) (*SubmitAndWaitForTransactionResponse, error)
type UnimplementedCommandSubmissionServiceServer ¶
type UnimplementedCommandSubmissionServiceServer struct{}
UnimplementedCommandSubmissionServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedCommandSubmissionServiceServer) Submit ¶
func (UnimplementedCommandSubmissionServiceServer) Submit(context.Context, *SubmitRequest) (*SubmitResponse, error)
func (UnimplementedCommandSubmissionServiceServer) SubmitReassignment ¶
func (UnimplementedCommandSubmissionServiceServer) SubmitReassignment(context.Context, *SubmitReassignmentRequest) (*SubmitReassignmentResponse, error)
type UnimplementedEventQueryServiceServer ¶
type UnimplementedEventQueryServiceServer struct{}
UnimplementedEventQueryServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedEventQueryServiceServer) GetEventsByContractId ¶
func (UnimplementedEventQueryServiceServer) GetEventsByContractId(context.Context, *GetEventsByContractIdRequest) (*GetEventsByContractIdResponse, error)
type UnimplementedPackageServiceServer ¶
type UnimplementedPackageServiceServer struct{}
UnimplementedPackageServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedPackageServiceServer) GetPackage ¶
func (UnimplementedPackageServiceServer) GetPackage(context.Context, *GetPackageRequest) (*GetPackageResponse, error)
func (UnimplementedPackageServiceServer) GetPackageStatus ¶
func (UnimplementedPackageServiceServer) GetPackageStatus(context.Context, *GetPackageStatusRequest) (*GetPackageStatusResponse, error)
func (UnimplementedPackageServiceServer) ListPackages ¶
func (UnimplementedPackageServiceServer) ListPackages(context.Context, *ListPackagesRequest) (*ListPackagesResponse, error)
func (UnimplementedPackageServiceServer) ListVettedPackages ¶
func (UnimplementedPackageServiceServer) ListVettedPackages(context.Context, *ListVettedPackagesRequest) (*ListVettedPackagesResponse, error)
type UnimplementedStateServiceServer ¶
type UnimplementedStateServiceServer struct{}
UnimplementedStateServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedStateServiceServer) GetActiveContracts ¶
func (UnimplementedStateServiceServer) GetActiveContracts(*GetActiveContractsRequest, grpc.ServerStreamingServer[GetActiveContractsResponse]) error
func (UnimplementedStateServiceServer) GetConnectedSynchronizers ¶
func (UnimplementedStateServiceServer) GetConnectedSynchronizers(context.Context, *GetConnectedSynchronizersRequest) (*GetConnectedSynchronizersResponse, error)
func (UnimplementedStateServiceServer) GetLatestPrunedOffsets ¶
func (UnimplementedStateServiceServer) GetLatestPrunedOffsets(context.Context, *GetLatestPrunedOffsetsRequest) (*GetLatestPrunedOffsetsResponse, error)
func (UnimplementedStateServiceServer) GetLedgerEnd ¶
func (UnimplementedStateServiceServer) GetLedgerEnd(context.Context, *GetLedgerEndRequest) (*GetLedgerEndResponse, error)
type UnimplementedUpdateServiceServer ¶
type UnimplementedUpdateServiceServer struct{}
UnimplementedUpdateServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedUpdateServiceServer) GetUpdateById ¶
func (UnimplementedUpdateServiceServer) GetUpdateById(context.Context, *GetUpdateByIdRequest) (*GetUpdateResponse, error)
func (UnimplementedUpdateServiceServer) GetUpdateByOffset ¶
func (UnimplementedUpdateServiceServer) GetUpdateByOffset(context.Context, *GetUpdateByOffsetRequest) (*GetUpdateResponse, error)
func (UnimplementedUpdateServiceServer) GetUpdates ¶
func (UnimplementedUpdateServiceServer) GetUpdates(*GetUpdatesRequest, grpc.ServerStreamingServer[GetUpdatesResponse]) error
type UnimplementedVersionServiceServer ¶
type UnimplementedVersionServiceServer struct{}
UnimplementedVersionServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedVersionServiceServer) GetLedgerApiVersion ¶
func (UnimplementedVersionServiceServer) GetLedgerApiVersion(context.Context, *GetLedgerApiVersionRequest) (*GetLedgerApiVersionResponse, error)
type UnsafeCommandCompletionServiceServer ¶
type UnsafeCommandCompletionServiceServer interface {
// contains filtered or unexported methods
}
UnsafeCommandCompletionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CommandCompletionServiceServer will result in compilation errors.
type UnsafeCommandServiceServer ¶
type UnsafeCommandServiceServer interface {
// contains filtered or unexported methods
}
UnsafeCommandServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CommandServiceServer will result in compilation errors.
type UnsafeCommandSubmissionServiceServer ¶
type UnsafeCommandSubmissionServiceServer interface {
// contains filtered or unexported methods
}
UnsafeCommandSubmissionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CommandSubmissionServiceServer will result in compilation errors.
type UnsafeEventQueryServiceServer ¶
type UnsafeEventQueryServiceServer interface {
// contains filtered or unexported methods
}
UnsafeEventQueryServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EventQueryServiceServer will result in compilation errors.
type UnsafePackageServiceServer ¶
type UnsafePackageServiceServer interface {
// contains filtered or unexported methods
}
UnsafePackageServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PackageServiceServer will result in compilation errors.
type UnsafeStateServiceServer ¶
type UnsafeStateServiceServer interface {
// contains filtered or unexported methods
}
UnsafeStateServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StateServiceServer will result in compilation errors.
type UnsafeUpdateServiceServer ¶
type UnsafeUpdateServiceServer interface {
// contains filtered or unexported methods
}
UnsafeUpdateServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UpdateServiceServer will result in compilation errors.
type UnsafeVersionServiceServer ¶
type UnsafeVersionServiceServer interface {
// contains filtered or unexported methods
}
UnsafeVersionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to VersionServiceServer will result in compilation errors.
type UpdateFormat ¶
type UpdateFormat struct {
// Include Daml transactions in streams.
// Optional, if unset, no transactions are emitted in the stream.
IncludeTransactions *TransactionFormat `protobuf:"bytes,1,opt,name=include_transactions,json=includeTransactions,proto3" json:"include_transactions,omitempty"`
// Include (un)assignments in the stream.
// The events in the result take the shape TRANSACTION_SHAPE_ACS_DELTA.
// Optional, if unset, no (un)assignments are emitted in the stream.
IncludeReassignments *EventFormat `protobuf:"bytes,2,opt,name=include_reassignments,json=includeReassignments,proto3" json:"include_reassignments,omitempty"`
// Include topology events in streams.
// Optional, if unset no topology events are emitted in the stream.
IncludeTopologyEvents *TopologyFormat `` /* 126-byte string literal not displayed */
// contains filtered or unexported fields
}
A format specifying what updates to include and how to render them.
func (*UpdateFormat) Descriptor
deprecated
func (*UpdateFormat) Descriptor() ([]byte, []int)
Deprecated: Use UpdateFormat.ProtoReflect.Descriptor instead.
func (*UpdateFormat) GetIncludeReassignments ¶
func (x *UpdateFormat) GetIncludeReassignments() *EventFormat
func (*UpdateFormat) GetIncludeTopologyEvents ¶
func (x *UpdateFormat) GetIncludeTopologyEvents() *TopologyFormat
func (*UpdateFormat) GetIncludeTransactions ¶
func (x *UpdateFormat) GetIncludeTransactions() *TransactionFormat
func (*UpdateFormat) ProtoMessage ¶
func (*UpdateFormat) ProtoMessage()
func (*UpdateFormat) ProtoReflect ¶
func (x *UpdateFormat) ProtoReflect() protoreflect.Message
func (*UpdateFormat) Reset ¶
func (x *UpdateFormat) Reset()
func (*UpdateFormat) String ¶
func (x *UpdateFormat) String() string
type UpdateServiceClient ¶
type UpdateServiceClient interface {
// Read the ledger's filtered update stream for the specified contents and filters.
// It returns the event types in accordance with the stream contents selected. Also the selection criteria
// for individual events depends on the transaction shape chosen.
//
// - ACS delta: a requesting party must be a stakeholder of an event for it to be included.
// - ledger effects: a requesting party must be a witness of an en event for it to be included.
GetUpdates(ctx context.Context, in *GetUpdatesRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetUpdatesResponse], error)
// Lookup an update by its offset.
// If there is no update with this offset, or all the events are filtered, an UPDATE_NOT_FOUND error will be raised.
GetUpdateByOffset(ctx context.Context, in *GetUpdateByOffsetRequest, opts ...grpc.CallOption) (*GetUpdateResponse, error)
// Lookup an update by its ID.
// If there is no update with this ID, or all the events are filtered, an UPDATE_NOT_FOUND error will be raised.
GetUpdateById(ctx context.Context, in *GetUpdateByIdRequest, opts ...grpc.CallOption) (*GetUpdateResponse, error)
}
UpdateServiceClient is the client API for UpdateService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
Allows clients to read updates (transactions, (un)assignments, topology events) from the ledger.
“GetUpdates“ and “GetUpdateTrees“ provide a comprehensive stream of updates/changes which happened on the virtual shared ledger. These streams are indexed with ledger offsets, which are strictly increasing. The virtual shared ledger consist of changes happening on multiple synchronizers which are connected to the serving participant. Each update belongs to one synchronizer, this is provided in the result (the “synchronizer_id“ field in “Transaction“ for transactions, the “source“ field in “UnassignedEvent“ and the “target“ field in “AssignedEvent“). Consumers can rely on strong causal guarantees on the virtual shared ledger for a single synchronizer: updates which have greater offsets are happened after than updates with smaller offsets for the same synchronizer. Across different synchronizers this is not guaranteed.
func NewUpdateServiceClient ¶
func NewUpdateServiceClient(cc grpc.ClientConnInterface) UpdateServiceClient
type UpdateServiceServer ¶
type UpdateServiceServer interface {
// Read the ledger's filtered update stream for the specified contents and filters.
// It returns the event types in accordance with the stream contents selected. Also the selection criteria
// for individual events depends on the transaction shape chosen.
//
// - ACS delta: a requesting party must be a stakeholder of an event for it to be included.
// - ledger effects: a requesting party must be a witness of an en event for it to be included.
GetUpdates(*GetUpdatesRequest, grpc.ServerStreamingServer[GetUpdatesResponse]) error
// Lookup an update by its offset.
// If there is no update with this offset, or all the events are filtered, an UPDATE_NOT_FOUND error will be raised.
GetUpdateByOffset(context.Context, *GetUpdateByOffsetRequest) (*GetUpdateResponse, error)
// Lookup an update by its ID.
// If there is no update with this ID, or all the events are filtered, an UPDATE_NOT_FOUND error will be raised.
GetUpdateById(context.Context, *GetUpdateByIdRequest) (*GetUpdateResponse, error)
// contains filtered or unexported methods
}
UpdateServiceServer is the server API for UpdateService service. All implementations must embed UnimplementedUpdateServiceServer for forward compatibility.
Allows clients to read updates (transactions, (un)assignments, topology events) from the ledger.
“GetUpdates“ and “GetUpdateTrees“ provide a comprehensive stream of updates/changes which happened on the virtual shared ledger. These streams are indexed with ledger offsets, which are strictly increasing. The virtual shared ledger consist of changes happening on multiple synchronizers which are connected to the serving participant. Each update belongs to one synchronizer, this is provided in the result (the “synchronizer_id“ field in “Transaction“ for transactions, the “source“ field in “UnassignedEvent“ and the “target“ field in “AssignedEvent“). Consumers can rely on strong causal guarantees on the virtual shared ledger for a single synchronizer: updates which have greater offsets are happened after than updates with smaller offsets for the same synchronizer. Across different synchronizers this is not guaranteed.
type UpdateService_GetUpdatesClient ¶
type UpdateService_GetUpdatesClient = grpc.ServerStreamingClient[GetUpdatesResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type UpdateService_GetUpdatesServer ¶
type UpdateService_GetUpdatesServer = grpc.ServerStreamingServer[GetUpdatesResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type UserManagementFeature ¶
type UserManagementFeature struct {
// Whether the Ledger API server provides the user management service.
Supported bool `protobuf:"varint,1,opt,name=supported,proto3" json:"supported,omitempty"`
// The maximum number of rights that can be assigned to a single user.
// Servers MUST support at least 100 rights per user.
// A value of 0 means that the server enforces no rights per user limit.
MaxRightsPerUser int32 `protobuf:"varint,2,opt,name=max_rights_per_user,json=maxRightsPerUser,proto3" json:"max_rights_per_user,omitempty"`
// The maximum number of users the server can return in a single response (page).
// Servers MUST support at least a 100 users per page.
// A value of 0 means that the server enforces no page size limit.
MaxUsersPageSize int32 `protobuf:"varint,3,opt,name=max_users_page_size,json=maxUsersPageSize,proto3" json:"max_users_page_size,omitempty"`
// contains filtered or unexported fields
}
func (*UserManagementFeature) Descriptor
deprecated
func (*UserManagementFeature) Descriptor() ([]byte, []int)
Deprecated: Use UserManagementFeature.ProtoReflect.Descriptor instead.
func (*UserManagementFeature) GetMaxRightsPerUser ¶
func (x *UserManagementFeature) GetMaxRightsPerUser() int32
func (*UserManagementFeature) GetMaxUsersPageSize ¶
func (x *UserManagementFeature) GetMaxUsersPageSize() int32
func (*UserManagementFeature) GetSupported ¶
func (x *UserManagementFeature) GetSupported() bool
func (*UserManagementFeature) ProtoMessage ¶
func (*UserManagementFeature) ProtoMessage()
func (*UserManagementFeature) ProtoReflect ¶
func (x *UserManagementFeature) ProtoReflect() protoreflect.Message
func (*UserManagementFeature) Reset ¶
func (x *UserManagementFeature) Reset()
func (*UserManagementFeature) String ¶
func (x *UserManagementFeature) String() string
type Value ¶
type Value struct {
// Types that are valid to be assigned to Sum:
//
// *Value_Unit
// *Value_Bool
// *Value_Int64
// *Value_Date
// *Value_Timestamp
// *Value_Numeric
// *Value_Party
// *Value_Text
// *Value_ContractId
// *Value_Optional
// *Value_List
// *Value_TextMap
// *Value_GenMap
// *Value_Record
// *Value_Variant
// *Value_Enum
Sum isValue_Sum `protobuf_oneof:"sum"`
// contains filtered or unexported fields
}
Encodes values that the ledger accepts as command arguments and emits as contract arguments.
The values encoding use different classes of non-empty strings as identifiers. Those classes are defined as follows:
- NameStrings are strings with length <= 1000 that match the regexp “[A-Za-z\$_][A-Za-z0-9\$_]*“. - PackageIdStrings are strings with length <= 64 that match the regexp “[A-Za-z0-9\-_ ]+“. - PartyIdStrings are strings with length <= 255 that match the regexp “[A-Za-z0-9:\-_ ]+“. - LedgerStrings are strings with length <= 255 that match the regexp “[A-Za-z0-9#:\-_/ ]+“. - UserIdStrings are strings with length <= 128 that match the regexp “[a-zA-Z0-9@^$.!`\-#+'~_|:]+“.
func (*Value) Descriptor
deprecated
func (*Value) GetContractId ¶
func (*Value) GetNumeric ¶
func (*Value) GetOptional ¶
func (*Value) GetTextMap ¶
func (*Value) GetTimestamp ¶
func (*Value) GetVariant ¶
func (*Value) ProtoMessage ¶
func (*Value) ProtoMessage()
func (*Value) ProtoReflect ¶
func (x *Value) ProtoReflect() protoreflect.Message
type Value_Bool ¶
type Value_Bool struct {
// True or false.
Bool bool `protobuf:"varint,2,opt,name=bool,proto3,oneof"`
}
type Value_ContractId ¶
type Value_ContractId struct {
// Identifier of an on-ledger contract. Commands which reference an unknown or already archived contract ID will fail.
// Must be a valid LedgerString.
ContractId string `protobuf:"bytes,9,opt,name=contract_id,json=contractId,proto3,oneof"`
}
type Value_Date ¶
type Value_Date struct {
// Days since the unix epoch. Can go backwards. Limited from
// 0001-01-01 to 9999-12-31, also to be compatible with
// https://www.ietf.org/rfc/rfc3339.txt
Date int32 `protobuf:"varint,4,opt,name=date,proto3,oneof"`
}
type Value_Enum ¶
type Value_Enum struct {
// The Enum type
Enum *Enum `protobuf:"bytes,16,opt,name=enum,proto3,oneof"`
}
type Value_GenMap ¶
type Value_GenMap struct {
// The GenMap type
GenMap *GenMap `protobuf:"bytes,13,opt,name=gen_map,json=genMap,proto3,oneof"`
}
type Value_Int64 ¶
type Value_Int64 struct {
Int64 int64 `protobuf:"zigzag64,3,opt,name=int64,proto3,oneof"`
}
type Value_List ¶
type Value_List struct {
// Represents a homogeneous list of values.
List *List `protobuf:"bytes,11,opt,name=list,proto3,oneof"`
}
type Value_Numeric ¶
type Value_Numeric struct {
// A Numeric, that is a decimal value with precision 38 (at most 38 significant digits) and a
// scale between 0 and 37 (significant digits on the right of the decimal point).
// The field has to match the regex
//
// .. code-block:: none
//
// [+-]?\d{1,38}(.\d{0,37})?
//
// and should be representable by a Numeric without loss of precision.
Numeric string `protobuf:"bytes,6,opt,name=numeric,proto3,oneof"`
}
type Value_Optional ¶
type Value_Optional struct {
// The Optional type, None or Some
Optional *Optional `protobuf:"bytes,10,opt,name=optional,proto3,oneof"`
}
type Value_Party ¶
type Value_Party struct {
// An agent operating on the ledger.
// Must be a valid PartyIdString.
Party string `protobuf:"bytes,7,opt,name=party,proto3,oneof"`
}
type Value_Record ¶
type Value_Record struct {
Record *Record `protobuf:"bytes,14,opt,name=record,proto3,oneof"`
}
type Value_Text ¶
type Value_Text struct {
// A string.
Text string `protobuf:"bytes,8,opt,name=text,proto3,oneof"`
}
type Value_TextMap ¶
type Value_TextMap struct {
// The TextMap type
TextMap *TextMap `protobuf:"bytes,12,opt,name=text_map,json=textMap,proto3,oneof"`
}
type Value_Timestamp ¶
type Value_Timestamp struct {
// Microseconds since the UNIX epoch. Can go backwards. Fixed
// since the vast majority of values will be greater than
// 2^28, since currently the number of microseconds since the
// epoch is greater than that. Range: 0001-01-01T00:00:00Z to
// 9999-12-31T23:59:59.999999Z, so that we can convert to/from
// https://www.ietf.org/rfc/rfc3339.txt
Timestamp int64 `protobuf:"fixed64,5,opt,name=timestamp,proto3,oneof"`
}
type Value_Unit ¶
type Value_Variant ¶
type Value_Variant struct {
Variant *Variant `protobuf:"bytes,15,opt,name=variant,proto3,oneof"`
}
type Variant ¶
type Variant struct {
// Omitted from the transaction stream when verbose streaming is not enabled.
// Optional when submitting commands.
VariantId *Identifier `protobuf:"bytes,1,opt,name=variant_id,json=variantId,proto3" json:"variant_id,omitempty"`
// Determines which of the Variant's alternatives is encoded in this message.
// Must be a valid NameString.
// Required
Constructor string `protobuf:"bytes,2,opt,name=constructor,proto3" json:"constructor,omitempty"`
// The value encoded within the Variant.
// Required
Value *Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
A value with alternative representations.
func (*Variant) Descriptor
deprecated
func (*Variant) GetConstructor ¶
func (*Variant) GetVariantId ¶
func (x *Variant) GetVariantId() *Identifier
func (*Variant) ProtoMessage ¶
func (*Variant) ProtoMessage()
func (*Variant) ProtoReflect ¶
func (x *Variant) ProtoReflect() protoreflect.Message
type VersionServiceClient ¶
type VersionServiceClient interface {
// Read the Ledger API version
GetLedgerApiVersion(ctx context.Context, in *GetLedgerApiVersionRequest, opts ...grpc.CallOption) (*GetLedgerApiVersionResponse, error)
}
VersionServiceClient is the client API for VersionService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
Allows clients to retrieve information about the ledger API version
func NewVersionServiceClient ¶
func NewVersionServiceClient(cc grpc.ClientConnInterface) VersionServiceClient
type VersionServiceServer ¶
type VersionServiceServer interface {
// Read the Ledger API version
GetLedgerApiVersion(context.Context, *GetLedgerApiVersionRequest) (*GetLedgerApiVersionResponse, error)
// contains filtered or unexported methods
}
VersionServiceServer is the server API for VersionService service. All implementations must embed UnimplementedVersionServiceServer for forward compatibility.
Allows clients to retrieve information about the ledger API version
type VettedPackage ¶
type VettedPackage struct {
// Package ID of this package. Always present.
PackageId string `protobuf:"bytes,1,opt,name=package_id,json=packageId,proto3" json:"package_id,omitempty"`
// The time from which this package is vetted. Empty if vetting time has no
// lower bound.
ValidFromInclusive *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=valid_from_inclusive,json=validFromInclusive,proto3" json:"valid_from_inclusive,omitempty"`
// The time until which this package is vetted. Empty if vetting time has no
// upper bound.
ValidUntilExclusive *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=valid_until_exclusive,json=validUntilExclusive,proto3" json:"valid_until_exclusive,omitempty"`
// Name of this package.
// Only available if the package has been uploaded to the current participant.
// If unavailable, is empty string.
PackageName string `protobuf:"bytes,4,opt,name=package_name,json=packageName,proto3" json:"package_name,omitempty"`
// Version of this package.
// Only available if the package has been uploaded to the current participant.
// If unavailable, is empty string.
PackageVersion string `protobuf:"bytes,5,opt,name=package_version,json=packageVersion,proto3" json:"package_version,omitempty"`
// contains filtered or unexported fields
}
A package that is vetting on a given participant and synchronizer, modelled after “VettedPackage“ in `topology.proto <https://github.com/digital-asset/canton/blob/main/community/base/src/main/protobuf/com/digitalasset/canton/protocol/v30/topology.proto#L206>`_, enriched with the package name and version.
func (*VettedPackage) Descriptor
deprecated
func (*VettedPackage) Descriptor() ([]byte, []int)
Deprecated: Use VettedPackage.ProtoReflect.Descriptor instead.
func (*VettedPackage) GetPackageId ¶
func (x *VettedPackage) GetPackageId() string
func (*VettedPackage) GetPackageName ¶
func (x *VettedPackage) GetPackageName() string
func (*VettedPackage) GetPackageVersion ¶
func (x *VettedPackage) GetPackageVersion() string
func (*VettedPackage) GetValidFromInclusive ¶
func (x *VettedPackage) GetValidFromInclusive() *timestamppb.Timestamp
func (*VettedPackage) GetValidUntilExclusive ¶
func (x *VettedPackage) GetValidUntilExclusive() *timestamppb.Timestamp
func (*VettedPackage) ProtoMessage ¶
func (*VettedPackage) ProtoMessage()
func (*VettedPackage) ProtoReflect ¶
func (x *VettedPackage) ProtoReflect() protoreflect.Message
func (*VettedPackage) Reset ¶
func (x *VettedPackage) Reset()
func (*VettedPackage) String ¶
func (x *VettedPackage) String() string
type VettedPackages ¶
type VettedPackages struct {
// Sorted by package_name and package_version where known, and package_id as a
// last resort.
Packages []*VettedPackage `protobuf:"bytes,1,rep,name=packages,proto3" json:"packages,omitempty"`
// Participant on which these packages are vetted. Always present.
ParticipantId string `protobuf:"bytes,2,opt,name=participant_id,json=participantId,proto3" json:"participant_id,omitempty"`
// Synchronizer on which these packages are vetted. Always present.
SynchronizerId string `protobuf:"bytes,3,opt,name=synchronizer_id,json=synchronizerId,proto3" json:"synchronizer_id,omitempty"`
// Serial of last “VettedPackages“ topology transaction of this participant
// and on this synchronizer. Always present.
TopologySerial uint32 `protobuf:"varint,4,opt,name=topology_serial,json=topologySerial,proto3" json:"topology_serial,omitempty"`
// contains filtered or unexported fields
}
The list of packages vetted on a given participant and synchronizer, modelled after “VettedPackages“ in `topology.proto <https://github.com/digital-asset/canton/blob/main/community/base/src/main/protobuf/com/digitalasset/canton/protocol/v30/topology.proto#L206>`_. The list only contains packages that matched a filter in the query that originated it.
func (*VettedPackages) Descriptor
deprecated
func (*VettedPackages) Descriptor() ([]byte, []int)
Deprecated: Use VettedPackages.ProtoReflect.Descriptor instead.
func (*VettedPackages) GetPackages ¶
func (x *VettedPackages) GetPackages() []*VettedPackage
func (*VettedPackages) GetParticipantId ¶
func (x *VettedPackages) GetParticipantId() string
func (*VettedPackages) GetSynchronizerId ¶
func (x *VettedPackages) GetSynchronizerId() string
func (*VettedPackages) GetTopologySerial ¶
func (x *VettedPackages) GetTopologySerial() uint32
func (*VettedPackages) ProtoMessage ¶
func (*VettedPackages) ProtoMessage()
func (*VettedPackages) ProtoReflect ¶
func (x *VettedPackages) ProtoReflect() protoreflect.Message
func (*VettedPackages) Reset ¶
func (x *VettedPackages) Reset()
func (*VettedPackages) String ¶
func (x *VettedPackages) String() string
type WildcardFilter ¶
type WildcardFilter struct {
// Whether to include a “created_event_blob“ in the returned “CreatedEvent“.
// Use this to access the contract create event payload in your API client
// for submitting it as a disclosed contract with future commands.
// Optional
IncludeCreatedEventBlob bool `` /* 135-byte string literal not displayed */
// contains filtered or unexported fields
}
This filter matches all templates.
func (*WildcardFilter) Descriptor
deprecated
func (*WildcardFilter) Descriptor() ([]byte, []int)
Deprecated: Use WildcardFilter.ProtoReflect.Descriptor instead.
func (*WildcardFilter) GetIncludeCreatedEventBlob ¶
func (x *WildcardFilter) GetIncludeCreatedEventBlob() bool
func (*WildcardFilter) ProtoMessage ¶
func (*WildcardFilter) ProtoMessage()
func (*WildcardFilter) ProtoReflect ¶
func (x *WildcardFilter) ProtoReflect() protoreflect.Message
func (*WildcardFilter) Reset ¶
func (x *WildcardFilter) Reset()
func (*WildcardFilter) String ¶
func (x *WildcardFilter) String() string
Source Files
¶
- command_completion_service.pb.go
- command_completion_service_grpc.pb.go
- command_service.pb.go
- command_service_grpc.pb.go
- command_submission_service.pb.go
- command_submission_service_grpc.pb.go
- commands.pb.go
- completion.pb.go
- crypto.pb.go
- event.pb.go
- event_query_service.pb.go
- event_query_service_grpc.pb.go
- experimental_features.pb.go
- offset_checkpoint.pb.go
- package_reference.pb.go
- package_service.pb.go
- package_service_grpc.pb.go
- reassignment.pb.go
- reassignment_commands.pb.go
- state_service.pb.go
- state_service_grpc.pb.go
- topology_transaction.pb.go
- trace_context.pb.go
- transaction.pb.go
- transaction_filter.pb.go
- update_service.pb.go
- update_service_grpc.pb.go
- value.pb.go
- version_service.pb.go
- version_service_grpc.pb.go