configpb

Documentation

Overview

Package configpb holds a config protobuf for Migrillian.

Index

• type MigrationConfig
  • func (*MigrationConfig) Descriptor() ([]byte, []int)
  • func (m *MigrationConfig) GetBatchSize() int32
  • func (m *MigrationConfig) GetEndIndex() int64
  • func (m *MigrationConfig) GetIsContinuous() bool
  • func (m *MigrationConfig) GetLogId() int64
  • func (m *MigrationConfig) GetPublicKey() *keyspb.PublicKey
  • func (m *MigrationConfig) GetSourceUri() string
  • func (m *MigrationConfig) GetStartIndex() int64
  • func (m *MigrationConfig) GetTrillianUri() string
  • func (*MigrationConfig) ProtoMessage()
  • func (m *MigrationConfig) Reset()
  • func (m *MigrationConfig) String() string
  • func (m *MigrationConfig) XXX_DiscardUnknown()
  • func (m *MigrationConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *MigrationConfig) XXX_Merge(src proto.Message)
  • func (m *MigrationConfig) XXX_Size() int
  • func (m *MigrationConfig) XXX_Unmarshal(b []byte) error

Types

type MigrationConfig

type MigrationConfig struct {
	// The URI of the source CT log, e.g. "https://ct.googleapis.com/pilot".
	SourceUri string `protobuf:"bytes,1,opt,name=source_uri,json=sourceUri,proto3" json:"source_uri,omitempty"`
	// The public key of the source log.
	PublicKey *keyspb.PublicKey `protobuf:"bytes,2,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// Trillian backend RPC endpoint (host:port), e.g. "localhost:8090".
	// TODO(pavelkalinnikov): Reference a CTFE's LogBackend by name.
	TrillianUri string `protobuf:"bytes,3,opt,name=trillian_uri,json=trillianUri,proto3" json:"trillian_uri,omitempty"`
	// The ID of a Trillian PREORDERED_LOG tree that stores the log data.
	LogId int64 `protobuf:"varint,4,opt,name=log_id,json=logId,proto3" json:"log_id,omitempty"`
	// Max number of entries per get-entries request from the source log.
	BatchSize int32 `protobuf:"varint,5,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// Determines whether the migration should run continuously, i.e. watch and
	// follow the updates of the source log's STH. For example, this mode can be
	// used to support a mirror CT log.
	IsContinuous bool `protobuf:"varint,6,opt,name=is_continuous,json=isContinuous,proto3" json:"is_continuous,omitempty"`
	// The log entry index to start fetching at. Ignored in continuous mode which
	// starts at the point where it stopped (e.g. the current Trillian tree size
	// in a simple case).
	StartIndex int64 `protobuf:"varint,7,opt,name=start_index,json=startIndex,proto3" json:"start_index,omitempty"`
	// The log index to end fetching at, non-inclusive. If zero, fetch up to the
	// source log's current STH. Ignored in continuous mode which keeps updating
	// STH and fetching up to that.
	EndIndex             int64    `protobuf:"varint,8,opt,name=end_index,json=endIndex,proto3" json:"end_index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

MigrationConfig describes the configuration options for a single CT log migration instance.

func (*MigrationConfig) Descriptor

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

func (*MigrationConfig) GetBatchSize

func (m *MigrationConfig) GetBatchSize() int32

func (*MigrationConfig) GetEndIndex

func (m *MigrationConfig) GetEndIndex() int64

func (*MigrationConfig) GetIsContinuous

func (m *MigrationConfig) GetIsContinuous() bool

func (*MigrationConfig) GetLogId

func (m *MigrationConfig) GetLogId() int64

func (*MigrationConfig) GetPublicKey

func (m *MigrationConfig) GetPublicKey() *keyspb.PublicKey

func (*MigrationConfig) GetSourceUri

func (m *MigrationConfig) GetSourceUri() string

func (*MigrationConfig) GetStartIndex

func (m *MigrationConfig) GetStartIndex() int64

func (*MigrationConfig) GetTrillianUri

func (m *MigrationConfig) GetTrillianUri() string

func (*MigrationConfig) ProtoMessage

func (*MigrationConfig) ProtoMessage()

func (*MigrationConfig) Reset

func (m *MigrationConfig) Reset()

func (*MigrationConfig) String

func (m *MigrationConfig) String() string

func (*MigrationConfig) XXX_DiscardUnknown

func (m *MigrationConfig) XXX_DiscardUnknown()

func (*MigrationConfig) XXX_Marshal

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

func (*MigrationConfig) XXX_Merge

func (dst *MigrationConfig) XXX_Merge(src proto.Message)

func (*MigrationConfig) XXX_Size

func (m *MigrationConfig) XXX_Size() int

func (*MigrationConfig) XXX_Unmarshal

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