sequencer_go_proto

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

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

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"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type UnimplementedKeyTransparencySequencerServer struct {
}