v1

package
v7.12.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 10, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_com_digitalasset_canton_domain_admin_v1_sequencer_initialization_service_proto protoreflect.FileDescriptor
View Source
var File_com_digitalasset_canton_domain_admin_v1_sequencer_initialization_snapshot_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type InitRequest

type InitRequest struct {
	DomainId string `protobuf:"bytes,1,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"`
	// a topology snapshot up until the point where this sequencer's key is registered
	TopologySnapshot *v0.TopologyTransactions   `protobuf:"bytes,2,opt,name=topology_snapshot,json=topologySnapshot,proto3" json:"topology_snapshot,omitempty"`
	DomainParameters *v1.StaticDomainParameters `protobuf:"bytes,4,opt,name=domain_parameters,json=domainParameters,proto3" json:"domain_parameters,omitempty"`
	// optional - snapshot to initialize sequencer from
	Snapshot *v01.SequencerSnapshot `protobuf:"bytes,3,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

Includes sufficient detail for:

  • the sequencer to generate its own key to return the public key to the domain node
  • topology and additional bootstrap information

func (*InitRequest) Descriptor deprecated

func (*InitRequest) Descriptor() ([]byte, []int)

Deprecated: Use InitRequest.ProtoReflect.Descriptor instead.

func (*InitRequest) GetDomainId

func (x *InitRequest) GetDomainId() string

func (*InitRequest) GetDomainParameters

func (x *InitRequest) GetDomainParameters() *v1.StaticDomainParameters

func (*InitRequest) GetSnapshot

func (x *InitRequest) GetSnapshot() *v01.SequencerSnapshot

func (*InitRequest) GetTopologySnapshot

func (x *InitRequest) GetTopologySnapshot() *v0.TopologyTransactions

func (*InitRequest) ProtoMessage

func (*InitRequest) ProtoMessage()

func (*InitRequest) ProtoReflect

func (x *InitRequest) ProtoReflect() protoreflect.Message

func (*InitRequest) Reset

func (x *InitRequest) Reset()

func (*InitRequest) String

func (x *InitRequest) String() string

type SequencerSnapshot

type SequencerSnapshot struct {
	LatestTimestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=latest_timestamp,json=latestTimestamp,proto3" json:"latest_timestamp,omitempty"`
	// Changed from map<string, int64> in v0 to explicit repeated so that we control the order of the entries
	HeadMemberCounters []*SequencerSnapshot_MemberCounter `protobuf:"bytes,2,rep,name=head_member_counters,json=headMemberCounters,proto3" json:"head_member_counters,omitempty"`
	Status             *v0.SequencerPruningStatus         `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	Additional         *v0.ImplementationSpecificInfo     `protobuf:"bytes,4,opt,name=additional,proto3" json:"additional,omitempty"`
	// New in v1
	InFlightAggregations []*SequencerSnapshot_InFlightAggregationWithId `protobuf:"bytes,5,rep,name=in_flight_aggregations,json=inFlightAggregations,proto3" json:"in_flight_aggregations,omitempty"`
	// New in v1
	TrafficSnapshots []*SequencerSnapshot_MemberTrafficSnapshot `protobuf:"bytes,6,rep,name=traffic_snapshots,json=trafficSnapshots,proto3" json:"traffic_snapshots,omitempty"`
	// contains filtered or unexported fields
}

func (*SequencerSnapshot) Descriptor deprecated

func (*SequencerSnapshot) Descriptor() ([]byte, []int)

Deprecated: Use SequencerSnapshot.ProtoReflect.Descriptor instead.

func (*SequencerSnapshot) GetAdditional

func (x *SequencerSnapshot) GetAdditional() *v0.ImplementationSpecificInfo

func (*SequencerSnapshot) GetHeadMemberCounters

func (x *SequencerSnapshot) GetHeadMemberCounters() []*SequencerSnapshot_MemberCounter

func (*SequencerSnapshot) GetInFlightAggregations

func (x *SequencerSnapshot) GetInFlightAggregations() []*SequencerSnapshot_InFlightAggregationWithId

func (*SequencerSnapshot) GetLatestTimestamp

func (x *SequencerSnapshot) GetLatestTimestamp() *timestamppb.Timestamp

func (*SequencerSnapshot) GetStatus

func (*SequencerSnapshot) GetTrafficSnapshots

func (x *SequencerSnapshot) GetTrafficSnapshots() []*SequencerSnapshot_MemberTrafficSnapshot

func (*SequencerSnapshot) ProtoMessage

func (*SequencerSnapshot) ProtoMessage()

func (*SequencerSnapshot) ProtoReflect

func (x *SequencerSnapshot) ProtoReflect() protoreflect.Message

func (*SequencerSnapshot) Reset

func (x *SequencerSnapshot) Reset()

func (*SequencerSnapshot) String

func (x *SequencerSnapshot) String() string

type SequencerSnapshot_AggregationBySender

type SequencerSnapshot_AggregationBySender struct {
	Sender               string                                     `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	SequencingTimestamp  *timestamppb.Timestamp                     `protobuf:"bytes,2,opt,name=sequencing_timestamp,json=sequencingTimestamp,proto3" json:"sequencing_timestamp,omitempty"`
	SignaturesByEnvelope []*SequencerSnapshot_SignaturesForEnvelope `protobuf:"bytes,3,rep,name=signatures_by_envelope,json=signaturesByEnvelope,proto3" json:"signatures_by_envelope,omitempty"`
	// contains filtered or unexported fields
}

func (*SequencerSnapshot_AggregationBySender) Descriptor deprecated

func (*SequencerSnapshot_AggregationBySender) Descriptor() ([]byte, []int)

Deprecated: Use SequencerSnapshot_AggregationBySender.ProtoReflect.Descriptor instead.

func (*SequencerSnapshot_AggregationBySender) GetSender

func (*SequencerSnapshot_AggregationBySender) GetSequencingTimestamp

func (x *SequencerSnapshot_AggregationBySender) GetSequencingTimestamp() *timestamppb.Timestamp

func (*SequencerSnapshot_AggregationBySender) GetSignaturesByEnvelope

func (*SequencerSnapshot_AggregationBySender) ProtoMessage

func (*SequencerSnapshot_AggregationBySender) ProtoMessage()

func (*SequencerSnapshot_AggregationBySender) ProtoReflect

func (*SequencerSnapshot_AggregationBySender) Reset

func (*SequencerSnapshot_AggregationBySender) String

type SequencerSnapshot_InFlightAggregationWithId

type SequencerSnapshot_InFlightAggregationWithId struct {
	AggregationId     []byte                                   `protobuf:"bytes,1,opt,name=aggregation_id,json=aggregationId,proto3" json:"aggregation_id,omitempty"`
	AggregationRule   *v01.AggregationRule                     `protobuf:"bytes,2,opt,name=aggregation_rule,json=aggregationRule,proto3" json:"aggregation_rule,omitempty"`
	MaxSequencingTime *timestamppb.Timestamp                   `protobuf:"bytes,3,opt,name=max_sequencing_time,json=maxSequencingTime,proto3" json:"max_sequencing_time,omitempty"`
	AggregatedSenders []*SequencerSnapshot_AggregationBySender `protobuf:"bytes,4,rep,name=aggregated_senders,json=aggregatedSenders,proto3" json:"aggregated_senders,omitempty"`
	// contains filtered or unexported fields
}

func (*SequencerSnapshot_InFlightAggregationWithId) Descriptor deprecated

Deprecated: Use SequencerSnapshot_InFlightAggregationWithId.ProtoReflect.Descriptor instead.

func (*SequencerSnapshot_InFlightAggregationWithId) GetAggregatedSenders

func (*SequencerSnapshot_InFlightAggregationWithId) GetAggregationId

func (x *SequencerSnapshot_InFlightAggregationWithId) GetAggregationId() []byte

func (*SequencerSnapshot_InFlightAggregationWithId) GetAggregationRule

func (*SequencerSnapshot_InFlightAggregationWithId) GetMaxSequencingTime

func (*SequencerSnapshot_InFlightAggregationWithId) ProtoMessage

func (*SequencerSnapshot_InFlightAggregationWithId) ProtoReflect

func (*SequencerSnapshot_InFlightAggregationWithId) Reset

func (*SequencerSnapshot_InFlightAggregationWithId) String

type SequencerSnapshot_MemberCounter

type SequencerSnapshot_MemberCounter struct {
	Member           string `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"`
	SequencerCounter int64  `protobuf:"varint,2,opt,name=sequencer_counter,json=sequencerCounter,proto3" json:"sequencer_counter,omitempty"`
	// contains filtered or unexported fields
}

func (*SequencerSnapshot_MemberCounter) Descriptor deprecated

func (*SequencerSnapshot_MemberCounter) Descriptor() ([]byte, []int)

Deprecated: Use SequencerSnapshot_MemberCounter.ProtoReflect.Descriptor instead.

func (*SequencerSnapshot_MemberCounter) GetMember

func (x *SequencerSnapshot_MemberCounter) GetMember() string

func (*SequencerSnapshot_MemberCounter) GetSequencerCounter

func (x *SequencerSnapshot_MemberCounter) GetSequencerCounter() int64

func (*SequencerSnapshot_MemberCounter) ProtoMessage

func (*SequencerSnapshot_MemberCounter) ProtoMessage()

func (*SequencerSnapshot_MemberCounter) ProtoReflect

func (*SequencerSnapshot_MemberCounter) Reset

func (*SequencerSnapshot_MemberCounter) String

type SequencerSnapshot_MemberTrafficSnapshot

type SequencerSnapshot_MemberTrafficSnapshot struct {
	Member                string                 `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"`
	ExtraTrafficRemainder uint64                 `` /* 127-byte string literal not displayed */
	ExtraTrafficConsumed  uint64                 `protobuf:"varint,3,opt,name=extra_traffic_consumed,json=extraTrafficConsumed,proto3" json:"extra_traffic_consumed,omitempty"`
	BaseTrafficRemainder  uint64                 `protobuf:"varint,4,opt,name=base_traffic_remainder,json=baseTrafficRemainder,proto3" json:"base_traffic_remainder,omitempty"`
	SequencingTimestamp   *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=sequencing_timestamp,json=sequencingTimestamp,proto3" json:"sequencing_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*SequencerSnapshot_MemberTrafficSnapshot) Descriptor deprecated

func (*SequencerSnapshot_MemberTrafficSnapshot) Descriptor() ([]byte, []int)

Deprecated: Use SequencerSnapshot_MemberTrafficSnapshot.ProtoReflect.Descriptor instead.

func (*SequencerSnapshot_MemberTrafficSnapshot) GetBaseTrafficRemainder

func (x *SequencerSnapshot_MemberTrafficSnapshot) GetBaseTrafficRemainder() uint64

func (*SequencerSnapshot_MemberTrafficSnapshot) GetExtraTrafficConsumed

func (x *SequencerSnapshot_MemberTrafficSnapshot) GetExtraTrafficConsumed() uint64

func (*SequencerSnapshot_MemberTrafficSnapshot) GetExtraTrafficRemainder

func (x *SequencerSnapshot_MemberTrafficSnapshot) GetExtraTrafficRemainder() uint64

func (*SequencerSnapshot_MemberTrafficSnapshot) GetMember

func (*SequencerSnapshot_MemberTrafficSnapshot) GetSequencingTimestamp

func (x *SequencerSnapshot_MemberTrafficSnapshot) GetSequencingTimestamp() *timestamppb.Timestamp

func (*SequencerSnapshot_MemberTrafficSnapshot) ProtoMessage

func (*SequencerSnapshot_MemberTrafficSnapshot) ProtoReflect

func (*SequencerSnapshot_MemberTrafficSnapshot) Reset

func (*SequencerSnapshot_MemberTrafficSnapshot) String

type SequencerSnapshot_SignaturesForEnvelope

type SequencerSnapshot_SignaturesForEnvelope struct {
	Signatures []*v02.Signature `protobuf:"bytes,3,rep,name=signatures,proto3" json:"signatures,omitempty"`
	// contains filtered or unexported fields
}

func (*SequencerSnapshot_SignaturesForEnvelope) Descriptor deprecated

func (*SequencerSnapshot_SignaturesForEnvelope) Descriptor() ([]byte, []int)

Deprecated: Use SequencerSnapshot_SignaturesForEnvelope.ProtoReflect.Descriptor instead.

func (*SequencerSnapshot_SignaturesForEnvelope) GetSignatures

func (*SequencerSnapshot_SignaturesForEnvelope) ProtoMessage

func (*SequencerSnapshot_SignaturesForEnvelope) ProtoReflect

func (*SequencerSnapshot_SignaturesForEnvelope) Reset

func (*SequencerSnapshot_SignaturesForEnvelope) String

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL