Documentation
¶
Overview ¶
Package gcppb contains proto messages for GCP-based Skylog storage.
Index ¶
- type BuildJob
- func (*BuildJob) Descriptor() ([]byte, []int)
- func (m *BuildJob) GetBegin() uint64
- func (m *BuildJob) GetEnd() uint64
- func (m *BuildJob) GetSeqSharding() *SequenceSharding
- func (m *BuildJob) GetTreeId() int64
- func (m *BuildJob) GetTreeSharding() *TreeSharding
- func (*BuildJob) ProtoMessage()
- func (m *BuildJob) Reset()
- func (m *BuildJob) String() string
- func (m *BuildJob) XXX_DiscardUnknown()
- func (m *BuildJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BuildJob) XXX_Merge(src proto.Message)
- func (m *BuildJob) XXX_Size() int
- func (m *BuildJob) XXX_Unmarshal(b []byte) error
- type SequenceSharding
- func (*SequenceSharding) Descriptor() ([]byte, []int)
- func (m *SequenceSharding) GetShards() uint32
- func (m *SequenceSharding) GetSize() uint64
- func (*SequenceSharding) ProtoMessage()
- func (m *SequenceSharding) Reset()
- func (m *SequenceSharding) String() string
- func (m *SequenceSharding) XXX_DiscardUnknown()
- func (m *SequenceSharding) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SequenceSharding) XXX_Merge(src proto.Message)
- func (m *SequenceSharding) XXX_Size() int
- func (m *SequenceSharding) XXX_Unmarshal(b []byte) error
- type TreeSharding
- func (*TreeSharding) Descriptor() ([]byte, []int)
- func (m *TreeSharding) GetLevels() uint32
- func (m *TreeSharding) GetShards() uint32
- func (*TreeSharding) ProtoMessage()
- func (m *TreeSharding) Reset()
- func (m *TreeSharding) String() string
- func (m *TreeSharding) XXX_DiscardUnknown()
- func (m *TreeSharding) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TreeSharding) XXX_Merge(src proto.Message)
- func (m *TreeSharding) XXX_Size() int
- func (m *TreeSharding) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) GetSeqSharding ¶
func (m *BuildJob) GetSeqSharding() *SequenceSharding
func (*BuildJob) GetTreeSharding ¶
func (m *BuildJob) GetTreeSharding() *TreeSharding
func (*BuildJob) ProtoMessage ¶
func (*BuildJob) ProtoMessage()
func (*BuildJob) XXX_DiscardUnknown ¶
func (m *BuildJob) XXX_DiscardUnknown()
func (*BuildJob) XXX_Marshal ¶
func (*BuildJob) XXX_Unmarshal ¶
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