log

package
v0.0.0-...-4e5fb1c Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthLog        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLog          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLog = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var MemberGroupStrategy_name = map[int32]string{
	0: "HOST_AWARE",
	1: "RACK_AWARE",
	2: "ZONE_AWARE",
}
View Source 
var MemberGroupStrategy_value = map[string]int32{
	"HOST_AWARE": 0,
	"RACK_AWARE": 1,
	"ZONE_AWARE": 2,
}
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 CompactionSpec 

type CompactionSpec struct {
	Dynamic        bool    `protobuf:"varint,1,opt,name=dynamic,proto3" json:"dynamic,omitempty"`
	FreeDiskBuffer float64 `protobuf:"fixed64,2,opt,name=free_disk_buffer,json=freeDiskBuffer,proto3" json:"free_disk_buffer,omitempty"`
}

Partition group compaction configuration

func (*CompactionSpec) Descriptor 

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

func (*CompactionSpec) GetDynamic 

func (m *CompactionSpec) GetDynamic() bool

func (*CompactionSpec) GetFreeDiskBuffer 

func (m *CompactionSpec) GetFreeDiskBuffer() float64

func (*CompactionSpec) Marshal 

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

func (*CompactionSpec) MarshalTo 

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

func (*CompactionSpec) MarshalToSizedBuffer 

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

func (*CompactionSpec) ProtoMessage 

func (*CompactionSpec) ProtoMessage()

func (*CompactionSpec) Reset 

func (m *CompactionSpec) Reset()

func (*CompactionSpec) Size 

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

func (*CompactionSpec) String 

func (m *CompactionSpec) String() string

func (*CompactionSpec) Unmarshal 

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

func (*CompactionSpec) XXX_DiscardUnknown 

func (m *CompactionSpec) XXX_DiscardUnknown()

func (*CompactionSpec) XXX_Marshal 

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

func (*CompactionSpec) XXX_Merge 

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

func (*CompactionSpec) XXX_Size 

func (m *CompactionSpec) XXX_Size() int

func (*CompactionSpec) XXX_Unmarshal 

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

type LogProtocol 

type LogProtocol struct {
	MemberGroupStrategy MemberGroupStrategy `` /* 167-byte string literal not displayed */
	Storage             *StorageSpec        `protobuf:"bytes,2,opt,name=storage,proto3" json:"storage,omitempty"`
	Compaction          *CompactionSpec     `protobuf:"bytes,3,opt,name=compaction,proto3" json:"compaction,omitempty"`
}

Log protocol configuration

func (*LogProtocol) Descriptor 

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

func (*LogProtocol) GetCompaction 

func (m *LogProtocol) GetCompaction() *CompactionSpec

func (*LogProtocol) GetMemberGroupStrategy 

func (m *LogProtocol) GetMemberGroupStrategy() MemberGroupStrategy

func (*LogProtocol) GetStorage 

func (m *LogProtocol) GetStorage() *StorageSpec

func (*LogProtocol) Marshal 

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

func (*LogProtocol) MarshalTo 

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

func (*LogProtocol) MarshalToSizedBuffer 

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

func (*LogProtocol) ProtoMessage 

func (*LogProtocol) ProtoMessage()

func (*LogProtocol) Reset 

func (m *LogProtocol) Reset()

func (*LogProtocol) Size 

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

func (*LogProtocol) String 

func (m *LogProtocol) String() string

func (*LogProtocol) Unmarshal 

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

func (*LogProtocol) XXX_DiscardUnknown 

func (m *LogProtocol) XXX_DiscardUnknown()

func (*LogProtocol) XXX_Marshal 

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

func (*LogProtocol) XXX_Merge 

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

func (*LogProtocol) XXX_Size 

func (m *LogProtocol) XXX_Size() int

func (*LogProtocol) XXX_Unmarshal 

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

type MemberGroupStrategy 

type MemberGroupStrategy int32

Member group strategy 

const (
	MemberGroupStrategy_HOST_AWARE MemberGroupStrategy = 0
	MemberGroupStrategy_RACK_AWARE MemberGroupStrategy = 1
	MemberGroupStrategy_ZONE_AWARE MemberGroupStrategy = 2
)

func (MemberGroupStrategy) EnumDescriptor 

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

func (MemberGroupStrategy) String 

func (x MemberGroupStrategy) String() string

type StorageLevel 

type StorageLevel int32

Storage level 

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

type StorageSpec 

type StorageSpec struct {
	MaxEntrySize  uint32       `protobuf:"varint,1,opt,name=max_entry_size,json=maxEntrySize,proto3" json:"max_entry_size,omitempty"`
	SegmentSize   uint32       `protobuf:"varint,2,opt,name=segment_size,json=segmentSize,proto3" json:"segment_size,omitempty"`
	Level         StorageLevel `protobuf:"varint,3,opt,name=level,proto3,enum=atomix.protocols.log.StorageLevel" json:"level,omitempty"`
	FlushOnCommit bool         `protobuf:"varint,4,opt,name=flush_on_commit,json=flushOnCommit,proto3" json:"flush_on_commit,omitempty"`
}

Partition group storage configuration

func (*StorageSpec) Descriptor 

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

func (*StorageSpec) GetFlushOnCommit 

func (m *StorageSpec) GetFlushOnCommit() bool

func (*StorageSpec) GetLevel 

func (m *StorageSpec) GetLevel() StorageLevel

func (*StorageSpec) GetMaxEntrySize 

func (m *StorageSpec) GetMaxEntrySize() uint32

func (*StorageSpec) GetSegmentSize 

func (m *StorageSpec) GetSegmentSize() uint32

func (*StorageSpec) Marshal 

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

func (*StorageSpec) MarshalTo 

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

func (*StorageSpec) MarshalToSizedBuffer 

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

func (*StorageSpec) ProtoMessage 

func (*StorageSpec) ProtoMessage()

func (*StorageSpec) Reset 

func (m *StorageSpec) Reset()

func (*StorageSpec) Size 

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

func (*StorageSpec) String 

func (m *StorageSpec) String() string

func (*StorageSpec) Unmarshal 

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

func (*StorageSpec) XXX_DiscardUnknown 

func (m *StorageSpec) XXX_DiscardUnknown()

func (*StorageSpec) XXX_Marshal 

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

func (*StorageSpec) XXX_Merge 

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

func (*StorageSpec) XXX_Size 

func (m *StorageSpec) XXX_Size() int

func (*StorageSpec) XXX_Unmarshal 

func (m *StorageSpec) 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.