sequencer_go_proto

package
v0.1.3 Latest Latest
Warning

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

 Go to latest Published: Jan 2, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

ApplyRevisionRequest contains information needed to create a new revision.

func (*ApplyRevisionRequest) Descriptor 

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

func (*ApplyRevisionRequest) GetDirectoryId 

func (m *ApplyRevisionRequest) GetDirectoryId() string

func (*ApplyRevisionRequest) GetRevision 

func (m *ApplyRevisionRequest) GetRevision() int64

func (*ApplyRevisionRequest) ProtoMessage 

func (*ApplyRevisionRequest) ProtoMessage()

func (*ApplyRevisionRequest) Reset 

func (m *ApplyRevisionRequest) Reset()

func (*ApplyRevisionRequest) String 

func (m *ApplyRevisionRequest) String() string

func (*ApplyRevisionRequest) XXX_DiscardUnknown 

func (m *ApplyRevisionRequest) XXX_DiscardUnknown()

func (*ApplyRevisionRequest) XXX_Marshal 

func (m *ApplyRevisionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplyRevisionRequest) XXX_Merge 

func (m *ApplyRevisionRequest) XXX_Merge(src proto.Message)

func (*ApplyRevisionRequest) XXX_Size 

func (m *ApplyRevisionRequest) XXX_Size() int

func (*ApplyRevisionRequest) XXX_Unmarshal 

func (m *ApplyRevisionRequest) XXX_Unmarshal(b []byte) error

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

ApplyRevisionResponse contains stats about the created revision.

func (*ApplyRevisionResponse) Descriptor 

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

func (*ApplyRevisionResponse) GetDirectoryId 

func (m *ApplyRevisionResponse) GetDirectoryId() string

func (*ApplyRevisionResponse) GetMapLeaves 

func (m *ApplyRevisionResponse) GetMapLeaves() int64

func (*ApplyRevisionResponse) GetMutations 

func (m *ApplyRevisionResponse) GetMutations() int64

func (*ApplyRevisionResponse) GetRevision 

func (m *ApplyRevisionResponse) GetRevision() int64

func (*ApplyRevisionResponse) ProtoMessage 

func (*ApplyRevisionResponse) ProtoMessage()

func (*ApplyRevisionResponse) Reset 

func (m *ApplyRevisionResponse) Reset()

func (*ApplyRevisionResponse) String 

func (m *ApplyRevisionResponse) String() string

func (*ApplyRevisionResponse) XXX_DiscardUnknown 

func (m *ApplyRevisionResponse) XXX_DiscardUnknown()

func (*ApplyRevisionResponse) XXX_Marshal 

func (m *ApplyRevisionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplyRevisionResponse) XXX_Merge 

func (m *ApplyRevisionResponse) XXX_Merge(src proto.Message)

func (*ApplyRevisionResponse) XXX_Size 

func (m *ApplyRevisionResponse) XXX_Size() int

func (*ApplyRevisionResponse) XXX_Unmarshal 

func (m *ApplyRevisionResponse) XXX_Unmarshal(b []byte) error

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

ApplyRevisionsRequest triggers applying revisions to the directory's map.

func (*ApplyRevisionsRequest) Descriptor 

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

func (*ApplyRevisionsRequest) GetDirectoryId 

func (m *ApplyRevisionsRequest) GetDirectoryId() string

func (*ApplyRevisionsRequest) ProtoMessage 

func (*ApplyRevisionsRequest) ProtoMessage()

func (*ApplyRevisionsRequest) Reset 

func (m *ApplyRevisionsRequest) Reset()

func (*ApplyRevisionsRequest) String 

func (m *ApplyRevisionsRequest) String() string

func (*ApplyRevisionsRequest) XXX_DiscardUnknown 

func (m *ApplyRevisionsRequest) XXX_DiscardUnknown()

func (*ApplyRevisionsRequest) XXX_Marshal 

func (m *ApplyRevisionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplyRevisionsRequest) XXX_Merge 

func (m *ApplyRevisionsRequest) XXX_Merge(src proto.Message)

func (*ApplyRevisionsRequest) XXX_Size 

func (m *ApplyRevisionsRequest) XXX_Size() int

func (*ApplyRevisionsRequest) XXX_Unmarshal 

func (m *ApplyRevisionsRequest) XXX_Unmarshal(b []byte) error

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

DefineRevisionsRequest contains information needed to define new revisions.

func (*DefineRevisionsRequest) Descriptor 

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

func (*DefineRevisionsRequest) GetDirectoryId 

func (m *DefineRevisionsRequest) GetDirectoryId() string

func (*DefineRevisionsRequest) GetMaxBatch 

func (m *DefineRevisionsRequest) GetMaxBatch() int32

func (*DefineRevisionsRequest) GetMaxUnapplied 

func (m *DefineRevisionsRequest) GetMaxUnapplied() int32

func (*DefineRevisionsRequest) GetMinBatch 

func (m *DefineRevisionsRequest) GetMinBatch() int32

func (*DefineRevisionsRequest) ProtoMessage 

func (*DefineRevisionsRequest) ProtoMessage()

func (*DefineRevisionsRequest) Reset 

func (m *DefineRevisionsRequest) Reset()

func (*DefineRevisionsRequest) String 

func (m *DefineRevisionsRequest) String() string

func (*DefineRevisionsRequest) XXX_DiscardUnknown 

func (m *DefineRevisionsRequest) XXX_DiscardUnknown()

func (*DefineRevisionsRequest) XXX_Marshal 

func (m *DefineRevisionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DefineRevisionsRequest) XXX_Merge 

func (m *DefineRevisionsRequest) XXX_Merge(src proto.Message)

func (*DefineRevisionsRequest) XXX_Size 

func (m *DefineRevisionsRequest) XXX_Size() int

func (*DefineRevisionsRequest) XXX_Unmarshal 

func (m *DefineRevisionsRequest) XXX_Unmarshal(b []byte) error

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

DefineRevisionsResponse contains information about defined/applied revisions.

func (*DefineRevisionsResponse) Descriptor 

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

func (*DefineRevisionsResponse) GetHighestApplied 

func (m *DefineRevisionsResponse) GetHighestApplied() int64

func (*DefineRevisionsResponse) GetHighestDefined 

func (m *DefineRevisionsResponse) GetHighestDefined() int64

func (*DefineRevisionsResponse) ProtoMessage 

func (*DefineRevisionsResponse) ProtoMessage()

func (*DefineRevisionsResponse) Reset 

func (m *DefineRevisionsResponse) Reset()

func (*DefineRevisionsResponse) String 

func (m *DefineRevisionsResponse) String() string

func (*DefineRevisionsResponse) XXX_DiscardUnknown 

func (m *DefineRevisionsResponse) XXX_DiscardUnknown()

func (*DefineRevisionsResponse) XXX_Marshal 

func (m *DefineRevisionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DefineRevisionsResponse) XXX_Merge 

func (m *DefineRevisionsResponse) XXX_Merge(src proto.Message)

func (*DefineRevisionsResponse) XXX_Size 

func (m *DefineRevisionsResponse) XXX_Size() int

func (*DefineRevisionsResponse) XXX_Unmarshal 

func (m *DefineRevisionsResponse) XXX_Unmarshal(b []byte) error

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

func (*EstimateBacklogRequest) Descriptor 

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

func (*EstimateBacklogRequest) GetDirectoryId 

func (m *EstimateBacklogRequest) GetDirectoryId() string

func (*EstimateBacklogRequest) GetMaxUnappliedCount 

func (m *EstimateBacklogRequest) GetMaxUnappliedCount() int32

func (*EstimateBacklogRequest) ProtoMessage 

func (*EstimateBacklogRequest) ProtoMessage()

func (*EstimateBacklogRequest) Reset 

func (m *EstimateBacklogRequest) Reset()

func (*EstimateBacklogRequest) String 

func (m *EstimateBacklogRequest) String() string

func (*EstimateBacklogRequest) XXX_DiscardUnknown 

func (m *EstimateBacklogRequest) XXX_DiscardUnknown()

func (*EstimateBacklogRequest) XXX_Marshal 

func (m *EstimateBacklogRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EstimateBacklogRequest) XXX_Merge 

func (m *EstimateBacklogRequest) XXX_Merge(src proto.Message)

func (*EstimateBacklogRequest) XXX_Size 

func (m *EstimateBacklogRequest) XXX_Size() int

func (*EstimateBacklogRequest) XXX_Unmarshal 

func (m *EstimateBacklogRequest) XXX_Unmarshal(b []byte) error

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

func (*EstimateBacklogResponse) Descriptor 

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

func (*EstimateBacklogResponse) GetDirectoryId 

func (m *EstimateBacklogResponse) GetDirectoryId() string

func (*EstimateBacklogResponse) GetUnappliedCount 

func (m *EstimateBacklogResponse) GetUnappliedCount() int32

func (*EstimateBacklogResponse) ProtoMessage 

func (*EstimateBacklogResponse) ProtoMessage()

func (*EstimateBacklogResponse) Reset 

func (m *EstimateBacklogResponse) Reset()

func (*EstimateBacklogResponse) String 

func (m *EstimateBacklogResponse) String() string

func (*EstimateBacklogResponse) XXX_DiscardUnknown 

func (m *EstimateBacklogResponse) XXX_DiscardUnknown()

func (*EstimateBacklogResponse) XXX_Marshal 

func (m *EstimateBacklogResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EstimateBacklogResponse) XXX_Merge 

func (m *EstimateBacklogResponse) XXX_Merge(src proto.Message)

func (*EstimateBacklogResponse) XXX_Size 

func (m *EstimateBacklogResponse) XXX_Size() int

func (*EstimateBacklogResponse) XXX_Unmarshal 

func (m *EstimateBacklogResponse) XXX_Unmarshal(b []byte) error

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

GetDefinedRevisionsRequest contains information needed to request the set of defined/applied revisions.

func (*GetDefinedRevisionsRequest) Descriptor 

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

func (*GetDefinedRevisionsRequest) GetDirectoryId 

func (m *GetDefinedRevisionsRequest) GetDirectoryId() string

func (*GetDefinedRevisionsRequest) ProtoMessage 

func (*GetDefinedRevisionsRequest) ProtoMessage()

func (*GetDefinedRevisionsRequest) Reset 

func (m *GetDefinedRevisionsRequest) Reset()

func (*GetDefinedRevisionsRequest) String 

func (m *GetDefinedRevisionsRequest) String() string

func (*GetDefinedRevisionsRequest) XXX_DiscardUnknown 

func (m *GetDefinedRevisionsRequest) XXX_DiscardUnknown()

func (*GetDefinedRevisionsRequest) XXX_Marshal 

func (m *GetDefinedRevisionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDefinedRevisionsRequest) XXX_Merge 

func (m *GetDefinedRevisionsRequest) XXX_Merge(src proto.Message)

func (*GetDefinedRevisionsRequest) XXX_Size 

func (m *GetDefinedRevisionsRequest) XXX_Size() int

func (*GetDefinedRevisionsRequest) XXX_Unmarshal 

func (m *GetDefinedRevisionsRequest) XXX_Unmarshal(b []byte) error

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

GetDefinedRevisionResponse contains info about defined/applied revisions.

func (*GetDefinedRevisionsResponse) Descriptor 

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

func (*GetDefinedRevisionsResponse) GetHighestApplied 

func (m *GetDefinedRevisionsResponse) GetHighestApplied() int64

func (*GetDefinedRevisionsResponse) GetHighestDefined 

func (m *GetDefinedRevisionsResponse) GetHighestDefined() int64

func (*GetDefinedRevisionsResponse) ProtoMessage 

func (*GetDefinedRevisionsResponse) ProtoMessage()

func (*GetDefinedRevisionsResponse) Reset 

func (m *GetDefinedRevisionsResponse) Reset()

func (*GetDefinedRevisionsResponse) String 

func (m *GetDefinedRevisionsResponse) String() string

func (*GetDefinedRevisionsResponse) XXX_DiscardUnknown 

func (m *GetDefinedRevisionsResponse) XXX_DiscardUnknown()

func (*GetDefinedRevisionsResponse) XXX_Marshal 

func (m *GetDefinedRevisionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDefinedRevisionsResponse) XXX_Merge 

func (m *GetDefinedRevisionsResponse) XXX_Merge(src proto.Message)

func (*GetDefinedRevisionsResponse) XXX_Size 

func (m *GetDefinedRevisionsResponse) XXX_Size() int

func (*GetDefinedRevisionsResponse) XXX_Unmarshal 

func (m *GetDefinedRevisionsResponse) XXX_Unmarshal(b []byte) error

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

func (*MapMetadata) Descriptor 

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

func (*MapMetadata) GetSources 

func (m *MapMetadata) GetSources() []*MapMetadata_SourceSlice

func (*MapMetadata) ProtoMessage 

func (*MapMetadata) ProtoMessage()

func (*MapMetadata) Reset 

func (m *MapMetadata) Reset()

func (*MapMetadata) String 

func (m *MapMetadata) String() string

func (*MapMetadata) XXX_DiscardUnknown 

func (m *MapMetadata) XXX_DiscardUnknown()

func (*MapMetadata) XXX_Marshal 

func (m *MapMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MapMetadata) XXX_Merge 

func (m *MapMetadata) XXX_Merge(src proto.Message)

func (*MapMetadata) XXX_Size 

func (m *MapMetadata) XXX_Size() int

func (*MapMetadata) XXX_Unmarshal 

func (m *MapMetadata) XXX_Unmarshal(b []byte) error

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

SourceSlice is the range of inputs that have been included in a map revision.

func (*MapMetadata_SourceSlice) Descriptor 

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

func (*MapMetadata_SourceSlice) GetHighestExclusive 

func (m *MapMetadata_SourceSlice) GetHighestExclusive() int64

func (*MapMetadata_SourceSlice) GetLogId 

func (m *MapMetadata_SourceSlice) GetLogId() int64

func (*MapMetadata_SourceSlice) GetLowestInclusive 

func (m *MapMetadata_SourceSlice) GetLowestInclusive() int64

func (*MapMetadata_SourceSlice) ProtoMessage 

func (*MapMetadata_SourceSlice) ProtoMessage()

func (*MapMetadata_SourceSlice) Reset 

func (m *MapMetadata_SourceSlice) Reset()

func (*MapMetadata_SourceSlice) String 

func (m *MapMetadata_SourceSlice) String() string

func (*MapMetadata_SourceSlice) XXX_DiscardUnknown 

func (m *MapMetadata_SourceSlice) XXX_DiscardUnknown()

func (*MapMetadata_SourceSlice) XXX_Marshal 

func (m *MapMetadata_SourceSlice) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MapMetadata_SourceSlice) XXX_Merge 

func (m *MapMetadata_SourceSlice) XXX_Merge(src proto.Message)

func (*MapMetadata_SourceSlice) XXX_Size 

func (m *MapMetadata_SourceSlice) XXX_Size() int

func (*MapMetadata_SourceSlice) XXX_Unmarshal 

func (m *MapMetadata_SourceSlice) XXX_Unmarshal(b []byte) error

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

PublishRevisionsRequest copies all available SignedMapRoots into the Log of SignedMapRoots.

func (*PublishRevisionsRequest) Descriptor 

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

func (*PublishRevisionsRequest) GetBlock 

func (m *PublishRevisionsRequest) GetBlock() bool

func (*PublishRevisionsRequest) GetDirectoryId 

func (m *PublishRevisionsRequest) GetDirectoryId() string

func (*PublishRevisionsRequest) ProtoMessage 

func (*PublishRevisionsRequest) ProtoMessage()

func (*PublishRevisionsRequest) Reset 

func (m *PublishRevisionsRequest) Reset()

func (*PublishRevisionsRequest) String 

func (m *PublishRevisionsRequest) String() string

func (*PublishRevisionsRequest) XXX_DiscardUnknown 

func (m *PublishRevisionsRequest) XXX_DiscardUnknown()

func (*PublishRevisionsRequest) XXX_Marshal 

func (m *PublishRevisionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PublishRevisionsRequest) XXX_Merge 

func (m *PublishRevisionsRequest) XXX_Merge(src proto.Message)

func (*PublishRevisionsRequest) XXX_Size 

func (m *PublishRevisionsRequest) XXX_Size() int

func (*PublishRevisionsRequest) XXX_Unmarshal 

func (m *PublishRevisionsRequest) XXX_Unmarshal(b []byte) error

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

PublishRevisionsResponse contains metrics about the publishing operation.

func (*PublishRevisionsResponse) Descriptor 

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

func (*PublishRevisionsResponse) GetRevisions 

func (m *PublishRevisionsResponse) GetRevisions() []int64

func (*PublishRevisionsResponse) ProtoMessage 

func (*PublishRevisionsResponse) ProtoMessage()

func (*PublishRevisionsResponse) Reset 

func (m *PublishRevisionsResponse) Reset()

func (*PublishRevisionsResponse) String 

func (m *PublishRevisionsResponse) String() string

func (*PublishRevisionsResponse) XXX_DiscardUnknown 

func (m *PublishRevisionsResponse) XXX_DiscardUnknown()

func (*PublishRevisionsResponse) XXX_Marshal 

func (m *PublishRevisionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PublishRevisionsResponse) XXX_Merge 

func (m *PublishRevisionsResponse) XXX_Merge(src proto.Message)

func (*PublishRevisionsResponse) XXX_Size 

func (m *PublishRevisionsResponse) XXX_Size() int

func (*PublishRevisionsResponse) XXX_Unmarshal 

func (m *PublishRevisionsResponse) XXX_Unmarshal(b []byte) error

type UnimplementedKeyTransparencySequencerServer 

type UnimplementedKeyTransparencySequencerServer struct {
}

UnimplementedKeyTransparencySequencerServer can be embedded to have forward compatible implementations.

func (*UnimplementedKeyTransparencySequencerServer) ApplyRevision 

func (*UnimplementedKeyTransparencySequencerServer) ApplyRevision(ctx context.Context, req *ApplyRevisionRequest) (*ApplyRevisionResponse, error)

func (*UnimplementedKeyTransparencySequencerServer) ApplyRevisions 

func (*UnimplementedKeyTransparencySequencerServer) ApplyRevisions(ctx context.Context, req *ApplyRevisionsRequest) (*empty.Empty, error)

func (*UnimplementedKeyTransparencySequencerServer) DefineRevisions 

func (*UnimplementedKeyTransparencySequencerServer) DefineRevisions(ctx context.Context, req *DefineRevisionsRequest) (*DefineRevisionsResponse, error)

func (*UnimplementedKeyTransparencySequencerServer) EstimateBacklog 

func (*UnimplementedKeyTransparencySequencerServer) EstimateBacklog(ctx context.Context, req *EstimateBacklogRequest) (*EstimateBacklogResponse, error)

func (*UnimplementedKeyTransparencySequencerServer) GetDefinedRevisions 

func (*UnimplementedKeyTransparencySequencerServer) GetDefinedRevisions(ctx context.Context, req *GetDefinedRevisionsRequest) (*GetDefinedRevisionsResponse, error)

func (*UnimplementedKeyTransparencySequencerServer) PublishRevisions 

func (*UnimplementedKeyTransparencySequencerServer) PublishRevisions(ctx context.Context, req *PublishRevisionsRequest) (*PublishRevisionsResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.