v1

package
v0.0.21 Latest Latest
Warning

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

 Go to latest Published: Aug 15, 2023 License: AGPL-3.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	StorePrefix_name = map[int32]string{
		0: "SITES",
		1: "BLOCKS",
		2: "ALERTS",
	}
	StorePrefix_value = map[string]int32{
		"SITES":  0,
		"BLOCKS": 1,
		"ALERTS": 2,
	}
)

Enum value maps for StorePrefix.

View Source 
var (
	Op_name = map[int32]string{
		0: "equal",
		1: "not_equal",
		2: "greater",
		3: "greater_equal",
		4: "less",
		5: "less_equal",
	}
	Op_value = map[string]int32{
		"equal":         0,
		"not_equal":     1,
		"greater":       2,
		"greater_equal": 3,
		"less":          4,
		"less_equal":    5,
	}
)

Enum value maps for Op.

View Source 
var (
	Block_Key_Kind_name = map[int32]string{
		0: "METADATA",
		1: "INDEX",
	}
	Block_Key_Kind_value = map[string]int32{
		"METADATA": 0,
		"INDEX":    1,
	}
)

Enum value maps for Block_Key_Kind.

View Source 
var (
	Block_Index_Column_name = map[int32]string{
		0:  "Browser",
		1:  "BrowserVersion",
		2:  "City",
		3:  "Country",
		4:  "Domain",
		5:  "EntryPage",
		6:  "ExitPage",
		7:  "Host",
		8:  "Event",
		9:  "Os",
		10: "OsVersion",
		11: "Path",
		12: "Referrer",
		13: "ReferrerSource",
		14: "Region",
		15: "Screen",
		16: "UtmCampaign",
		17: "UtmContent",
		18: "UtmMedium",
		19: "UtmSource",
		20: "UtmTerm",
	}
	Block_Index_Column_value = map[string]int32{
		"Browser":        0,
		"BrowserVersion": 1,
		"City":           2,
		"Country":        3,
		"Domain":         4,
		"EntryPage":      5,
		"ExitPage":       6,
		"Host":           7,
		"Event":          8,
		"Os":             9,
		"OsVersion":      10,
		"Path":           11,
		"Referrer":       12,
		"ReferrerSource": 13,
		"Region":         14,
		"Screen":         15,
		"UtmCampaign":    16,
		"UtmContent":     17,
		"UtmMedium":      18,
		"UtmSource":      19,
		"UtmTerm":        20,
	}
)

Enum value maps for Block_Index_Column.

View Source 
var File_api_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Block 

type Block struct {

	// a ULID string identifier for this block.
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Smallest timestamp in milliseconds observed in this block
	Min int64 `protobuf:"varint,2,opt,name=min,proto3" json:"min,omitempty"`
	// Largest timestamp in milliseconds observed in this block.
	Max int64 `protobuf:"varint,3,opt,name=max,proto3" json:"max,omitempty"`
	// Size on bytes contained in this block
	Size int64 `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

Defines metadata about a single parquet file.

func (*Block) Descriptor deprecated 

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

Deprecated: Use Block.ProtoReflect.Descriptor instead.

func (*Block) GetId 

func (x *Block) GetId() []byte

func (*Block) GetMax 

func (x *Block) GetMax() int64

func (*Block) GetMin 

func (x *Block) GetMin() int64

func (*Block) GetSize 

func (x *Block) GetSize() int64

func (*Block) ProtoMessage 

func (*Block) ProtoMessage()

func (*Block) ProtoReflect 

func (x *Block) ProtoReflect() protoreflect.Message

func (*Block) Reset 

func (x *Block) Reset()

func (*Block) String 

func (x *Block) String() string

type Block_Index added in v0.0.19 

type Block_Index struct {
	Groups map[int32]*Block_Index_Bitmap `` /* 154-byte string literal not displayed */
	Min    int64                         `protobuf:"varint,2,opt,name=min,proto3" json:"min,omitempty"`
	Max    int64                         `protobuf:"varint,3,opt,name=max,proto3" json:"max,omitempty"`
	// contains filtered or unexported fields
}

func (*Block_Index) Descriptor deprecated added in v0.0.19 

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

Deprecated: Use Block_Index.ProtoReflect.Descriptor instead.

func (*Block_Index) GetGroups added in v0.0.19 

func (x *Block_Index) GetGroups() map[int32]*Block_Index_Bitmap

func (*Block_Index) GetMax added in v0.0.19 

func (x *Block_Index) GetMax() int64

func (*Block_Index) GetMin added in v0.0.19 

func (x *Block_Index) GetMin() int64

func (*Block_Index) ProtoMessage added in v0.0.19 

func (*Block_Index) ProtoMessage()

func (*Block_Index) ProtoReflect added in v0.0.19 

func (x *Block_Index) ProtoReflect() protoreflect.Message

func (*Block_Index) Reset added in v0.0.19 

func (x *Block_Index) Reset()

func (*Block_Index) String added in v0.0.19 

func (x *Block_Index) String() string

type Block_Index_Bitmap added in v0.0.19 

type Block_Index_Bitmap struct {
	Bitmap []byte `protobuf:"bytes,1,opt,name=bitmap,proto3" json:"bitmap,omitempty"`
	Min    int64  `protobuf:"varint,2,opt,name=min,proto3" json:"min,omitempty"`
	Max    int64  `protobuf:"varint,3,opt,name=max,proto3" json:"max,omitempty"`
	// contains filtered or unexported fields
}

func (*Block_Index_Bitmap) Descriptor deprecated added in v0.0.19 

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

Deprecated: Use Block_Index_Bitmap.ProtoReflect.Descriptor instead.

func (*Block_Index_Bitmap) GetBitmap added in v0.0.19 

func (x *Block_Index_Bitmap) GetBitmap() []byte

func (*Block_Index_Bitmap) GetMax added in v0.0.19 

func (x *Block_Index_Bitmap) GetMax() int64

func (*Block_Index_Bitmap) GetMin added in v0.0.19 

func (x *Block_Index_Bitmap) GetMin() int64

func (*Block_Index_Bitmap) ProtoMessage added in v0.0.19 

func (*Block_Index_Bitmap) ProtoMessage()

func (*Block_Index_Bitmap) ProtoReflect added in v0.0.19 

func (x *Block_Index_Bitmap) ProtoReflect() protoreflect.Message

func (*Block_Index_Bitmap) Reset added in v0.0.19 

func (x *Block_Index_Bitmap) Reset()

func (*Block_Index_Bitmap) String added in v0.0.19 

func (x *Block_Index_Bitmap) String() string

type Block_Index_BloomKey added in v0.0.19 

type Block_Index_BloomKey struct {
	Column Block_Index_Column `protobuf:"varint,1,opt,name=column,proto3,enum=v1.Block_Index_Column" json:"column,omitempty"`
	Value  string             `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Block_Index_BloomKey) Descriptor deprecated added in v0.0.19 

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

Deprecated: Use Block_Index_BloomKey.ProtoReflect.Descriptor instead.

func (*Block_Index_BloomKey) GetColumn added in v0.0.19 

func (x *Block_Index_BloomKey) GetColumn() Block_Index_Column

func (*Block_Index_BloomKey) GetValue added in v0.0.19 

func (x *Block_Index_BloomKey) GetValue() string

func (*Block_Index_BloomKey) ProtoMessage added in v0.0.19 

func (*Block_Index_BloomKey) ProtoMessage()

func (*Block_Index_BloomKey) ProtoReflect added in v0.0.19 

func (x *Block_Index_BloomKey) ProtoReflect() protoreflect.Message

func (*Block_Index_BloomKey) Reset added in v0.0.19 

func (x *Block_Index_BloomKey) Reset()

func (*Block_Index_BloomKey) String added in v0.0.19 

func (x *Block_Index_BloomKey) String() string

type Block_Index_Column added in v0.0.19 

type Block_Index_Column int32
const (
	Block_Index_Browser        Block_Index_Column = 0
	Block_Index_BrowserVersion Block_Index_Column = 1
	Block_Index_City           Block_Index_Column = 2
	Block_Index_Country        Block_Index_Column = 3
	Block_Index_Domain         Block_Index_Column = 4
	Block_Index_EntryPage      Block_Index_Column = 5
	Block_Index_ExitPage       Block_Index_Column = 6
	Block_Index_Host           Block_Index_Column = 7
	Block_Index_Event          Block_Index_Column = 8
	Block_Index_Os             Block_Index_Column = 9
	Block_Index_OsVersion      Block_Index_Column = 10
	Block_Index_Path           Block_Index_Column = 11
	Block_Index_Referrer       Block_Index_Column = 12
	Block_Index_ReferrerSource Block_Index_Column = 13
	Block_Index_Region         Block_Index_Column = 14
	Block_Index_Screen         Block_Index_Column = 15
	Block_Index_UtmCampaign    Block_Index_Column = 16
	Block_Index_UtmContent     Block_Index_Column = 17
	Block_Index_UtmMedium      Block_Index_Column = 18
	Block_Index_UtmSource      Block_Index_Column = 19
	Block_Index_UtmTerm        Block_Index_Column = 20
)

func (Block_Index_Column) Descriptor added in v0.0.19 

func (Block_Index_Column) Descriptor() protoreflect.EnumDescriptor

func (Block_Index_Column) Enum added in v0.0.19 

func (x Block_Index_Column) Enum() *Block_Index_Column

func (Block_Index_Column) EnumDescriptor deprecated added in v0.0.19 

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

Deprecated: Use Block_Index_Column.Descriptor instead.

func (Block_Index_Column) Number added in v0.0.19 

func (x Block_Index_Column) Number() protoreflect.EnumNumber

func (Block_Index_Column) String added in v0.0.19 

func (x Block_Index_Column) String() string

func (Block_Index_Column) Type added in v0.0.19 

func (Block_Index_Column) Type() protoreflect.EnumType

type Block_Key added in v0.0.19 

type Block_Key struct {
	Kind   Block_Key_Kind `protobuf:"varint,1,opt,name=kind,proto3,enum=v1.Block_Key_Kind" json:"kind,omitempty"`
	Domain string         `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	Uid    string         `protobuf:"bytes,3,opt,name=uid,proto3" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

func (*Block_Key) Badger added in v0.0.19 

func (s *Block_Key) Badger() string

func (*Block_Key) Descriptor deprecated added in v0.0.19 

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

Deprecated: Use Block_Key.ProtoReflect.Descriptor instead.

func (*Block_Key) GetDomain added in v0.0.19 

func (x *Block_Key) GetDomain() string

func (*Block_Key) GetKind added in v0.0.19 

func (x *Block_Key) GetKind() Block_Key_Kind

func (*Block_Key) GetUid added in v0.0.19 

func (x *Block_Key) GetUid() string

func (*Block_Key) ProtoMessage added in v0.0.19 

func (*Block_Key) ProtoMessage()

func (*Block_Key) ProtoReflect added in v0.0.19 

func (x *Block_Key) ProtoReflect() protoreflect.Message

func (*Block_Key) Reset added in v0.0.19 

func (x *Block_Key) Reset()

func (*Block_Key) String added in v0.0.19 

func (x *Block_Key) String() string

type Block_Key_Kind added in v0.0.19 

type Block_Key_Kind int32
const (
	Block_Key_METADATA Block_Key_Kind = 0
	Block_Key_INDEX    Block_Key_Kind = 1
)

func (Block_Key_Kind) Descriptor added in v0.0.19 

func (Block_Key_Kind) Descriptor() protoreflect.EnumDescriptor

func (Block_Key_Kind) Enum added in v0.0.19 

func (x Block_Key_Kind) Enum() *Block_Key_Kind

func (Block_Key_Kind) EnumDescriptor deprecated added in v0.0.19 

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

Deprecated: Use Block_Key_Kind.Descriptor instead.

func (Block_Key_Kind) Number added in v0.0.19 

func (x Block_Key_Kind) Number() protoreflect.EnumNumber

func (Block_Key_Kind) String added in v0.0.19 

func (x Block_Key_Kind) String() string

func (Block_Key_Kind) Type added in v0.0.19 

func (Block_Key_Kind) Type() protoreflect.EnumType

type Build added in v0.0.21 

type Build struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*Build) Descriptor deprecated added in v0.0.21 

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

Deprecated: Use Build.ProtoReflect.Descriptor instead.

func (*Build) GetVersion added in v0.0.21 

func (x *Build) GetVersion() string

func (*Build) ProtoMessage added in v0.0.21 

func (*Build) ProtoMessage()

func (*Build) ProtoReflect added in v0.0.21 

func (x *Build) ProtoReflect() protoreflect.Message

func (*Build) Reset added in v0.0.21 

func (x *Build) Reset()

func (*Build) String added in v0.0.21 

func (x *Build) String() string

type Config added in v0.0.21 

type Config struct {

	// Path to the directory which is used to store metadata. This directory  is
	// managed by  badger key/value store. WHich is used to store all metadata
	// regarding sites events.
	//
	// Metadata includes
	//   - Registered sites
	//   - Blocks metadata
	//   - Blocks indexes
	MetaPath string `protobuf:"bytes,1,opt,name=meta_path,json=metaPath,proto3" json:"meta_path,omitempty"`
	// Path to where block files are stored. Blocks are stored as files with ULID
	// as filenames
	BlocksPath string `protobuf:"bytes,2,opt,name=blocks_path,json=blocksPath,proto3" json:"blocks_path,omitempty"`
	// host:port to bind for http api. This is used by serve command. The server
	// serves ui console
	ListenAddress string `protobuf:"bytes,3,opt,name=listen_address,json=listenAddress,proto3" json:"listen_address,omitempty"`
	// Control how much is logged options are
	// trace,debug,info,warn,error,fatal,panic
	LogLevel string `protobuf:"bytes,4,opt,name=log_level,json=logLevel,proto3" json:"log_level,omitempty"`
	// Interval for syncing buffered entries. By default events are buffered and
	// periodically saved.
	SyncInterval *durationpb.Duration `protobuf:"bytes,5,opt,name=sync_interval,json=syncInterval,proto3" json:"sync_interval,omitempty"`
	// Expose /debug/pprof endpoint when serving
	EnableProfile bool `protobuf:"varint,6,opt,name=enable_profile,json=enableProfile,proto3" json:"enable_profile,omitempty"`
	// contains filtered or unexported fields
}

Configuration object for vince instance

func (*Config) Descriptor deprecated added in v0.0.21 

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetBlocksPath added in v0.0.21 

func (x *Config) GetBlocksPath() string

func (*Config) GetEnableProfile added in v0.0.21 

func (x *Config) GetEnableProfile() bool

func (*Config) GetListenAddress added in v0.0.21 

func (x *Config) GetListenAddress() string

func (*Config) GetLogLevel added in v0.0.21 

func (x *Config) GetLogLevel() string

func (*Config) GetMetaPath added in v0.0.21 

func (x *Config) GetMetaPath() string

func (*Config) GetSyncInterval added in v0.0.21 

func (x *Config) GetSyncInterval() *durationpb.Duration

func (*Config) ProtoMessage added in v0.0.21 

func (*Config) ProtoMessage()

func (*Config) ProtoReflect added in v0.0.21 

func (x *Config) ProtoReflect() protoreflect.Message

func (*Config) Reset added in v0.0.21 

func (x *Config) Reset()

func (*Config) String added in v0.0.21 

func (x *Config) String() string

type Filter 

type Filter struct {
	Column string `protobuf:"bytes,1,opt,name=column,proto3" json:"column,omitempty"`
	Op     Op     `protobuf:"varint,2,opt,name=op,proto3,enum=v1.Op" json:"op,omitempty"`
	// Types that are assignable to Value:
	//
	//	*Filter_Str
	//	*Filter_Timestamp
	//	*Filter_Duration
	Value isFilter_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*Filter) Descriptor deprecated 

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

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetColumn 

func (x *Filter) GetColumn() string

func (*Filter) GetDuration 

func (x *Filter) GetDuration() int64

func (*Filter) GetOp 

func (x *Filter) GetOp() Op

func (*Filter) GetStr 

func (x *Filter) GetStr() string

func (*Filter) GetTimestamp 

func (x *Filter) GetTimestamp() int64

func (*Filter) GetValue 

func (m *Filter) GetValue() isFilter_Value

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect 

func (x *Filter) ProtoReflect() protoreflect.Message

func (*Filter) Reset 

func (x *Filter) Reset()

func (*Filter) String 

func (x *Filter) String() string

type Filter_Duration 

type Filter_Duration struct {
	Duration int64 `protobuf:"varint,5,opt,name=duration,proto3,oneof"`
}

type Filter_Str 

type Filter_Str struct {
	Str string `protobuf:"bytes,3,opt,name=str,proto3,oneof"`
}

type Filter_Timestamp 

type Filter_Timestamp struct {
	Timestamp int64 `protobuf:"varint,4,opt,name=timestamp,proto3,oneof"`
}

type Metadata 

type Metadata struct {
	Blocks []*Block `protobuf:"bytes,1,rep,name=blocks,proto3" json:"blocks,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata) Descriptor deprecated 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetBlocks 

func (x *Metadata) GetBlocks() []*Block

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

func (x *Metadata) ProtoReflect() protoreflect.Message

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) String 

func (x *Metadata) String() string

type Op 

type Op int32
const (
	Op_equal         Op = 0
	Op_not_equal     Op = 1
	Op_greater       Op = 2
	Op_greater_equal Op = 3
	Op_less          Op = 4
	Op_less_equal    Op = 5
)

func (Op) Descriptor 

func (Op) Descriptor() protoreflect.EnumDescriptor

func (Op) Enum 

func (x Op) Enum() *Op

func (Op) EnumDescriptor deprecated 

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

Deprecated: Use Op.Descriptor instead.

func (Op) Number 

func (x Op) Number() protoreflect.EnumNumber

func (Op) String 

func (x Op) String() string

func (Op) Type 

func (Op) Type() protoreflect.EnumType

type Site 

type Site struct {
	Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	// contains filtered or unexported fields
}

func (*Site) Descriptor deprecated 

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

Deprecated: Use Site.ProtoReflect.Descriptor instead.

func (*Site) GetDomain added in v0.0.19 

func (x *Site) GetDomain() string

func (*Site) ProtoMessage 

func (*Site) ProtoMessage()

func (*Site) ProtoReflect 

func (x *Site) ProtoReflect() protoreflect.Message

func (*Site) Reset 

func (x *Site) Reset()

func (*Site) String 

func (x *Site) String() string

type Site_List added in v0.0.21 

type Site_List struct {
	List []*Site `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

func (*Site_List) Descriptor deprecated added in v0.0.21 

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

Deprecated: Use Site_List.ProtoReflect.Descriptor instead.

func (*Site_List) GetList added in v0.0.21 

func (x *Site_List) GetList() []*Site

func (*Site_List) ProtoMessage added in v0.0.21 

func (*Site_List) ProtoMessage()

func (*Site_List) ProtoReflect added in v0.0.21 

func (x *Site_List) ProtoReflect() protoreflect.Message

func (*Site_List) Reset added in v0.0.21 

func (x *Site_List) Reset()

func (*Site_List) String added in v0.0.21 

func (x *Site_List) String() string

type Status added in v0.0.21 

type Status struct {
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated added in v0.0.21 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) ProtoMessage added in v0.0.21 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect added in v0.0.21 

func (x *Status) ProtoReflect() protoreflect.Message

func (*Status) Reset added in v0.0.21 

func (x *Status) Reset()

func (*Status) String added in v0.0.21 

func (x *Status) String() string

type StoreKey 

type StoreKey struct {
	Namespace string      `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Prefix    StorePrefix `protobuf:"varint,2,opt,name=prefix,proto3,enum=v1.StorePrefix" json:"prefix,omitempty"`
	Key       string      `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreKey) Badger added in v0.0.19 

func (s *StoreKey) Badger() string

func (*StoreKey) Descriptor deprecated 

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

Deprecated: Use StoreKey.ProtoReflect.Descriptor instead.

func (*StoreKey) GetKey 

func (x *StoreKey) GetKey() string

func (*StoreKey) GetNamespace 

func (x *StoreKey) GetNamespace() string

func (*StoreKey) GetPrefix 

func (x *StoreKey) GetPrefix() StorePrefix

func (*StoreKey) ProtoMessage 

func (*StoreKey) ProtoMessage()

func (*StoreKey) ProtoReflect 

func (x *StoreKey) ProtoReflect() protoreflect.Message

func (*StoreKey) Reset 

func (x *StoreKey) Reset()

func (*StoreKey) String 

func (x *StoreKey) String() string

type StorePrefix 

type StorePrefix int32

StorePrefix defines different kind of data we are storing in the key value store. 

const (
	StorePrefix_SITES  StorePrefix = 0
	StorePrefix_BLOCKS StorePrefix = 1
	StorePrefix_ALERTS StorePrefix = 2
)

func (StorePrefix) Descriptor 

func (StorePrefix) Descriptor() protoreflect.EnumDescriptor

func (StorePrefix) Enum 

func (x StorePrefix) Enum() *StorePrefix

func (StorePrefix) EnumDescriptor deprecated 

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

Deprecated: Use StorePrefix.Descriptor instead.

func (StorePrefix) Number 

func (x StorePrefix) Number() protoreflect.EnumNumber

func (StorePrefix) String 

func (x StorePrefix) String() string

func (StorePrefix) Type 

func (StorePrefix) Type() protoreflect.EnumType

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.