Documentation ¶
Index ¶
- Variables
- func RegisterKeyTransparencySequencerServer(s *grpc.Server, srv KeyTransparencySequencerServer)
- type ApplyRevisionRequest
- func (*ApplyRevisionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApplyRevisionRequest) GetDirectoryId() string
- func (x *ApplyRevisionRequest) GetRevision() int64
- func (*ApplyRevisionRequest) ProtoMessage()
- func (x *ApplyRevisionRequest) ProtoReflect() protoreflect.Message
- func (x *ApplyRevisionRequest) Reset()
- func (x *ApplyRevisionRequest) String() string
- type ApplyRevisionResponse
- func (*ApplyRevisionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ApplyRevisionResponse) GetDirectoryId() string
- func (x *ApplyRevisionResponse) GetMapLeaves() int64
- func (x *ApplyRevisionResponse) GetMutations() int64
- func (x *ApplyRevisionResponse) GetRevision() int64
- func (*ApplyRevisionResponse) ProtoMessage()
- func (x *ApplyRevisionResponse) ProtoReflect() protoreflect.Message
- func (x *ApplyRevisionResponse) Reset()
- func (x *ApplyRevisionResponse) String() string
- type ApplyRevisionsRequest
- func (*ApplyRevisionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApplyRevisionsRequest) GetDirectoryId() string
- func (*ApplyRevisionsRequest) ProtoMessage()
- func (x *ApplyRevisionsRequest) ProtoReflect() protoreflect.Message
- func (x *ApplyRevisionsRequest) Reset()
- func (x *ApplyRevisionsRequest) String() string
- type DefineRevisionsRequest
- func (*DefineRevisionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DefineRevisionsRequest) GetDirectoryId() string
- func (x *DefineRevisionsRequest) GetMaxBatch() int32
- func (x *DefineRevisionsRequest) GetMaxUnapplied() int32
- func (x *DefineRevisionsRequest) GetMinBatch() int32
- func (*DefineRevisionsRequest) ProtoMessage()
- func (x *DefineRevisionsRequest) ProtoReflect() protoreflect.Message
- func (x *DefineRevisionsRequest) Reset()
- func (x *DefineRevisionsRequest) String() string
- type DefineRevisionsResponse
- func (*DefineRevisionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DefineRevisionsResponse) GetHighestApplied() int64
- func (x *DefineRevisionsResponse) GetHighestDefined() int64
- func (*DefineRevisionsResponse) ProtoMessage()
- func (x *DefineRevisionsResponse) ProtoReflect() protoreflect.Message
- func (x *DefineRevisionsResponse) Reset()
- func (x *DefineRevisionsResponse) String() string
- type EstimateBacklogRequest
- func (*EstimateBacklogRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EstimateBacklogRequest) GetDirectoryId() string
- func (x *EstimateBacklogRequest) GetMaxUnappliedCount() int32
- func (*EstimateBacklogRequest) ProtoMessage()
- func (x *EstimateBacklogRequest) ProtoReflect() protoreflect.Message
- func (x *EstimateBacklogRequest) Reset()
- func (x *EstimateBacklogRequest) String() string
- type EstimateBacklogResponse
- func (*EstimateBacklogResponse) Descriptor() ([]byte, []int)deprecated
- func (x *EstimateBacklogResponse) GetDirectoryId() string
- func (x *EstimateBacklogResponse) GetUnappliedCount() int32
- func (*EstimateBacklogResponse) ProtoMessage()
- func (x *EstimateBacklogResponse) ProtoReflect() protoreflect.Message
- func (x *EstimateBacklogResponse) Reset()
- func (x *EstimateBacklogResponse) String() string
- type GetDefinedRevisionsRequest
- func (*GetDefinedRevisionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetDefinedRevisionsRequest) GetDirectoryId() string
- func (*GetDefinedRevisionsRequest) ProtoMessage()
- func (x *GetDefinedRevisionsRequest) ProtoReflect() protoreflect.Message
- func (x *GetDefinedRevisionsRequest) Reset()
- func (x *GetDefinedRevisionsRequest) String() string
- type GetDefinedRevisionsResponse
- func (*GetDefinedRevisionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetDefinedRevisionsResponse) GetHighestApplied() int64
- func (x *GetDefinedRevisionsResponse) GetHighestDefined() int64
- func (*GetDefinedRevisionsResponse) ProtoMessage()
- func (x *GetDefinedRevisionsResponse) ProtoReflect() protoreflect.Message
- func (x *GetDefinedRevisionsResponse) Reset()
- func (x *GetDefinedRevisionsResponse) String() string
- type KeyTransparencySequencerClient
- type KeyTransparencySequencerServer
- type MapMetadata
- type MapMetadata_SourceSlice
- func (*MapMetadata_SourceSlice) Descriptor() ([]byte, []int)deprecated
- func (x *MapMetadata_SourceSlice) GetHighestExclusive() int64
- func (x *MapMetadata_SourceSlice) GetLogId() int64
- func (x *MapMetadata_SourceSlice) GetLowestInclusive() int64
- func (*MapMetadata_SourceSlice) ProtoMessage()
- func (x *MapMetadata_SourceSlice) ProtoReflect() protoreflect.Message
- func (x *MapMetadata_SourceSlice) Reset()
- func (x *MapMetadata_SourceSlice) String() string
- type PublishRevisionsRequest
- func (*PublishRevisionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PublishRevisionsRequest) GetBlock() bool
- func (x *PublishRevisionsRequest) GetDirectoryId() string
- func (*PublishRevisionsRequest) ProtoMessage()
- func (x *PublishRevisionsRequest) ProtoReflect() protoreflect.Message
- func (x *PublishRevisionsRequest) Reset()
- func (x *PublishRevisionsRequest) String() string
- type PublishRevisionsResponse
- func (*PublishRevisionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PublishRevisionsResponse) GetRevisions() []int64
- func (*PublishRevisionsResponse) ProtoMessage()
- func (x *PublishRevisionsResponse) ProtoReflect() protoreflect.Message
- func (x *PublishRevisionsResponse) Reset()
- func (x *PublishRevisionsResponse) String() string
- type UnimplementedKeyTransparencySequencerServer
- func (*UnimplementedKeyTransparencySequencerServer) ApplyRevision(context.Context, *ApplyRevisionRequest) (*ApplyRevisionResponse, error)
- func (*UnimplementedKeyTransparencySequencerServer) ApplyRevisions(context.Context, *ApplyRevisionsRequest) (*empty.Empty, error)
- func (*UnimplementedKeyTransparencySequencerServer) DefineRevisions(context.Context, *DefineRevisionsRequest) (*DefineRevisionsResponse, error)
- func (*UnimplementedKeyTransparencySequencerServer) EstimateBacklog(context.Context, *EstimateBacklogRequest) (*EstimateBacklogResponse, error)
- func (*UnimplementedKeyTransparencySequencerServer) GetDefinedRevisions(context.Context, *GetDefinedRevisionsRequest) (*GetDefinedRevisionsResponse, error)
- func (*UnimplementedKeyTransparencySequencerServer) PublishRevisions(context.Context, *PublishRevisionsRequest) (*PublishRevisionsResponse, error)
Constants ¶
This section is empty.
Variables ¶
var File_sequencer_api_proto protoreflect.FileDescriptor
Functions ¶
func RegisterKeyTransparencySequencerServer ¶
func RegisterKeyTransparencySequencerServer(s *grpc.Server, srv KeyTransparencySequencerServer)
Types ¶
type ApplyRevisionRequest ¶
type ApplyRevisionRequest struct { // directory_id is the directory to apply the mutations to. DirectoryId string `protobuf:"bytes,1,opt,name=directory_id,json=directoryId,proto3" json:"directory_id,omitempty"` // revision is the expected revision of the new revision. Revision int64 `protobuf:"varint,2,opt,name=revision,proto3" json:"revision,omitempty"` // contains filtered or unexported fields }
ApplyRevisionRequest contains information needed to create a new revision.
func (*ApplyRevisionRequest) Descriptor
deprecated
func (*ApplyRevisionRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApplyRevisionRequest.ProtoReflect.Descriptor instead.
func (*ApplyRevisionRequest) GetDirectoryId ¶
func (x *ApplyRevisionRequest) GetDirectoryId() string
func (*ApplyRevisionRequest) GetRevision ¶
func (x *ApplyRevisionRequest) GetRevision() int64
func (*ApplyRevisionRequest) ProtoMessage ¶
func (*ApplyRevisionRequest) ProtoMessage()
func (*ApplyRevisionRequest) ProtoReflect ¶ added in v0.3.0
func (x *ApplyRevisionRequest) ProtoReflect() protoreflect.Message
func (*ApplyRevisionRequest) Reset ¶
func (x *ApplyRevisionRequest) Reset()
func (*ApplyRevisionRequest) String ¶
func (x *ApplyRevisionRequest) String() string
type ApplyRevisionResponse ¶
type ApplyRevisionResponse struct { DirectoryId string `protobuf:"bytes,1,opt,name=directory_id,json=directoryId,proto3" json:"directory_id,omitempty"` // The revision this is for. Revision int64 `protobuf:"varint,2,opt,name=revision,proto3" json:"revision,omitempty"` // mutations processed. Mutations int64 `protobuf:"varint,3,opt,name=mutations,proto3" json:"mutations,omitempty"` // map_leaves written. MapLeaves int64 `protobuf:"varint,4,opt,name=map_leaves,json=mapLeaves,proto3" json:"map_leaves,omitempty"` // contains filtered or unexported fields }
ApplyRevisionResponse contains stats about the created revision.
func (*ApplyRevisionResponse) Descriptor
deprecated
func (*ApplyRevisionResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApplyRevisionResponse.ProtoReflect.Descriptor instead.
func (*ApplyRevisionResponse) GetDirectoryId ¶
func (x *ApplyRevisionResponse) GetDirectoryId() string
func (*ApplyRevisionResponse) GetMapLeaves ¶
func (x *ApplyRevisionResponse) GetMapLeaves() int64
func (*ApplyRevisionResponse) GetMutations ¶
func (x *ApplyRevisionResponse) GetMutations() int64
func (*ApplyRevisionResponse) GetRevision ¶
func (x *ApplyRevisionResponse) GetRevision() int64
func (*ApplyRevisionResponse) ProtoMessage ¶
func (*ApplyRevisionResponse) ProtoMessage()
func (*ApplyRevisionResponse) ProtoReflect ¶ added in v0.3.0
func (x *ApplyRevisionResponse) ProtoReflect() protoreflect.Message
func (*ApplyRevisionResponse) Reset ¶
func (x *ApplyRevisionResponse) Reset()
func (*ApplyRevisionResponse) String ¶
func (x *ApplyRevisionResponse) String() string
type ApplyRevisionsRequest ¶
type ApplyRevisionsRequest struct { // directory_id is the directory to apply revisions for. DirectoryId string `protobuf:"bytes,1,opt,name=directory_id,json=directoryId,proto3" json:"directory_id,omitempty"` // contains filtered or unexported fields }
ApplyRevisionsRequest triggers applying revisions to the directory's map.
func (*ApplyRevisionsRequest) Descriptor
deprecated
func (*ApplyRevisionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApplyRevisionsRequest.ProtoReflect.Descriptor instead.
func (*ApplyRevisionsRequest) GetDirectoryId ¶
func (x *ApplyRevisionsRequest) GetDirectoryId() string
func (*ApplyRevisionsRequest) ProtoMessage ¶
func (*ApplyRevisionsRequest) ProtoMessage()
func (*ApplyRevisionsRequest) ProtoReflect ¶ added in v0.3.0
func (x *ApplyRevisionsRequest) ProtoReflect() protoreflect.Message
func (*ApplyRevisionsRequest) Reset ¶
func (x *ApplyRevisionsRequest) Reset()
func (*ApplyRevisionsRequest) String ¶
func (x *ApplyRevisionsRequest) String() string
type DefineRevisionsRequest ¶
type DefineRevisionsRequest struct { // directory_id is the directory to examine the outstanding mutations for. DirectoryId string `protobuf:"bytes,1,opt,name=directory_id,json=directoryId,proto3" json:"directory_id,omitempty"` // min_batch is the minimum number of items in a batch. // If less than min_batch items are available, nothing happens. // TODO(#1047): Replace with timeout so items in the log get processed // eventually. MinBatch int32 `protobuf:"varint,2,opt,name=min_batch,json=minBatch,proto3" json:"min_batch,omitempty"` // max_batch is the maximum number of items in a batch. MaxBatch int32 `protobuf:"varint,3,opt,name=max_batch,json=maxBatch,proto3" json:"max_batch,omitempty"` // max_unapplied is the maximum number of revisions that can be defined ahead // of applied revisions. MaxUnapplied int32 `protobuf:"varint,4,opt,name=max_unapplied,json=maxUnapplied,proto3" json:"max_unapplied,omitempty"` // contains filtered or unexported fields }
DefineRevisionsRequest contains information needed to define new revisions.
func (*DefineRevisionsRequest) Descriptor
deprecated
func (*DefineRevisionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use DefineRevisionsRequest.ProtoReflect.Descriptor instead.
func (*DefineRevisionsRequest) GetDirectoryId ¶
func (x *DefineRevisionsRequest) GetDirectoryId() string
func (*DefineRevisionsRequest) GetMaxBatch ¶
func (x *DefineRevisionsRequest) GetMaxBatch() int32
func (*DefineRevisionsRequest) GetMaxUnapplied ¶
func (x *DefineRevisionsRequest) GetMaxUnapplied() int32
func (*DefineRevisionsRequest) GetMinBatch ¶
func (x *DefineRevisionsRequest) GetMinBatch() int32
func (*DefineRevisionsRequest) ProtoMessage ¶
func (*DefineRevisionsRequest) ProtoMessage()
func (*DefineRevisionsRequest) ProtoReflect ¶ added in v0.3.0
func (x *DefineRevisionsRequest) ProtoReflect() protoreflect.Message
func (*DefineRevisionsRequest) Reset ¶
func (x *DefineRevisionsRequest) Reset()
func (*DefineRevisionsRequest) String ¶
func (x *DefineRevisionsRequest) String() string
type DefineRevisionsResponse ¶
type DefineRevisionsResponse struct { // highest_applied is the current map revision, which is also the highest map // revision that has been applied. HighestApplied int64 `protobuf:"varint,2,opt,name=highest_applied,json=highestApplied,proto3" json:"highest_applied,omitempty"` // highest_defined is the highest defined revision after this call. HighestDefined int64 `protobuf:"varint,3,opt,name=highest_defined,json=highestDefined,proto3" json:"highest_defined,omitempty"` // contains filtered or unexported fields }
DefineRevisionsResponse contains information about defined/applied revisions.
func (*DefineRevisionsResponse) Descriptor
deprecated
func (*DefineRevisionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use DefineRevisionsResponse.ProtoReflect.Descriptor instead.
func (*DefineRevisionsResponse) GetHighestApplied ¶
func (x *DefineRevisionsResponse) GetHighestApplied() int64
func (*DefineRevisionsResponse) GetHighestDefined ¶
func (x *DefineRevisionsResponse) GetHighestDefined() int64
func (*DefineRevisionsResponse) ProtoMessage ¶
func (*DefineRevisionsResponse) ProtoMessage()
func (*DefineRevisionsResponse) ProtoReflect ¶ added in v0.3.0
func (x *DefineRevisionsResponse) ProtoReflect() protoreflect.Message
func (*DefineRevisionsResponse) Reset ¶
func (x *DefineRevisionsResponse) Reset()
func (*DefineRevisionsResponse) String ¶
func (x *DefineRevisionsResponse) String() string
type EstimateBacklogRequest ¶
type EstimateBacklogRequest struct { DirectoryId string `protobuf:"bytes,1,opt,name=directory_id,json=directoryId,proto3" json:"directory_id,omitempty"` MaxUnappliedCount int32 `protobuf:"varint,2,opt,name=max_unapplied_count,json=maxUnappliedCount,proto3" json:"max_unapplied_count,omitempty"` // contains filtered or unexported fields }
func (*EstimateBacklogRequest) Descriptor
deprecated
func (*EstimateBacklogRequest) Descriptor() ([]byte, []int)
Deprecated: Use EstimateBacklogRequest.ProtoReflect.Descriptor instead.
func (*EstimateBacklogRequest) GetDirectoryId ¶
func (x *EstimateBacklogRequest) GetDirectoryId() string
func (*EstimateBacklogRequest) GetMaxUnappliedCount ¶
func (x *EstimateBacklogRequest) GetMaxUnappliedCount() int32
func (*EstimateBacklogRequest) ProtoMessage ¶
func (*EstimateBacklogRequest) ProtoMessage()
func (*EstimateBacklogRequest) ProtoReflect ¶ added in v0.3.0
func (x *EstimateBacklogRequest) ProtoReflect() protoreflect.Message
func (*EstimateBacklogRequest) Reset ¶
func (x *EstimateBacklogRequest) Reset()
func (*EstimateBacklogRequest) String ¶
func (x *EstimateBacklogRequest) String() string
type EstimateBacklogResponse ¶
type EstimateBacklogResponse struct { DirectoryId string `protobuf:"bytes,1,opt,name=directory_id,json=directoryId,proto3" json:"directory_id,omitempty"` UnappliedCount int32 `protobuf:"varint,2,opt,name=unapplied_count,json=unappliedCount,proto3" json:"unapplied_count,omitempty"` // contains filtered or unexported fields }
func (*EstimateBacklogResponse) Descriptor
deprecated
func (*EstimateBacklogResponse) Descriptor() ([]byte, []int)
Deprecated: Use EstimateBacklogResponse.ProtoReflect.Descriptor instead.
func (*EstimateBacklogResponse) GetDirectoryId ¶
func (x *EstimateBacklogResponse) GetDirectoryId() string
func (*EstimateBacklogResponse) GetUnappliedCount ¶
func (x *EstimateBacklogResponse) GetUnappliedCount() int32
func (*EstimateBacklogResponse) ProtoMessage ¶
func (*EstimateBacklogResponse) ProtoMessage()
func (*EstimateBacklogResponse) ProtoReflect ¶ added in v0.3.0
func (x *EstimateBacklogResponse) ProtoReflect() protoreflect.Message
func (*EstimateBacklogResponse) Reset ¶
func (x *EstimateBacklogResponse) Reset()
func (*EstimateBacklogResponse) String ¶
func (x *EstimateBacklogResponse) String() string
type GetDefinedRevisionsRequest ¶
type GetDefinedRevisionsRequest struct { // directory_id is the directory to examine the revisions for. DirectoryId string `protobuf:"bytes,1,opt,name=directory_id,json=directoryId,proto3" json:"directory_id,omitempty"` // contains filtered or unexported fields }
GetDefinedRevisionsRequest contains information needed to request the set of defined/applied revisions.
func (*GetDefinedRevisionsRequest) Descriptor
deprecated
func (*GetDefinedRevisionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDefinedRevisionsRequest.ProtoReflect.Descriptor instead.
func (*GetDefinedRevisionsRequest) GetDirectoryId ¶
func (x *GetDefinedRevisionsRequest) GetDirectoryId() string
func (*GetDefinedRevisionsRequest) ProtoMessage ¶
func (*GetDefinedRevisionsRequest) ProtoMessage()
func (*GetDefinedRevisionsRequest) ProtoReflect ¶ added in v0.3.0
func (x *GetDefinedRevisionsRequest) ProtoReflect() protoreflect.Message
func (*GetDefinedRevisionsRequest) Reset ¶
func (x *GetDefinedRevisionsRequest) Reset()
func (*GetDefinedRevisionsRequest) String ¶
func (x *GetDefinedRevisionsRequest) String() string
type GetDefinedRevisionsResponse ¶
type GetDefinedRevisionsResponse struct { // highest_applied is the current map revision, which is also the highest map // revision that has been applied. HighestApplied int64 `protobuf:"varint,1,opt,name=highest_applied,json=highestApplied,proto3" json:"highest_applied,omitempty"` // highest_defined is the highest defined revision after this call. HighestDefined int64 `protobuf:"varint,2,opt,name=highest_defined,json=highestDefined,proto3" json:"highest_defined,omitempty"` // contains filtered or unexported fields }
GetDefinedRevisionResponse contains info about defined/applied revisions.
func (*GetDefinedRevisionsResponse) Descriptor
deprecated
func (*GetDefinedRevisionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetDefinedRevisionsResponse.ProtoReflect.Descriptor instead.
func (*GetDefinedRevisionsResponse) GetHighestApplied ¶
func (x *GetDefinedRevisionsResponse) GetHighestApplied() int64
func (*GetDefinedRevisionsResponse) GetHighestDefined ¶
func (x *GetDefinedRevisionsResponse) GetHighestDefined() int64
func (*GetDefinedRevisionsResponse) ProtoMessage ¶
func (*GetDefinedRevisionsResponse) ProtoMessage()
func (*GetDefinedRevisionsResponse) ProtoReflect ¶ added in v0.3.0
func (x *GetDefinedRevisionsResponse) ProtoReflect() protoreflect.Message
func (*GetDefinedRevisionsResponse) Reset ¶
func (x *GetDefinedRevisionsResponse) Reset()
func (*GetDefinedRevisionsResponse) String ¶
func (x *GetDefinedRevisionsResponse) String() string
type KeyTransparencySequencerClient ¶
type KeyTransparencySequencerClient interface { // DefineRevisions returns the info on defined/applied revisions, after // optionally defining a new revision of outstanding mutations. DefineRevisions(ctx context.Context, in *DefineRevisionsRequest, opts ...grpc.CallOption) (*DefineRevisionsResponse, error) // GetDefinedRevisions returns the range of defined and unapplied revisions. GetDefinedRevisions(ctx context.Context, in *GetDefinedRevisionsRequest, opts ...grpc.CallOption) (*GetDefinedRevisionsResponse, error) // ApplyRevisions figures out the outstanding revisions, and applies the // corresponding mutations the to the map. ApplyRevisions(ctx context.Context, in *ApplyRevisionsRequest, opts ...grpc.CallOption) (*empty.Empty, error) // ApplyRevision applies the mutations for the supplied revision. // If the revision does not exist, this must return `NotFound`. ApplyRevision(ctx context.Context, in *ApplyRevisionRequest, opts ...grpc.CallOption) (*ApplyRevisionResponse, error) // PublishRevisions copies the MapRoots of all known map revisions into the Log // of MapRoots. PublishRevisions(ctx context.Context, in *PublishRevisionsRequest, opts ...grpc.CallOption) (*PublishRevisionsResponse, error) // EstimateBacklog will update various counters on the server. Call periodically. EstimateBacklog(ctx context.Context, in *EstimateBacklogRequest, opts ...grpc.CallOption) (*EstimateBacklogResponse, error) }
KeyTransparencySequencerClient is the client API for KeyTransparencySequencer service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewKeyTransparencySequencerClient ¶
func NewKeyTransparencySequencerClient(cc grpc.ClientConnInterface) KeyTransparencySequencerClient
type KeyTransparencySequencerServer ¶
type KeyTransparencySequencerServer interface { // DefineRevisions returns the info on defined/applied revisions, after // optionally defining a new revision of outstanding mutations. DefineRevisions(context.Context, *DefineRevisionsRequest) (*DefineRevisionsResponse, error) // GetDefinedRevisions returns the range of defined and unapplied revisions. GetDefinedRevisions(context.Context, *GetDefinedRevisionsRequest) (*GetDefinedRevisionsResponse, error) // ApplyRevisions figures out the outstanding revisions, and applies the // corresponding mutations the to the map. ApplyRevisions(context.Context, *ApplyRevisionsRequest) (*empty.Empty, error) // ApplyRevision applies the mutations for the supplied revision. // If the revision does not exist, this must return `NotFound`. ApplyRevision(context.Context, *ApplyRevisionRequest) (*ApplyRevisionResponse, error) // PublishRevisions copies the MapRoots of all known map revisions into the Log // of MapRoots. PublishRevisions(context.Context, *PublishRevisionsRequest) (*PublishRevisionsResponse, error) // EstimateBacklog will update various counters on the server. Call periodically. EstimateBacklog(context.Context, *EstimateBacklogRequest) (*EstimateBacklogResponse, error) }
KeyTransparencySequencerServer is the server API for KeyTransparencySequencer service.
type MapMetadata ¶
type MapMetadata struct { // sources is a list of log sources that were used to construct this map revision. Sources []*MapMetadata_SourceSlice `protobuf:"bytes,2,rep,name=sources,proto3" json:"sources,omitempty"` // contains filtered or unexported fields }
func (*MapMetadata) Descriptor
deprecated
func (*MapMetadata) Descriptor() ([]byte, []int)
Deprecated: Use MapMetadata.ProtoReflect.Descriptor instead.
func (*MapMetadata) GetSources ¶
func (x *MapMetadata) GetSources() []*MapMetadata_SourceSlice
func (*MapMetadata) ProtoMessage ¶
func (*MapMetadata) ProtoMessage()
func (*MapMetadata) ProtoReflect ¶ added in v0.3.0
func (x *MapMetadata) ProtoReflect() protoreflect.Message
func (*MapMetadata) Reset ¶
func (x *MapMetadata) Reset()
func (*MapMetadata) String ¶
func (x *MapMetadata) String() string
type MapMetadata_SourceSlice ¶
type MapMetadata_SourceSlice struct { // lowest_inclusive is the lowest primary key (inclusive) of the source // log that has been incorporated into this map revision. The primary // keys of logged items MUST be monotonically increasing. // Defined in terms of microseconds from the Unix epoch. LowestInclusive int64 `protobuf:"varint,1,opt,name=lowest_inclusive,json=lowestInclusive,proto3" json:"lowest_inclusive,omitempty"` // highest_exclusive is the highest primary key (exclusive) of the source // log that has been incorporated into this map revision. The primary keys // of logged items MUST be monotonically increasing. // Defined in terms of microseconds from the Unix epoch. HighestExclusive int64 `protobuf:"varint,2,opt,name=highest_exclusive,json=highestExclusive,proto3" json:"highest_exclusive,omitempty"` // log_id is the ID of the source log. LogId int64 `protobuf:"varint,3,opt,name=log_id,json=logId,proto3" json:"log_id,omitempty"` // contains filtered or unexported fields }
SourceSlice is the range of inputs that have been included in a map revision.
func (*MapMetadata_SourceSlice) Descriptor
deprecated
func (*MapMetadata_SourceSlice) Descriptor() ([]byte, []int)
Deprecated: Use MapMetadata_SourceSlice.ProtoReflect.Descriptor instead.
func (*MapMetadata_SourceSlice) GetHighestExclusive ¶
func (x *MapMetadata_SourceSlice) GetHighestExclusive() int64
func (*MapMetadata_SourceSlice) GetLogId ¶
func (x *MapMetadata_SourceSlice) GetLogId() int64
func (*MapMetadata_SourceSlice) GetLowestInclusive ¶
func (x *MapMetadata_SourceSlice) GetLowestInclusive() int64
func (*MapMetadata_SourceSlice) ProtoMessage ¶
func (*MapMetadata_SourceSlice) ProtoMessage()
func (*MapMetadata_SourceSlice) ProtoReflect ¶ added in v0.3.0
func (x *MapMetadata_SourceSlice) ProtoReflect() protoreflect.Message
func (*MapMetadata_SourceSlice) Reset ¶
func (x *MapMetadata_SourceSlice) Reset()
func (*MapMetadata_SourceSlice) String ¶
func (x *MapMetadata_SourceSlice) String() string
type PublishRevisionsRequest ¶
type PublishRevisionsRequest struct { DirectoryId string `protobuf:"bytes,1,opt,name=directory_id,json=directoryId,proto3" json:"directory_id,omitempty"` // block until a Signed Log Root has been published which encompases all map roots. Block bool `protobuf:"varint,2,opt,name=block,proto3" json:"block,omitempty"` // contains filtered or unexported fields }
PublishRevisionsRequest copies all available SignedMapRoots into the Log of SignedMapRoots.
func (*PublishRevisionsRequest) Descriptor
deprecated
func (*PublishRevisionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use PublishRevisionsRequest.ProtoReflect.Descriptor instead.
func (*PublishRevisionsRequest) GetBlock ¶
func (x *PublishRevisionsRequest) GetBlock() bool
func (*PublishRevisionsRequest) GetDirectoryId ¶
func (x *PublishRevisionsRequest) GetDirectoryId() string
func (*PublishRevisionsRequest) ProtoMessage ¶
func (*PublishRevisionsRequest) ProtoMessage()
func (*PublishRevisionsRequest) ProtoReflect ¶ added in v0.3.0
func (x *PublishRevisionsRequest) ProtoReflect() protoreflect.Message
func (*PublishRevisionsRequest) Reset ¶
func (x *PublishRevisionsRequest) Reset()
func (*PublishRevisionsRequest) String ¶
func (x *PublishRevisionsRequest) String() string
type PublishRevisionsResponse ¶
type PublishRevisionsResponse struct { // revisions published to the log of signed map roots. Revisions []int64 `protobuf:"varint,1,rep,packed,name=revisions,proto3" json:"revisions,omitempty"` // contains filtered or unexported fields }
PublishRevisionsResponse contains metrics about the publishing operation.
func (*PublishRevisionsResponse) Descriptor
deprecated
func (*PublishRevisionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use PublishRevisionsResponse.ProtoReflect.Descriptor instead.
func (*PublishRevisionsResponse) GetRevisions ¶
func (x *PublishRevisionsResponse) GetRevisions() []int64
func (*PublishRevisionsResponse) ProtoMessage ¶
func (*PublishRevisionsResponse) ProtoMessage()
func (*PublishRevisionsResponse) ProtoReflect ¶ added in v0.3.0
func (x *PublishRevisionsResponse) ProtoReflect() protoreflect.Message
func (*PublishRevisionsResponse) Reset ¶
func (x *PublishRevisionsResponse) Reset()
func (*PublishRevisionsResponse) String ¶
func (x *PublishRevisionsResponse) String() string
type UnimplementedKeyTransparencySequencerServer ¶
type UnimplementedKeyTransparencySequencerServer struct { }
UnimplementedKeyTransparencySequencerServer can be embedded to have forward compatible implementations.
func (*UnimplementedKeyTransparencySequencerServer) ApplyRevision ¶
func (*UnimplementedKeyTransparencySequencerServer) ApplyRevision(context.Context, *ApplyRevisionRequest) (*ApplyRevisionResponse, error)
func (*UnimplementedKeyTransparencySequencerServer) ApplyRevisions ¶
func (*UnimplementedKeyTransparencySequencerServer) ApplyRevisions(context.Context, *ApplyRevisionsRequest) (*empty.Empty, error)
func (*UnimplementedKeyTransparencySequencerServer) DefineRevisions ¶
func (*UnimplementedKeyTransparencySequencerServer) DefineRevisions(context.Context, *DefineRevisionsRequest) (*DefineRevisionsResponse, error)
func (*UnimplementedKeyTransparencySequencerServer) EstimateBacklog ¶
func (*UnimplementedKeyTransparencySequencerServer) EstimateBacklog(context.Context, *EstimateBacklogRequest) (*EstimateBacklogResponse, error)
func (*UnimplementedKeyTransparencySequencerServer) GetDefinedRevisions ¶
func (*UnimplementedKeyTransparencySequencerServer) GetDefinedRevisions(context.Context, *GetDefinedRevisionsRequest) (*GetDefinedRevisionsResponse, error)
func (*UnimplementedKeyTransparencySequencerServer) PublishRevisions ¶
func (*UnimplementedKeyTransparencySequencerServer) PublishRevisions(context.Context, *PublishRevisionsRequest) (*PublishRevisionsResponse, error)