package gcppb

import "github.com/google/trillian/skylog/storage/gcp/gcppb"

Package gcppb contains proto messages for GCP-based Skylog storage.

Index

Types

type BuildJob 

type BuildJob struct {
	// The tree ID to build a subtree of.
	TreeId int64 `protobuf:"varint,1,opt,name=tree_id,json=treeId,proto3" json:"tree_id,omitempty"`
	// The beginning of the leaves range (inclusive).
	Begin uint64 `protobuf:"varint,2,opt,name=begin,proto3" json:"begin,omitempty"`
	// The ending of the leaves range (exclusive).
	End uint64 `protobuf:"varint,3,opt,name=end,proto3" json:"end,omitempty"`
	// The tree sharding scheme that the build worker should use. Since builders
	// are stateless it is more efficient to pass it in from the master rather
	// than fetch it from storage on each job invocation.
	TreeSharding *TreeSharding `protobuf:"bytes,4,opt,name=tree_sharding,json=treeSharding,proto3" json:"tree_sharding,omitempty"`
	// The sequence sharding scheme that the build worker should use. It is
	// provided for the same reason as the tree sharding field.
	SeqSharding          *SequenceSharding `protobuf:"bytes,5,opt,name=seq_sharding,json=seqSharding,proto3" json:"seq_sharding,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

BuildJob is a Merke tree building job. It instructs workers to build a subtree covering leaves of the [begin, end) range for the specified tree.

func (*BuildJob) Descriptor 

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

func (*BuildJob) GetBegin 

func (m *BuildJob) GetBegin() uint64

func (*BuildJob) GetEnd 

func (m *BuildJob) GetEnd() uint64

func (*BuildJob) GetSeqSharding 

func (m *BuildJob) GetSeqSharding() *SequenceSharding

func (*BuildJob) GetTreeId 

func (m *BuildJob) GetTreeId() int64

func (*BuildJob) GetTreeSharding 

func (m *BuildJob) GetTreeSharding() *TreeSharding

func (*BuildJob) ProtoMessage 

func (*BuildJob) ProtoMessage()

func (*BuildJob) Reset 

func (m *BuildJob) Reset()

func (*BuildJob) String 

func (m *BuildJob) String() string

func (*BuildJob) XXX_DiscardUnknown 

func (m *BuildJob) XXX_DiscardUnknown()

func (*BuildJob) XXX_Marshal 

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

func (*BuildJob) XXX_Merge 

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

func (*BuildJob) XXX_Size 

func (m *BuildJob) XXX_Size() int

func (*BuildJob) XXX_Unmarshal 

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

type SequenceSharding 

type SequenceSharding struct {
	Shards               uint32   `protobuf:"varint,1,opt,name=shards,proto3" json:"shards,omitempty"`
	Size                 uint64   `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SequenceSharding describes the sequenced log entries sharding scheme.

The sequence is split into the specified number of shards, where each shard stores a periodic sub-sequence consisting of stripes of the specified size.

See the sequence storage comments for more details.

func (*SequenceSharding) Descriptor 

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

func (*SequenceSharding) GetShards 

func (m *SequenceSharding) GetShards() uint32

func (*SequenceSharding) GetSize 

func (m *SequenceSharding) GetSize() uint64

func (*SequenceSharding) ProtoMessage 

func (*SequenceSharding) ProtoMessage()

func (*SequenceSharding) Reset 

func (m *SequenceSharding) Reset()

func (*SequenceSharding) String 

func (m *SequenceSharding) String() string

func (*SequenceSharding) XXX_DiscardUnknown 

func (m *SequenceSharding) XXX_DiscardUnknown()

func (*SequenceSharding) XXX_Marshal 

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

func (*SequenceSharding) XXX_Merge 

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

func (*SequenceSharding) XXX_Size 

func (m *SequenceSharding) XXX_Size() int

func (*SequenceSharding) XXX_Unmarshal 

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

type TreeSharding 

type TreeSharding struct {
	Levels               uint32   `protobuf:"varint,1,opt,name=levels,proto3" json:"levels,omitempty"`
	Shards               uint32   `protobuf:"varint,2,opt,name=shards,proto3" json:"shards,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TreeSharding describes the tree nodes sharding scheme.

The specified number of lower tree levels are split into the specified number of shards, where each shard stores a periodic sub-structure of perfect subtrees. There is one extra shard covering the upper tree levels.

See the tree storage comments for more details.

func (*TreeSharding) Descriptor 

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

func (*TreeSharding) GetLevels 

func (m *TreeSharding) GetLevels() uint32

func (*TreeSharding) GetShards 

func (m *TreeSharding) GetShards() uint32

func (*TreeSharding) ProtoMessage 

func (*TreeSharding) ProtoMessage()

func (*TreeSharding) Reset 

func (m *TreeSharding) Reset()

func (*TreeSharding) String 

func (m *TreeSharding) String() string

func (*TreeSharding) XXX_DiscardUnknown 

func (m *TreeSharding) XXX_DiscardUnknown()

func (*TreeSharding) XXX_Marshal 

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

func (*TreeSharding) XXX_Merge 

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

func (*TreeSharding) XXX_Size 

func (m *TreeSharding) XXX_Size() int

func (*TreeSharding) XXX_Unmarshal 

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

Source Files

gcp.pb.go gen.go

Version
v1.3.8
Published
Feb 18, 2020
Platform
js/wasm
Imports
3 packages
Last checked
6 hours ago –

Tools for package owners.