flush

package
v0.9.0 Latest Latest
Warning

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

Go to latest
Published: May 6, 2019 License: Apache-2.0 Imports: 4 Imported by: 2

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

Constants

This section is empty.

Variables

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

Functions

This section is empty.

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 (*ForwardedFlushTimesForResolution) Size

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

func (*ForwardedFlushTimesForResolution) 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL