sequencer_go_proto

package
v0.3.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source
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 (*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 (*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.

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) ApplyRevisions

func (*UnimplementedKeyTransparencySequencerServer) DefineRevisions

func (*UnimplementedKeyTransparencySequencerServer) EstimateBacklog

func (*UnimplementedKeyTransparencySequencerServer) GetDefinedRevisions

func (*UnimplementedKeyTransparencySequencerServer) PublishRevisions

Jump to

Keyboard shortcuts

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