config

package
v0.0.0-...-f429149 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthConfig = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowConfig   = fmt.Errorf("proto: integer overflow")
)
View Source 
var StorageLevel_name = map[int32]string{
	0: "DISK",
	1: "MAPPED",
}
View Source 
var StorageLevel_value = map[string]int32{
	"DISK":   0,
	"MAPPED": 1,
}

Functions

This section is empty.

Types

type CompactionConfig 

type CompactionConfig struct {
	Dynamic          bool    `protobuf:"varint,1,opt,name=dynamic,proto3" json:"dynamic,omitempty"`
	FreeDiskBuffer   float32 `protobuf:"fixed32,2,opt,name=free_disk_buffer,json=freeDiskBuffer,proto3" json:"free_disk_buffer,omitempty"`
	FreeMemoryBuffer float32 `protobuf:"fixed32,3,opt,name=free_memory_buffer,json=freeMemoryBuffer,proto3" json:"free_memory_buffer,omitempty"`
}

func NewPopulatedCompactionConfig 

func NewPopulatedCompactionConfig(r randyConfig, easy bool) *CompactionConfig

func (*CompactionConfig) Descriptor 

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

func (*CompactionConfig) Equal 

func (this *CompactionConfig) Equal(that interface{}) bool

func (*CompactionConfig) GetDynamic 

func (m *CompactionConfig) GetDynamic() bool

func (*CompactionConfig) GetFreeDiskBuffer 

func (m *CompactionConfig) GetFreeDiskBuffer() float32

func (*CompactionConfig) GetFreeMemoryBuffer 

func (m *CompactionConfig) GetFreeMemoryBuffer() float32

func (*CompactionConfig) Marshal 

func (m *CompactionConfig) Marshal() (dAtA []byte, err error)

func (*CompactionConfig) MarshalTo 

func (m *CompactionConfig) MarshalTo(dAtA []byte) (int, error)

func (*CompactionConfig) MarshalToSizedBuffer 

func (m *CompactionConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CompactionConfig) ProtoMessage 

func (*CompactionConfig) ProtoMessage()

func (*CompactionConfig) Reset 

func (m *CompactionConfig) Reset()

func (*CompactionConfig) Size 

func (m *CompactionConfig) Size() (n int)

func (*CompactionConfig) String 

func (m *CompactionConfig) String() string

func (*CompactionConfig) Unmarshal 

func (m *CompactionConfig) Unmarshal(dAtA []byte) error

func (*CompactionConfig) XXX_DiscardUnknown 

func (m *CompactionConfig) XXX_DiscardUnknown()

func (*CompactionConfig) XXX_Marshal 

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

func (*CompactionConfig) XXX_Merge 

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

func (*CompactionConfig) XXX_Size 

func (m *CompactionConfig) XXX_Size() int

func (*CompactionConfig) XXX_Unmarshal 

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

type ProtocolConfig 

type ProtocolConfig struct {
	ElectionTimeout   *time.Duration    `protobuf:"bytes,1,opt,name=election_timeout,json=electionTimeout,proto3,stdduration" json:"election_timeout,omitempty"`
	HeartbeatInterval *time.Duration    `protobuf:"bytes,2,opt,name=heartbeat_interval,json=heartbeatInterval,proto3,stdduration" json:"heartbeat_interval,omitempty"`
	Storage           *StorageConfig    `protobuf:"bytes,3,opt,name=storage,proto3" json:"storage,omitempty"`
	Compaction        *CompactionConfig `protobuf:"bytes,4,opt,name=compaction,proto3" json:"compaction,omitempty"`
}

func NewPopulatedProtocolConfig 

func NewPopulatedProtocolConfig(r randyConfig, easy bool) *ProtocolConfig

func (*ProtocolConfig) Descriptor 

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

func (*ProtocolConfig) Equal 

func (this *ProtocolConfig) Equal(that interface{}) bool

func (*ProtocolConfig) GetCompaction 

func (m *ProtocolConfig) GetCompaction() *CompactionConfig

func (*ProtocolConfig) GetElectionTimeout 

func (m *ProtocolConfig) GetElectionTimeout() *time.Duration

func (*ProtocolConfig) GetElectionTimeoutOrDefault 

func (c *ProtocolConfig) GetElectionTimeoutOrDefault() time.Duration

GetElectionTimeoutOrDefault returns the configured election timeout if set, otherwise the default election timeout

func (*ProtocolConfig) GetHeartbeatInterval 

func (m *ProtocolConfig) GetHeartbeatInterval() *time.Duration

func (*ProtocolConfig) GetHeartbeatIntervalOrDefault 

func (c *ProtocolConfig) GetHeartbeatIntervalOrDefault() time.Duration

GetHeartbeatIntervalOrDefault returns the configured heartbeat interval if set, otherwise the default heartbeat interval

func (*ProtocolConfig) GetStorage 

func (m *ProtocolConfig) GetStorage() *StorageConfig

func (*ProtocolConfig) Marshal 

func (m *ProtocolConfig) Marshal() (dAtA []byte, err error)

func (*ProtocolConfig) MarshalTo 

func (m *ProtocolConfig) MarshalTo(dAtA []byte) (int, error)

func (*ProtocolConfig) MarshalToSizedBuffer 

func (m *ProtocolConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProtocolConfig) ProtoMessage 

func (*ProtocolConfig) ProtoMessage()

func (*ProtocolConfig) Reset 

func (m *ProtocolConfig) Reset()

func (*ProtocolConfig) Size 

func (m *ProtocolConfig) Size() (n int)

func (*ProtocolConfig) String 

func (m *ProtocolConfig) String() string

func (*ProtocolConfig) Unmarshal 

func (m *ProtocolConfig) Unmarshal(dAtA []byte) error

func (*ProtocolConfig) XXX_DiscardUnknown 

func (m *ProtocolConfig) XXX_DiscardUnknown()

func (*ProtocolConfig) XXX_Marshal 

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

func (*ProtocolConfig) XXX_Merge 

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

func (*ProtocolConfig) XXX_Size 

func (m *ProtocolConfig) XXX_Size() int

func (*ProtocolConfig) XXX_Unmarshal 

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

type StorageConfig 

type StorageConfig struct {
	Directory     string       `protobuf:"bytes,1,opt,name=directory,proto3" json:"directory,omitempty"`
	Level         StorageLevel `protobuf:"varint,2,opt,name=level,proto3,enum=atomix.raft.config.StorageLevel" json:"level,omitempty"`
	MaxEntrySize  uint32       `protobuf:"varint,3,opt,name=max_entry_size,json=maxEntrySize,proto3" json:"max_entry_size,omitempty"`
	SegmentSize   uint32       `protobuf:"varint,4,opt,name=segment_size,json=segmentSize,proto3" json:"segment_size,omitempty"`
	FlushOnCommit bool         `protobuf:"varint,5,opt,name=flush_on_commit,json=flushOnCommit,proto3" json:"flush_on_commit,omitempty"`
}

func NewPopulatedStorageConfig 

func NewPopulatedStorageConfig(r randyConfig, easy bool) *StorageConfig

func (*StorageConfig) Descriptor 

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

func (*StorageConfig) Equal 

func (this *StorageConfig) Equal(that interface{}) bool

func (*StorageConfig) GetDirectory 

func (m *StorageConfig) GetDirectory() string

func (*StorageConfig) GetFlushOnCommit 

func (m *StorageConfig) GetFlushOnCommit() bool

func (*StorageConfig) GetLevel 

func (m *StorageConfig) GetLevel() StorageLevel

func (*StorageConfig) GetMaxEntrySize 

func (m *StorageConfig) GetMaxEntrySize() uint32

func (*StorageConfig) GetSegmentSize 

func (m *StorageConfig) GetSegmentSize() uint32

func (*StorageConfig) Marshal 

func (m *StorageConfig) Marshal() (dAtA []byte, err error)

func (*StorageConfig) MarshalTo 

func (m *StorageConfig) MarshalTo(dAtA []byte) (int, error)

func (*StorageConfig) MarshalToSizedBuffer 

func (m *StorageConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StorageConfig) ProtoMessage 

func (*StorageConfig) ProtoMessage()

func (*StorageConfig) Reset 

func (m *StorageConfig) Reset()

func (*StorageConfig) Size 

func (m *StorageConfig) Size() (n int)

func (*StorageConfig) String 

func (m *StorageConfig) String() string

func (*StorageConfig) Unmarshal 

func (m *StorageConfig) Unmarshal(dAtA []byte) error

func (*StorageConfig) XXX_DiscardUnknown 

func (m *StorageConfig) XXX_DiscardUnknown()

func (*StorageConfig) XXX_Marshal 

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

func (*StorageConfig) XXX_Merge 

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

func (*StorageConfig) XXX_Size 

func (m *StorageConfig) XXX_Size() int

func (*StorageConfig) XXX_Unmarshal 

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

type StorageLevel 

type StorageLevel int32
const (
	StorageLevel_DISK   StorageLevel = 0
	StorageLevel_MAPPED StorageLevel = 1
)

func (StorageLevel) EnumDescriptor 

func (StorageLevel) EnumDescriptor() ([]byte, []int)

func (StorageLevel) String 

func (x StorageLevel) String() string

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.