Versions in this module Expand all Collapse all v4 v4.15.3 Nov 27, 2018 v4.15.0 Aug 21, 2018 Changes in this version + const LatestVersion + var ErrorClusterDegraded = &CodedError + var ErrorDisconnected = &CodedError + var ErrorWrongArgs = &CodedError + func EndpointsFromEnv() []string + func OptKV(iz ...interface{}) map[string]*string + type AnnotationVersion uint64 + type BTrDB struct + func Connect(ctx context.Context, endpoints ...string) (*BTrDB, error) + func ConnectAuth(ctx context.Context, apikey string, endpoints ...string) (*BTrDB, error) + func (b *BTrDB) Create(ctx context.Context, uu uuid.UUID, collection string, tags map[string]string, ...) (*Stream, error) + func (b *BTrDB) Disconnect() error + func (b *BTrDB) EndpointFor(ctx context.Context, uuid uuid.UUID) (*Endpoint, error) + func (b *BTrDB) EndpointForHash(ctx context.Context, hash uint32) (*Endpoint, error) + func (b *BTrDB) GetAnyEndpoint(ctx context.Context) (*Endpoint, error) + func (b *BTrDB) GetMetadataUsage(ctx context.Context, prefix string) (tags map[string]int, annotations map[string]int, err error) + func (b *BTrDB) Info(ctx context.Context) (*MASH, error) + func (b *BTrDB) ListAllCollections(ctx context.Context) ([]string, error) + func (b *BTrDB) ListCollections(ctx context.Context, prefix string) ([]string, error) + func (b *BTrDB) LookupStreams(ctx context.Context, collection string, isCollectionPrefix bool, ...) ([]*Stream, error) + func (b *BTrDB) ReadEndpointFor(ctx context.Context, uuid uuid.UUID) (*Endpoint, error) + func (b *BTrDB) ResyncMash() + func (b *BTrDB) SnoopEpErr(ep *Endpoint, err chan error) chan error + func (b *BTrDB) StreamFromUUID(uu uuid.UUID) *Stream + func (b *BTrDB) StreamingLookupStreams(ctx context.Context, collection string, isCollectionPrefix bool, ...) (chan *Stream, chan error) + func (b *BTrDB) TestEpError(ep *Endpoint, err error) bool + type ChangedRange struct + End int64 + Start int64 + Version uint64 + type CodedError struct + func ToCodedError(e error) *CodedError + func (ce *CodedError) Error() string + type Endpoint struct + func ConnectEndpoint(ctx context.Context, addresses ...string) (*Endpoint, error) + func ConnectEndpointAuth(ctx context.Context, apikey string, addresses ...string) (*Endpoint, error) + func (b *Endpoint) AlignedWindows(ctx context.Context, uu uuid.UUID, start int64, end int64, pointwidth uint8, ...) (chan StatPoint, chan uint64, chan error) + func (b *Endpoint) Changes(ctx context.Context, uu uuid.UUID, fromVersion uint64, toVersion uint64, ...) (chan ChangedRange, chan uint64, chan error) + func (b *Endpoint) Create(ctx context.Context, uu uuid.UUID, collection string, tags map[string]string, ...) error + func (b *Endpoint) DeleteRange(ctx context.Context, uu uuid.UUID, start int64, end int64) (uint64, error) + func (b *Endpoint) Disconnect() error + func (b *Endpoint) FaultInject(ctx context.Context, typ uint64, args []byte) ([]byte, error) + func (b *Endpoint) Flush(ctx context.Context, uu uuid.UUID) error + func (b *Endpoint) GetGRPC() pb.BTrDBClient + func (b *Endpoint) GetMetadataUsage(ctx context.Context, prefix string) (tags map[string]int, annotations map[string]int, err error) + func (b *Endpoint) Info(ctx context.Context) (*MASH, *pb.InfoResponse, error) + func (b *Endpoint) Insert(ctx context.Context, uu uuid.UUID, values []*pb.RawPoint) error + func (b *Endpoint) ListAllCollections(ctx context.Context) ([]string, error) + func (b *Endpoint) ListCollections(ctx context.Context, prefix string, from string, limit uint64) ([]string, error) + func (b *Endpoint) LookupStreams(ctx context.Context, collection string, isCollectionPrefix bool, ...) (chan *Stream, chan error) + func (b *Endpoint) Nearest(ctx context.Context, uu uuid.UUID, time int64, version uint64, backward bool) (RawPoint, uint64, error) + func (b *Endpoint) Obliterate(ctx context.Context, uu uuid.UUID) error + func (b *Endpoint) RawValues(ctx context.Context, uu uuid.UUID, start int64, end int64, version uint64) (chan RawPoint, chan uint64, chan error) + func (b *Endpoint) SetStreamAnnotations(ctx context.Context, uu uuid.UUID, expected AnnotationVersion, ...) error + func (b *Endpoint) StreamInfo(ctx context.Context, uu uuid.UUID, omitDescriptor bool, omitVersion bool) (collection string, aver AnnotationVersion, tags map[string]string, ...) + func (b *Endpoint) Windows(ctx context.Context, uu uuid.UUID, start int64, end int64, width uint64, ...) (chan StatPoint, chan uint64, chan error) + type M map[string]string + type MASH struct + func (m *MASH) EndpointFor(uuid uuid.UUID) (found bool, hash uint32, addrs []string) + type RawPoint struct + Time int64 + Value float64 + type StatPoint struct + Count uint64 + Max float64 + Mean float64 + Min float64 + Time int64 + type Stream struct + func (s *Stream) AlignedWindows(ctx context.Context, start int64, end int64, pointwidth uint8, version uint64) (chan StatPoint, chan uint64, chan error) + func (s *Stream) Annotations(ctx context.Context) (map[string]string, AnnotationVersion, error) + func (s *Stream) CachedAnnotations(ctx context.Context) (map[string]string, AnnotationVersion, error) + func (s *Stream) Changes(ctx context.Context, fromVersion uint64, toVersion uint64, resolution uint8) (crv chan ChangedRange, cver chan uint64, cerr chan error) + func (s *Stream) Collection(ctx context.Context) (string, error) + func (s *Stream) CompareAndSetAnnotation(ctx context.Context, expected AnnotationVersion, changes map[string]*string) error + func (s *Stream) DeleteRange(ctx context.Context, start int64, end int64) (ver uint64, err error) + func (s *Stream) Exists(ctx context.Context) (bool, error) + func (s *Stream) Flush(ctx context.Context) error + func (s *Stream) Insert(ctx context.Context, vals []RawPoint) error + func (s *Stream) InsertF(ctx context.Context, length int, time func(int) int64, val func(int) float64) error + func (s *Stream) InsertTV(ctx context.Context, times []int64, values []float64) error + func (s *Stream) Nearest(ctx context.Context, time int64, version uint64, backward bool) (rv RawPoint, ver uint64, err error) + func (s *Stream) Obliterate(ctx context.Context) error + func (s *Stream) RawValues(ctx context.Context, start int64, end int64, version uint64) (chan RawPoint, chan uint64, chan error) + func (s *Stream) Tags(ctx context.Context) (map[string]string, error) + func (s *Stream) UUID() uuid.UUID + func (s *Stream) Version(ctx context.Context) (uint64, error) + func (s *Stream) Windows(ctx context.Context, start int64, end int64, width uint64, depth uint8, ...) (chan StatPoint, chan uint64, chan error) Other modules containing this package gopkg.in/BTrDB/btrdb.v5
Go to main page