sequencer_go_proto

package
v0.1.2-alpha Latest Latest
Warning

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

 Go to latest Published: Dec 21, 2018 License: Apache-2.0 Imports: 6 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 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DefineRevisionRequest contains information needed to define a new revision.

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) 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 {
	// outsanding_revisions a list of all the defined revisions which are not yet applied.
	OutstandingRevisions []int64  `` /* 129-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DefineRevisionResponse contains information about freshly defined revisions.

func (*DefineRevisionsResponse) Descriptor 

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

func (*DefineRevisionsResponse) GetOutstandingRevisions 

func (m *DefineRevisionsResponse) GetOutstandingRevisions() []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 KeyTransparencySequencerClient 

type KeyTransparencySequencerClient interface {
	// RunBatch calls DefineRevisions, ApplyRevision, and PublishRevisions successively.
	RunBatch(ctx context.Context, in *RunBatchRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// DefineRevision examines the outstanding items in the queue and optionally
	// writes the metadata for one or more revisions to the metadata database.
	DefineRevisions(ctx context.Context, in *DefineRevisionsRequest, opts ...grpc.CallOption) (*DefineRevisionsResponse, error)
	// ApplyRevision applies the contained mutations to the current map root.
	// If this method fails, it must be retried with the same arguments.
	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)
}

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 {
	// RunBatch calls DefineRevisions, ApplyRevision, and PublishRevisions successively.
	RunBatch(context.Context, *RunBatchRequest) (*empty.Empty, error)
	// DefineRevision examines the outstanding items in the queue and optionally
	// writes the metadata for one or more revisions to the metadata database.
	DefineRevisions(context.Context, *DefineRevisionsRequest) (*DefineRevisionsResponse, error)
	// ApplyRevision applies the contained mutations to the current map root.
	// If this method fails, it must be retried with the same arguments.
	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)
}

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.
	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.
	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 RunBatchRequest 

type RunBatchRequest struct {
	// directory_id is the directory to run 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"`
	// block until a Signed Log Root has been published which encompases all map roots.
	Block                bool     `protobuf:"varint,4,opt,name=block,proto3" json:"block,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RunBatchRequest triggers the sequencing of a batch of mutations for a directory, with the batch size governed by the request parameters.

func (*RunBatchRequest) Descriptor 

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

func (*RunBatchRequest) GetBlock 

func (m *RunBatchRequest) GetBlock() bool

func (*RunBatchRequest) GetDirectoryId 

func (m *RunBatchRequest) GetDirectoryId() string

func (*RunBatchRequest) GetMaxBatch 

func (m *RunBatchRequest) GetMaxBatch() int32

func (*RunBatchRequest) GetMinBatch 

func (m *RunBatchRequest) GetMinBatch() int32

func (*RunBatchRequest) ProtoMessage 

func (*RunBatchRequest) ProtoMessage()

func (*RunBatchRequest) Reset 

func (m *RunBatchRequest) Reset()

func (*RunBatchRequest) String 

func (m *RunBatchRequest) String() string

func (*RunBatchRequest) XXX_DiscardUnknown 

func (m *RunBatchRequest) XXX_DiscardUnknown()

func (*RunBatchRequest) XXX_Marshal 

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

func (*RunBatchRequest) XXX_Merge 

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

func (*RunBatchRequest) XXX_Size 

func (m *RunBatchRequest) XXX_Size() int

func (*RunBatchRequest) XXX_Unmarshal 

func (m *RunBatchRequest) XXX_Unmarshal(b []byte) 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.