flush

Documentation

Overview

Package flush is a generated protocol buffer package.

It is generated from these files:

github.com/m3db/m3/src/aggregator/generated/proto/flush/flush.proto

It has these top-level messages:

ShardSetFlushTimes
ShardFlushTimes
ForwardedFlushTimesForResolution

Index

• Variables
• type ForwardedFlushTimesForResolution
  • func (*ForwardedFlushTimesForResolution) Descriptor() ([]byte, []int)
  • func (m *ForwardedFlushTimesForResolution) GetByNumForwardedTimes() map[int32]int64
  • func (m *ForwardedFlushTimesForResolution) Marshal() (dAtA []byte, err error)
  • func (m *ForwardedFlushTimesForResolution) MarshalTo(dAtA []byte) (int, error)
  • func (*ForwardedFlushTimesForResolution) ProtoMessage()
  • func (m *ForwardedFlushTimesForResolution) Reset()
  • func (m *ForwardedFlushTimesForResolution) Size() (n int)
  • func (m *ForwardedFlushTimesForResolution) String() string
  • func (m *ForwardedFlushTimesForResolution) Unmarshal(dAtA []byte) error
• type ShardFlushTimes
  • func (*ShardFlushTimes) Descriptor() ([]byte, []int)
  • func (m *ShardFlushTimes) GetForwardedByResolution() map[int64]*ForwardedFlushTimesForResolution
  • func (m *ShardFlushTimes) GetStandardByResolution() map[int64]int64
  • func (m *ShardFlushTimes) GetTimedByResolution() map[int64]int64
  • func (m *ShardFlushTimes) GetTombstoned() bool
  • func (m *ShardFlushTimes) Marshal() (dAtA []byte, err error)
  • func (m *ShardFlushTimes) MarshalTo(dAtA []byte) (int, error)
  • func (*ShardFlushTimes) ProtoMessage()
  • func (m *ShardFlushTimes) Reset()
  • func (m *ShardFlushTimes) Size() (n int)
  • func (m *ShardFlushTimes) String() string
  • func (m *ShardFlushTimes) Unmarshal(dAtA []byte) error
• type ShardSetFlushTimes
  • func (*ShardSetFlushTimes) Descriptor() ([]byte, []int)
  • func (m *ShardSetFlushTimes) GetByShard() map[uint32]*ShardFlushTimes
  • func (m *ShardSetFlushTimes) Marshal() (dAtA []byte, err error)
  • func (m *ShardSetFlushTimes) MarshalTo(dAtA []byte) (int, error)
  • func (*ShardSetFlushTimes) ProtoMessage()
  • func (m *ShardSetFlushTimes) Reset()
  • func (m *ShardSetFlushTimes) Size() (n int)
  • func (m *ShardSetFlushTimes) String() string
  • func (m *ShardSetFlushTimes) Unmarshal(dAtA []byte) error

Variables

var (
	ErrInvalidLengthFlush = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFlush   = fmt.Errorf("proto: integer overflow")
)

Types

type ForwardedFlushTimesForResolution

type ForwardedFlushTimesForResolution struct {
	ByNumForwardedTimes map[int32]int64 `` /* 205-byte string literal not displayed */
}

func (*ForwardedFlushTimesForResolution) Descriptor

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

func (*ForwardedFlushTimesForResolution) GetByNumForwardedTimes

func (m *ForwardedFlushTimesForResolution) GetByNumForwardedTimes() map[int32]int64

func (*ForwardedFlushTimesForResolution) Marshal

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

func (*ForwardedFlushTimesForResolution) MarshalTo

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

func (*ForwardedFlushTimesForResolution) ProtoMessage

func (*ForwardedFlushTimesForResolution) ProtoMessage()

func (*ForwardedFlushTimesForResolution) Reset

func (m *ForwardedFlushTimesForResolution) Reset()

func (*ForwardedFlushTimesForResolution) Size

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

func (*ForwardedFlushTimesForResolution) String

func (m *ForwardedFlushTimesForResolution) String() string

func (*ForwardedFlushTimesForResolution) Unmarshal

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

type ShardFlushTimes

type ShardFlushTimes struct {
	StandardByResolution  map[int64]int64                             `` /* 206-byte string literal not displayed */
	Tombstoned            bool                                        `protobuf:"varint,2,opt,name=tombstoned,proto3" json:"tombstoned,omitempty"`
	ForwardedByResolution map[int64]*ForwardedFlushTimesForResolution `` /* 201-byte string literal not displayed */
	TimedByResolution     map[int64]int64                             `` /* 197-byte string literal not displayed */
}

func (*ShardFlushTimes) Descriptor

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

func (*ShardFlushTimes) GetForwardedByResolution

func (m *ShardFlushTimes) GetForwardedByResolution() map[int64]*ForwardedFlushTimesForResolution

func (*ShardFlushTimes) GetStandardByResolution

func (m *ShardFlushTimes) GetStandardByResolution() map[int64]int64

func (*ShardFlushTimes) GetTimedByResolution

func (m *ShardFlushTimes) GetTimedByResolution() map[int64]int64

func (*ShardFlushTimes) GetTombstoned

func (m *ShardFlushTimes) GetTombstoned() bool

func (*ShardFlushTimes) Marshal

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

func (*ShardFlushTimes) MarshalTo

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

func (*ShardFlushTimes) ProtoMessage

func (*ShardFlushTimes) ProtoMessage()

func (*ShardFlushTimes) Reset

func (m *ShardFlushTimes) Reset()

func (*ShardFlushTimes) Size

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

func (*ShardFlushTimes) String

func (m *ShardFlushTimes) String() string

func (*ShardFlushTimes) Unmarshal

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

type ShardSetFlushTimes

type ShardSetFlushTimes struct {
	ByShard map[uint32]*ShardFlushTimes `` /* 157-byte string literal not displayed */
}

func (*ShardSetFlushTimes) Descriptor

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

func (*ShardSetFlushTimes) GetByShard

func (m *ShardSetFlushTimes) GetByShard() map[uint32]*ShardFlushTimes

func (*ShardSetFlushTimes) Marshal

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

func (*ShardSetFlushTimes) MarshalTo

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

func (*ShardSetFlushTimes) ProtoMessage

func (*ShardSetFlushTimes) ProtoMessage()

func (*ShardSetFlushTimes) Reset

func (m *ShardSetFlushTimes) Reset()

func (*ShardSetFlushTimes) Size

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

func (*ShardSetFlushTimes) String

func (m *ShardSetFlushTimes) String() string

func (*ShardSetFlushTimes) Unmarshal

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