v1

package
v0.0.64 Latest Latest
Warning

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

 Go to latest Published: Mar 3, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	RaftTransport_AppendEntriesPipeline_FullMethodName = "/v1.RaftTransport/AppendEntriesPipeline"
	RaftTransport_AppendEntries_FullMethodName         = "/v1.RaftTransport/AppendEntries"
	RaftTransport_RequestVote_FullMethodName           = "/v1.RaftTransport/RequestVote"
	RaftTransport_TimeoutNow_FullMethodName            = "/v1.RaftTransport/TimeoutNow"
	RaftTransport_InstallSnapshot_FullMethodName       = "/v1.RaftTransport/InstallSnapshot"
)
View Source 
const (
	InternalCLuster_Join_FullMethodName       = "/v1.InternalCLuster/Join"
	InternalCLuster_Load_FullMethodName       = "/v1.InternalCLuster/Load"
	InternalCLuster_Backup_FullMethodName     = "/v1.InternalCLuster/Backup"
	InternalCLuster_RemoveNode_FullMethodName = "/v1.InternalCLuster/RemoveNode"
	InternalCLuster_Notify_FullMethodName     = "/v1.InternalCLuster/Notify"
	InternalCLuster_NodeAPI_FullMethodName    = "/v1.InternalCLuster/NodeAPI"
	InternalCLuster_SendData_FullMethodName   = "/v1.InternalCLuster/SendData"
	InternalCLuster_Realtime_FullMethodName   = "/v1.InternalCLuster/Realtime"
	InternalCLuster_Aggregate_FullMethodName  = "/v1.InternalCLuster/Aggregate"
	InternalCLuster_Timeseries_FullMethodName = "/v1.InternalCLuster/Timeseries"
	InternalCLuster_BreakDown_FullMethodName  = "/v1.InternalCLuster/BreakDown"
)

Variables

View Source 
var (
	Credential_Permission_name = map[int32]string{
		0:  "ALL",
		2:  "JOIN",
		3:  "JOIN_READ_ONLY",
		4:  "QUERY",
		5:  "STATUS",
		6:  "READY",
		7:  "BACKUP",
		8:  "LOAD",
		9:  "REMOVE",
		10: "DATA",
		11: "NODE_API",
		12: "NOTIFY",
	}
	Credential_Permission_value = map[string]int32{
		"ALL":            0,
		"JOIN":           2,
		"JOIN_READ_ONLY": 3,
		"QUERY":          4,
		"STATUS":         5,
		"READY":          6,
		"BACKUP":         7,
		"LOAD":           8,
		"REMOVE":         9,
		"DATA":           10,
		"NODE_API":       11,
		"NOTIFY":         12,
	}
)

Enum value maps for Credential_Permission.

View Source 
var (
	Server_Suffrage_name = map[int32]string{
		0: "Voter",
		1: "NotVoter",
		2: "Staging",
	}
	Server_Suffrage_value = map[string]int32{
		"Voter":    0,
		"NotVoter": 1,
		"Staging":  2,
	}
)

Enum value maps for Server_Suffrage.

View Source 
var (
	Log_LogType_name = map[int32]string{
		0: "LOG_COMMAND",
		1: "LOG_NOOP",
		2: "LOG_ADD_PEER_DEPRECATED",
		3: "LOG_REMOVE_PEER_DEPRECATED",
		4: "LOG_BARRIER",
		5: "LOG_CONFIGURATION",
	}
	Log_LogType_value = map[string]int32{
		"LOG_COMMAND":                0,
		"LOG_NOOP":                   1,
		"LOG_ADD_PEER_DEPRECATED":    2,
		"LOG_REMOVE_PEER_DEPRECATED": 3,
		"LOG_BARRIER":                4,
		"LOG_CONFIGURATION":          5,
	}
)

Enum value maps for Log_LogType.

View Source 
var (
	Interval_name = map[int32]string{
		0: "date",
		1: "minute",
		2: "hour",
		3: "week",
		4: "month",
	}
	Interval_value = map[string]int32{
		"date":   0,
		"minute": 1,
		"hour":   2,
		"week":   3,
		"month":  4,
	}
)

Enum value maps for Interval.

View Source 
var (
	Metric_name = map[int32]string{
		0: "unknown_metric",
		1: "visitors",
		2: "visits",
		3: "pageviews",
		4: "views_per_visit",
		5: "bounce_rate",
		6: "visit_duration",
		7: "events",
	}
	Metric_value = map[string]int32{
		"unknown_metric":  0,
		"visitors":        1,
		"visits":          2,
		"pageviews":       3,
		"views_per_visit": 4,
		"bounce_rate":     5,
		"visit_duration":  6,
		"events":          7,
	}
)

Enum value maps for Metric.

View Source 
var (
	Property_name = map[int32]string{
		0:  "event",
		7:  "browser",
		8:  "browser_version",
		9:  "city",
		10: "country",
		11: "device",
		12: "domain",
		13: "entry_page",
		15: "exit_page",
		16: "host",
		17: "os",
		18: "os_version",
		19: "page",
		20: "referrer",
		21: "region",
		22: "source",
		23: "tenant_id",
		24: "utm_campaign",
		25: "utm_content",
		26: "utm_medium",
		27: "utm_source",
		28: "utm_term",
	}
	Property_value = map[string]int32{
		"event":           0,
		"browser":         7,
		"browser_version": 8,
		"city":            9,
		"country":         10,
		"device":          11,
		"domain":          12,
		"entry_page":      13,
		"exit_page":       15,
		"host":            16,
		"os":              17,
		"os_version":      18,
		"page":            19,
		"referrer":        20,
		"region":          21,
		"source":          22,
		"tenant_id":       23,
		"utm_campaign":    24,
		"utm_content":     25,
		"utm_medium":      26,
		"utm_source":      27,
		"utm_term":        28,
	}
)

Enum value maps for Property.

View Source 
var (
	TimePeriod_Base_name = map[int32]string{
		0: "day",
		1: "_7d",
		3: "_30d",
		4: "mo",
		5: "_6mo",
		6: "_12mo",
		7: "year",
	}
	TimePeriod_Base_value = map[string]int32{
		"day":   0,
		"_7d":   1,
		"_30d":  3,
		"mo":    4,
		"_6mo":  5,
		"_12mo": 6,
		"year":  7,
	}
)

Enum value maps for TimePeriod_Base.

View Source 
var (
	Filters_Projection_name = map[int32]string{
		0:  "unknown",
		1:  "timestamp",
		2:  "id",
		3:  "bounce",
		4:  "session",
		5:  "view",
		6:  "duration",
		7:  "browser",
		8:  "browser_version",
		9:  "city",
		10: "country",
		11: "device",
		12: "domain",
		13: "entry_page",
		14: "event",
		15: "exit_page",
		16: "host",
		17: "os",
		18: "os_version",
		19: "page",
		20: "referrer",
		21: "region",
		22: "source",
		23: "tenant_id",
		24: "utm_campaign",
		25: "utm_content",
		26: "utm_medium",
		27: "utm_source",
		28: "utm_term",
	}
	Filters_Projection_value = map[string]int32{
		"unknown":         0,
		"timestamp":       1,
		"id":              2,
		"bounce":          3,
		"session":         4,
		"view":            5,
		"duration":        6,
		"browser":         7,
		"browser_version": 8,
		"city":            9,
		"country":         10,
		"device":          11,
		"domain":          12,
		"entry_page":      13,
		"event":           14,
		"exit_page":       15,
		"host":            16,
		"os":              17,
		"os_version":      18,
		"page":            19,
		"referrer":        20,
		"region":          21,
		"source":          22,
		"tenant_id":       23,
		"utm_campaign":    24,
		"utm_content":     25,
		"utm_medium":      26,
		"utm_source":      27,
		"utm_term":        28,
	}
)

Enum value maps for Filters_Projection.

View Source 
var (
	Filter_OP_name = map[int32]string{
		0: "equal",
		1: "not_equal",
		2: "re_equal",
		3: "re_not_equal",
	}
	Filter_OP_value = map[string]int32{
		"equal":        0,
		"not_equal":    1,
		"re_equal":     2,
		"re_not_equal": 3,
	}
)

Enum value maps for Filter_OP.

View Source 
var File_vince_v1_auth_proto protoreflect.FileDescriptor
View Source 
var File_vince_v1_config_proto protoreflect.FileDescriptor
View Source 
var File_vince_v1_events_proto protoreflect.FileDescriptor
View Source 
var File_vince_v1_raft_proto protoreflect.FileDescriptor
View Source 
var File_vince_v1_status_proto protoreflect.FileDescriptor
View Source 
var File_vince_v1_store_proto protoreflect.FileDescriptor
View Source 
var File_vince_v1_transport_proto protoreflect.FileDescriptor
View Source 
var File_vince_v1_vince_proto protoreflect.FileDescriptor
View Source 
var InternalCLuster_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.InternalCLuster",
	HandlerType: (*InternalCLusterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Join",
			Handler:    _InternalCLuster_Join_Handler,
		},
		{
			MethodName: "Load",
			Handler:    _InternalCLuster_Load_Handler,
		},
		{
			MethodName: "RemoveNode",
			Handler:    _InternalCLuster_RemoveNode_Handler,
		},
		{
			MethodName: "Notify",
			Handler:    _InternalCLuster_Notify_Handler,
		},
		{
			MethodName: "NodeAPI",
			Handler:    _InternalCLuster_NodeAPI_Handler,
		},
		{
			MethodName: "SendData",
			Handler:    _InternalCLuster_SendData_Handler,
		},
		{
			MethodName: "Realtime",
			Handler:    _InternalCLuster_Realtime_Handler,
		},
		{
			MethodName: "Aggregate",
			Handler:    _InternalCLuster_Aggregate_Handler,
		},
		{
			MethodName: "Timeseries",
			Handler:    _InternalCLuster_Timeseries_Handler,
		},
		{
			MethodName: "BreakDown",
			Handler:    _InternalCLuster_BreakDown_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Backup",
			Handler:       _InternalCLuster_Backup_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "vince/v1/vince.proto",
}

InternalCLuster_ServiceDesc is the grpc.ServiceDesc for InternalCLuster service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var RaftTransport_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.RaftTransport",
	HandlerType: (*RaftTransportServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AppendEntries",
			Handler:    _RaftTransport_AppendEntries_Handler,
		},
		{
			MethodName: "RequestVote",
			Handler:    _RaftTransport_RequestVote_Handler,
		},
		{
			MethodName: "TimeoutNow",
			Handler:    _RaftTransport_TimeoutNow_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "AppendEntriesPipeline",
			Handler:       _RaftTransport_AppendEntriesPipeline_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "InstallSnapshot",
			Handler:       _RaftTransport_InstallSnapshot_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "vince/v1/transport.proto",
}

RaftTransport_ServiceDesc is the grpc.ServiceDesc for RaftTransport service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterInternalCLusterServer 

func RegisterInternalCLusterServer(s grpc.ServiceRegistrar, srv InternalCLusterServer)

func RegisterRaftTransportServer 

func RegisterRaftTransportServer(s grpc.ServiceRegistrar, srv RaftTransportServer)

Types

type Acme 

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

func (*Acme) Descriptor deprecated 

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

Deprecated: Use Acme.ProtoReflect.Descriptor instead.

func (*Acme) GetDomain 

func (x *Acme) GetDomain() string

func (*Acme) GetEmail 

func (x *Acme) GetEmail() string

func (*Acme) ProtoMessage 

func (*Acme) ProtoMessage()

func (*Acme) ProtoReflect 

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

func (*Acme) Reset 

func (x *Acme) Reset()

func (*Acme) String 

func (x *Acme) String() string

type Aggregate 

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

func (*Aggregate) Descriptor deprecated 

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

Deprecated: Use Aggregate.ProtoReflect.Descriptor instead.

func (*Aggregate) ProtoMessage 

func (*Aggregate) ProtoMessage()

func (*Aggregate) ProtoReflect 

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

func (*Aggregate) Reset 

func (x *Aggregate) Reset()

func (*Aggregate) String 

func (x *Aggregate) String() string

type Aggregate_Request 

type Aggregate_Request struct {
	SiteId   string                 `protobuf:"bytes,1,opt,name=site_id,json=siteId,proto3" json:"site_id,omitempty"`
	TenantId string                 `protobuf:"bytes,2,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Period   *TimePeriod            `protobuf:"bytes,3,opt,name=period,proto3" json:"period,omitempty"`
	Metrics  []Metric               `protobuf:"varint,4,rep,packed,name=metrics,proto3,enum=v1.Metric" json:"metrics,omitempty"`
	Filters  []*Filter              `protobuf:"bytes,6,rep,name=filters,proto3" json:"filters,omitempty"`
	Date     *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=date,proto3" json:"date,omitempty"`
	// contains filtered or unexported fields
}

func (*Aggregate_Request) Descriptor deprecated 

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

Deprecated: Use Aggregate_Request.ProtoReflect.Descriptor instead.

func (*Aggregate_Request) GetDate 

func (x *Aggregate_Request) GetDate() *timestamppb.Timestamp

func (*Aggregate_Request) GetFilters 

func (x *Aggregate_Request) GetFilters() []*Filter

func (*Aggregate_Request) GetMetrics 

func (x *Aggregate_Request) GetMetrics() []Metric

func (*Aggregate_Request) GetPeriod 

func (x *Aggregate_Request) GetPeriod() *TimePeriod

func (*Aggregate_Request) GetSiteId 

func (x *Aggregate_Request) GetSiteId() string

func (*Aggregate_Request) GetTenantId 

func (x *Aggregate_Request) GetTenantId() string

func (*Aggregate_Request) ProtoMessage 

func (*Aggregate_Request) ProtoMessage()

func (*Aggregate_Request) ProtoReflect 

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

func (*Aggregate_Request) Reset 

func (x *Aggregate_Request) Reset()

func (*Aggregate_Request) String 

func (x *Aggregate_Request) String() string

type Aggregate_Response 

type Aggregate_Response struct {

	// Mappping of metric to metric value. We can't use enums as map keys that
	// is why we use string here.
	Results map[string]float64 `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Aggregate_Response) Descriptor deprecated 

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

Deprecated: Use Aggregate_Response.ProtoReflect.Descriptor instead.

func (*Aggregate_Response) GetResults 

func (x *Aggregate_Response) GetResults() map[string]float64

func (*Aggregate_Response) ProtoMessage 

func (*Aggregate_Response) ProtoMessage()

func (*Aggregate_Response) ProtoReflect 

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

func (*Aggregate_Response) Reset 

func (x *Aggregate_Response) Reset()

func (*Aggregate_Response) String 

func (x *Aggregate_Response) String() string

type AppendEntriesRequest 

type AppendEntriesRequest struct {
	RpcHeader         *RPCHeader `protobuf:"bytes,1,opt,name=rpc_header,json=rpcHeader,proto3" json:"rpc_header,omitempty"`
	Term              uint64     `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
	Leader            []byte     `protobuf:"bytes,3,opt,name=leader,proto3" json:"leader,omitempty"`
	PrevLogEntry      uint64     `protobuf:"varint,4,opt,name=prev_log_entry,json=prevLogEntry,proto3" json:"prev_log_entry,omitempty"`
	PrevLogTerm       uint64     `protobuf:"varint,5,opt,name=prev_log_term,json=prevLogTerm,proto3" json:"prev_log_term,omitempty"`
	Entries           []*Log     `protobuf:"bytes,6,rep,name=entries,proto3" json:"entries,omitempty"`
	LeaderCommitIndex uint64     `protobuf:"varint,7,opt,name=leader_commit_index,json=leaderCommitIndex,proto3" json:"leader_commit_index,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendEntriesRequest) Descriptor deprecated 

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

Deprecated: Use AppendEntriesRequest.ProtoReflect.Descriptor instead.

func (*AppendEntriesRequest) GetEntries 

func (x *AppendEntriesRequest) GetEntries() []*Log

func (*AppendEntriesRequest) GetLeader 

func (x *AppendEntriesRequest) GetLeader() []byte

func (*AppendEntriesRequest) GetLeaderCommitIndex 

func (x *AppendEntriesRequest) GetLeaderCommitIndex() uint64

func (*AppendEntriesRequest) GetPrevLogEntry 

func (x *AppendEntriesRequest) GetPrevLogEntry() uint64

func (*AppendEntriesRequest) GetPrevLogTerm 

func (x *AppendEntriesRequest) GetPrevLogTerm() uint64

func (*AppendEntriesRequest) GetRpcHeader 

func (x *AppendEntriesRequest) GetRpcHeader() *RPCHeader

func (*AppendEntriesRequest) GetTerm 

func (x *AppendEntriesRequest) GetTerm() uint64

func (*AppendEntriesRequest) ProtoMessage 

func (*AppendEntriesRequest) ProtoMessage()

func (*AppendEntriesRequest) ProtoReflect 

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

func (*AppendEntriesRequest) Reset 

func (x *AppendEntriesRequest) Reset()

func (*AppendEntriesRequest) String 

func (x *AppendEntriesRequest) String() string

type AppendEntriesResponse 

type AppendEntriesResponse struct {
	RpcHeader      *RPCHeader `protobuf:"bytes,1,opt,name=rpc_header,json=rpcHeader,proto3" json:"rpc_header,omitempty"`
	Term           uint64     `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
	LastLog        uint64     `protobuf:"varint,3,opt,name=last_log,json=lastLog,proto3" json:"last_log,omitempty"`
	Success        bool       `protobuf:"varint,4,opt,name=success,proto3" json:"success,omitempty"`
	NoRetryBackoff bool       `protobuf:"varint,5,opt,name=no_retry_backoff,json=noRetryBackoff,proto3" json:"no_retry_backoff,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendEntriesResponse) Descriptor deprecated 

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

Deprecated: Use AppendEntriesResponse.ProtoReflect.Descriptor instead.

func (*AppendEntriesResponse) GetLastLog 

func (x *AppendEntriesResponse) GetLastLog() uint64

func (*AppendEntriesResponse) GetNoRetryBackoff 

func (x *AppendEntriesResponse) GetNoRetryBackoff() bool

func (*AppendEntriesResponse) GetRpcHeader 

func (x *AppendEntriesResponse) GetRpcHeader() *RPCHeader

func (*AppendEntriesResponse) GetSuccess 

func (x *AppendEntriesResponse) GetSuccess() bool

func (*AppendEntriesResponse) GetTerm 

func (x *AppendEntriesResponse) GetTerm() uint64

func (*AppendEntriesResponse) ProtoMessage 

func (*AppendEntriesResponse) ProtoMessage()

func (*AppendEntriesResponse) ProtoReflect 

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

func (*AppendEntriesResponse) Reset 

func (x *AppendEntriesResponse) Reset()

func (*AppendEntriesResponse) String 

func (x *AppendEntriesResponse) String() string

type Backup 

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

func (*Backup) Descriptor deprecated 

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

Deprecated: Use Backup.ProtoReflect.Descriptor instead.

func (*Backup) ProtoMessage 

func (*Backup) ProtoMessage()

func (*Backup) ProtoReflect 

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

func (*Backup) Reset 

func (x *Backup) Reset()

func (*Backup) String 

func (x *Backup) String() string

type Backup_Request 

type Backup_Request struct {
	Leader   bool `protobuf:"varint,1,opt,name=leader,proto3" json:"leader,omitempty"`
	Compress bool `protobuf:"varint,2,opt,name=compress,proto3" json:"compress,omitempty"`
	// contains filtered or unexported fields
}

func (*Backup_Request) Descriptor deprecated 

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

Deprecated: Use Backup_Request.ProtoReflect.Descriptor instead.

func (*Backup_Request) GetCompress 

func (x *Backup_Request) GetCompress() bool

func (*Backup_Request) GetLeader 

func (x *Backup_Request) GetLeader() bool

func (*Backup_Request) ProtoMessage 

func (*Backup_Request) ProtoMessage()

func (*Backup_Request) ProtoReflect 

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

func (*Backup_Request) Reset 

func (x *Backup_Request) Reset()

func (*Backup_Request) String 

func (x *Backup_Request) String() string

type Backup_Response 

type Backup_Response struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Backup_Response) Descriptor deprecated 

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

Deprecated: Use Backup_Response.ProtoReflect.Descriptor instead.

func (*Backup_Response) GetData 

func (x *Backup_Response) GetData() []byte

func (*Backup_Response) ProtoMessage 

func (*Backup_Response) ProtoMessage()

func (*Backup_Response) ProtoReflect 

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

func (*Backup_Response) Reset 

func (x *Backup_Response) Reset()

func (*Backup_Response) String 

func (x *Backup_Response) String() string

type BreakDown 

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

func (*BreakDown) Descriptor deprecated 

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

Deprecated: Use BreakDown.ProtoReflect.Descriptor instead.

func (*BreakDown) ProtoMessage 

func (*BreakDown) ProtoMessage()

func (*BreakDown) ProtoReflect 

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

func (*BreakDown) Reset 

func (x *BreakDown) Reset()

func (*BreakDown) String 

func (x *BreakDown) String() string

type BreakDown_KeyValues 

type BreakDown_KeyValues struct {
	Key   string             `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value map[string]float64 `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*BreakDown_KeyValues) Descriptor deprecated 

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

Deprecated: Use BreakDown_KeyValues.ProtoReflect.Descriptor instead.

func (*BreakDown_KeyValues) GetKey 

func (x *BreakDown_KeyValues) GetKey() string

func (*BreakDown_KeyValues) GetValue 

func (x *BreakDown_KeyValues) GetValue() map[string]float64

func (*BreakDown_KeyValues) ProtoMessage 

func (*BreakDown_KeyValues) ProtoMessage()

func (*BreakDown_KeyValues) ProtoReflect 

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

func (*BreakDown_KeyValues) Reset 

func (x *BreakDown_KeyValues) Reset()

func (*BreakDown_KeyValues) String 

func (x *BreakDown_KeyValues) String() string

type BreakDown_Request 

type BreakDown_Request struct {
	SiteId   string                 `protobuf:"bytes,1,opt,name=site_id,json=siteId,proto3" json:"site_id,omitempty"`
	TenantId string                 `protobuf:"bytes,2,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Property []Property             `protobuf:"varint,3,rep,packed,name=property,proto3,enum=v1.Property" json:"property,omitempty"`
	Period   *TimePeriod            `protobuf:"bytes,4,opt,name=period,proto3" json:"period,omitempty"`
	Metrics  []Metric               `protobuf:"varint,5,rep,packed,name=metrics,proto3,enum=v1.Metric" json:"metrics,omitempty"`
	Filters  []*Filter              `protobuf:"bytes,6,rep,name=filters,proto3" json:"filters,omitempty"`
	Date     *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=date,proto3" json:"date,omitempty"`
	// contains filtered or unexported fields
}

func (*BreakDown_Request) Descriptor deprecated 

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

Deprecated: Use BreakDown_Request.ProtoReflect.Descriptor instead.

func (*BreakDown_Request) GetDate 

func (x *BreakDown_Request) GetDate() *timestamppb.Timestamp

func (*BreakDown_Request) GetFilters 

func (x *BreakDown_Request) GetFilters() []*Filter

func (*BreakDown_Request) GetMetrics 

func (x *BreakDown_Request) GetMetrics() []Metric

func (*BreakDown_Request) GetPeriod 

func (x *BreakDown_Request) GetPeriod() *TimePeriod

func (*BreakDown_Request) GetProperty 

func (x *BreakDown_Request) GetProperty() []Property

func (*BreakDown_Request) GetSiteId 

func (x *BreakDown_Request) GetSiteId() string

func (*BreakDown_Request) GetTenantId 

func (x *BreakDown_Request) GetTenantId() string

func (*BreakDown_Request) ProtoMessage 

func (*BreakDown_Request) ProtoMessage()

func (*BreakDown_Request) ProtoReflect 

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

func (*BreakDown_Request) Reset 

func (x *BreakDown_Request) Reset()

func (*BreakDown_Request) String 

func (x *BreakDown_Request) String() string

type BreakDown_Response 

type BreakDown_Response struct {
	Results []*BreakDown_Result `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*BreakDown_Response) Descriptor deprecated 

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

Deprecated: Use BreakDown_Response.ProtoReflect.Descriptor instead.

func (*BreakDown_Response) GetResults 

func (x *BreakDown_Response) GetResults() []*BreakDown_Result

func (*BreakDown_Response) ProtoMessage 

func (*BreakDown_Response) ProtoMessage()

func (*BreakDown_Response) ProtoReflect 

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

func (*BreakDown_Response) Reset 

func (x *BreakDown_Response) Reset()

func (*BreakDown_Response) String 

func (x *BreakDown_Response) String() string

type BreakDown_Result 

type BreakDown_Result struct {
	Property Property               `protobuf:"varint,1,opt,name=property,proto3,enum=v1.Property" json:"property,omitempty"`
	Values   []*BreakDown_KeyValues `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*BreakDown_Result) Descriptor deprecated 

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

Deprecated: Use BreakDown_Result.ProtoReflect.Descriptor instead.

func (*BreakDown_Result) GetProperty 

func (x *BreakDown_Result) GetProperty() Property

func (*BreakDown_Result) GetValues 

func (x *BreakDown_Result) GetValues() []*BreakDown_KeyValues

func (*BreakDown_Result) ProtoMessage 

func (*BreakDown_Result) ProtoMessage()

func (*BreakDown_Result) ProtoReflect 

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

func (*BreakDown_Result) Reset 

func (x *BreakDown_Result) Reset()

func (*BreakDown_Result) String 

func (x *BreakDown_Result) String() string

type Config 

type Config struct {
	Data        string  `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Listen      string  `protobuf:"bytes,2,opt,name=listen,proto3" json:"listen,omitempty"`
	RateLimit   float64 `protobuf:"fixed64,3,opt,name=rate_limit,json=rateLimit,proto3" json:"rate_limit,omitempty"`
	GranuleSize int64   `protobuf:"varint,5,opt,name=granule_size,json=granuleSize,proto3" json:"granule_size,omitempty"`
	// Path to the geoiip database used to set web analytics country attribute.
	GeoipDbPath string `protobuf:"bytes,8,opt,name=geoip_db_path,json=geoipDbPath,proto3" json:"geoip_db_path,omitempty"`
	// How long data will be persisted, Older data is automatically deleted.
	RetentionPeriod *durationpb.Duration `protobuf:"bytes,10,opt,name=retention_period,json=retentionPeriod,proto3" json:"retention_period,omitempty"`
	AutoTls         bool                 `protobuf:"varint,11,opt,name=auto_tls,json=autoTls,proto3" json:"auto_tls,omitempty"`
	Acme            *Acme                `protobuf:"bytes,12,opt,name=acme,proto3" json:"acme,omitempty"`
	AuthToken       string               `protobuf:"bytes,13,opt,name=auth_token,json=authToken,proto3" json:"auth_token,omitempty"`
	Tenants         []*Tenant            `protobuf:"bytes,14,rep,name=tenants,proto3" json:"tenants,omitempty"`
	Credentials     *Credential_List     `protobuf:"bytes,15,opt,name=credentials,proto3" json:"credentials,omitempty"`
	Node            *RaftNode            `protobuf:"bytes,16,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*Config) Descriptor deprecated 

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetAcme 

func (x *Config) GetAcme() *Acme

func (*Config) GetAuthToken 

func (x *Config) GetAuthToken() string

func (*Config) GetAutoTls 

func (x *Config) GetAutoTls() bool

func (*Config) GetCredentials 

func (x *Config) GetCredentials() *Credential_List

func (*Config) GetData 

func (x *Config) GetData() string

func (*Config) GetGeoipDbPath 

func (x *Config) GetGeoipDbPath() string

func (*Config) GetGranuleSize 

func (x *Config) GetGranuleSize() int64

func (*Config) GetListen 

func (x *Config) GetListen() string

func (*Config) GetNode 

func (x *Config) GetNode() *RaftNode

func (*Config) GetRateLimit 

func (x *Config) GetRateLimit() float64

func (*Config) GetRetentionPeriod 

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

func (*Config) GetTenants 

func (x *Config) GetTenants() []*Tenant

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) ProtoReflect 

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

func (*Config) Reset 

func (x *Config) Reset()

func (*Config) String 

func (x *Config) String() string

type Credential 

type Credential struct {
	Username string                  `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string                  `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	Perms    []Credential_Permission `protobuf:"varint,3,rep,packed,name=perms,proto3,enum=v1.Credential_Permission" json:"perms,omitempty"`
	// contains filtered or unexported fields
}

func (*Credential) Descriptor deprecated 

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

Deprecated: Use Credential.ProtoReflect.Descriptor instead.

func (*Credential) GetPassword 

func (x *Credential) GetPassword() string

func (*Credential) GetPerms 

func (x *Credential) GetPerms() []Credential_Permission

func (*Credential) GetUsername 

func (x *Credential) GetUsername() string

func (*Credential) ProtoMessage 

func (*Credential) ProtoMessage()

func (*Credential) ProtoReflect 

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

func (*Credential) Reset 

func (x *Credential) Reset()

func (*Credential) String 

func (x *Credential) String() string

type Credential_List 

type Credential_List struct {
	Items []*Credential `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*Credential_List) Descriptor deprecated 

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

Deprecated: Use Credential_List.ProtoReflect.Descriptor instead.

func (*Credential_List) GetItems 

func (x *Credential_List) GetItems() []*Credential

func (*Credential_List) ProtoMessage 

func (*Credential_List) ProtoMessage()

func (*Credential_List) ProtoReflect 

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

func (*Credential_List) Reset 

func (x *Credential_List) Reset()

func (*Credential_List) String 

func (x *Credential_List) String() string

type Credential_Permission 

type Credential_Permission int32
const (
	Credential_ALL            Credential_Permission = 0
	Credential_JOIN           Credential_Permission = 2
	Credential_JOIN_READ_ONLY Credential_Permission = 3
	Credential_QUERY          Credential_Permission = 4
	Credential_STATUS         Credential_Permission = 5
	Credential_READY          Credential_Permission = 6
	Credential_BACKUP         Credential_Permission = 7
	Credential_LOAD           Credential_Permission = 8
	Credential_REMOVE         Credential_Permission = 9
	Credential_DATA           Credential_Permission = 10
	Credential_NODE_API       Credential_Permission = 11
	Credential_NOTIFY         Credential_Permission = 12
)

func (Credential_Permission) Descriptor 

func (Credential_Permission) Descriptor() protoreflect.EnumDescriptor

func (Credential_Permission) Enum 

func (x Credential_Permission) Enum() *Credential_Permission

func (Credential_Permission) EnumDescriptor deprecated 

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

Deprecated: Use Credential_Permission.Descriptor instead.

func (Credential_Permission) Number 

func (x Credential_Permission) Number() protoreflect.EnumNumber

func (Credential_Permission) String 

func (x Credential_Permission) String() string

func (Credential_Permission) Type 

func (Credential_Permission) Type() protoreflect.EnumType

type Credentials 

type Credentials struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*Credentials) Descriptor deprecated 

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

Deprecated: Use Credentials.ProtoReflect.Descriptor instead.

func (*Credentials) GetPassword 

func (x *Credentials) GetPassword() string

func (*Credentials) GetUsername 

func (x *Credentials) GetUsername() string

func (*Credentials) ProtoMessage 

func (*Credentials) ProtoMessage()

func (*Credentials) ProtoReflect 

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

func (*Credentials) Reset 

func (x *Credentials) Reset()

func (*Credentials) String 

func (x *Credentials) String() string

type Data 

type Data struct {
	Timestamp      int64   `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Id             int64   `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Bounce         *bool   `protobuf:"varint,3,opt,name=bounce,proto3,oneof" json:"bounce,omitempty"`
	Session        bool    `protobuf:"varint,4,opt,name=session,proto3" json:"session,omitempty"`
	View           bool    `protobuf:"varint,5,opt,name=view,proto3" json:"view,omitempty"`
	Duration       float64 `protobuf:"fixed64,6,opt,name=duration,proto3" json:"duration,omitempty"`
	Browser        string  `protobuf:"bytes,19,opt,name=browser,proto3" json:"browser,omitempty"`
	BrowserVersion string  `protobuf:"bytes,20,opt,name=browser_version,json=browserVersion,proto3" json:"browser_version,omitempty"`
	City           string  `protobuf:"bytes,26,opt,name=city,proto3" json:"city,omitempty"`
	Country        string  `protobuf:"bytes,23,opt,name=country,proto3" json:"country,omitempty"`
	Device         string  `protobuf:"bytes,18,opt,name=device,proto3" json:"device,omitempty"`
	Domain         string  `protobuf:"bytes,25,opt,name=domain,proto3" json:"domain,omitempty"`
	EntryPage      string  `protobuf:"bytes,9,opt,name=entry_page,json=entryPage,proto3" json:"entry_page,omitempty"`
	Event          string  `protobuf:"bytes,7,opt,name=event,proto3" json:"event,omitempty"`
	ExitPage       string  `protobuf:"bytes,10,opt,name=exit_page,json=exitPage,proto3" json:"exit_page,omitempty"`
	Host           string  `protobuf:"bytes,27,opt,name=host,proto3" json:"host,omitempty"`
	Os             string  `protobuf:"bytes,21,opt,name=os,proto3" json:"os,omitempty"`
	OsVersion      string  `protobuf:"bytes,22,opt,name=os_version,json=osVersion,proto3" json:"os_version,omitempty"`
	Page           string  `protobuf:"bytes,8,opt,name=page,proto3" json:"page,omitempty"`
	Referrer       string  `protobuf:"bytes,12,opt,name=referrer,proto3" json:"referrer,omitempty"`
	Region         string  `protobuf:"bytes,24,opt,name=region,proto3" json:"region,omitempty"`
	Source         string  `protobuf:"bytes,11,opt,name=source,proto3" json:"source,omitempty"`
	UtmCampaign    string  `protobuf:"bytes,15,opt,name=utm_campaign,json=utmCampaign,proto3" json:"utm_campaign,omitempty"`
	UtmContent     string  `protobuf:"bytes,16,opt,name=utm_content,json=utmContent,proto3" json:"utm_content,omitempty"`
	UtmMedium      string  `protobuf:"bytes,14,opt,name=utm_medium,json=utmMedium,proto3" json:"utm_medium,omitempty"`
	UtmSource      string  `protobuf:"bytes,13,opt,name=utm_source,json=utmSource,proto3" json:"utm_source,omitempty"`
	UtmTerm        string  `protobuf:"bytes,17,opt,name=utm_term,json=utmTerm,proto3" json:"utm_term,omitempty"`
	TenantId       string  `protobuf:"bytes,28,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Data) Descriptor deprecated 

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

Deprecated: Use Data.ProtoReflect.Descriptor instead.

func (*Data) GetBounce 

func (x *Data) GetBounce() bool

func (*Data) GetBrowser 

func (x *Data) GetBrowser() string

func (*Data) GetBrowserVersion 

func (x *Data) GetBrowserVersion() string

func (*Data) GetCity 

func (x *Data) GetCity() string

func (*Data) GetCountry 

func (x *Data) GetCountry() string

func (*Data) GetDevice 

func (x *Data) GetDevice() string

func (*Data) GetDomain 

func (x *Data) GetDomain() string

func (*Data) GetDuration 

func (x *Data) GetDuration() float64

func (*Data) GetEntryPage 

func (x *Data) GetEntryPage() string

func (*Data) GetEvent 

func (x *Data) GetEvent() string

func (*Data) GetExitPage 

func (x *Data) GetExitPage() string

func (*Data) GetHost 

func (x *Data) GetHost() string

func (*Data) GetId 

func (x *Data) GetId() int64

func (*Data) GetOs 

func (x *Data) GetOs() string

func (*Data) GetOsVersion 

func (x *Data) GetOsVersion() string

func (*Data) GetPage 

func (x *Data) GetPage() string

func (*Data) GetReferrer 

func (x *Data) GetReferrer() string

func (*Data) GetRegion 

func (x *Data) GetRegion() string

func (*Data) GetSession 

func (x *Data) GetSession() bool

func (*Data) GetSource 

func (x *Data) GetSource() string

func (*Data) GetTenantId 

func (x *Data) GetTenantId() string

func (*Data) GetTimestamp 

func (x *Data) GetTimestamp() int64

func (*Data) GetUtmCampaign 

func (x *Data) GetUtmCampaign() string

func (*Data) GetUtmContent 

func (x *Data) GetUtmContent() string

func (*Data) GetUtmMedium 

func (x *Data) GetUtmMedium() string

func (*Data) GetUtmSource 

func (x *Data) GetUtmSource() string

func (*Data) GetUtmTerm 

func (x *Data) GetUtmTerm() string

func (*Data) GetView 

func (x *Data) GetView() bool

func (*Data) ProtoMessage 

func (*Data) ProtoMessage()

func (*Data) ProtoReflect 

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

func (*Data) Reset 

func (x *Data) Reset()

func (*Data) String 

func (x *Data) String() string

type Data_List 

type Data_List struct {
	Items []*Data `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*Data_List) Descriptor deprecated 

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

Deprecated: Use Data_List.ProtoReflect.Descriptor instead.

func (*Data_List) GetItems 

func (x *Data_List) GetItems() []*Data

func (*Data_List) ProtoMessage 

func (*Data_List) ProtoMessage()

func (*Data_List) ProtoReflect 

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

func (*Data_List) Reset 

func (x *Data_List) Reset()

func (*Data_List) String 

func (x *Data_List) String() string

type Domain 

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

func (*Domain) Descriptor deprecated 

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

Deprecated: Use Domain.ProtoReflect.Descriptor instead.

func (*Domain) GetName 

func (x *Domain) GetName() string

func (*Domain) ProtoMessage 

func (*Domain) ProtoMessage()

func (*Domain) ProtoReflect 

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

func (*Domain) Reset 

func (x *Domain) Reset()

func (*Domain) String 

func (x *Domain) String() string

type Error 

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

func (*Error) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetError 

func (x *Error) GetError() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

type Event 

type Event struct {

	// / EventName
	N string `protobuf:"bytes,1,opt,name=n,proto3" json:"n,omitempty"`
	U string `protobuf:"bytes,2,opt,name=u,proto3" json:"u,omitempty"`
	// Domain
	D string `protobuf:"bytes,3,opt,name=d,proto3" json:"d,omitempty"`
	// Screen width
	W int32 `protobuf:"varint,4,opt,name=w,proto3" json:"w,omitempty"`
	// Hash mode
	H  bool   `protobuf:"varint,5,opt,name=h,proto3" json:"h,omitempty"`
	Ip string `protobuf:"bytes,6,opt,name=ip,proto3" json:"ip,omitempty"`
	// user agent
	Ua string `protobuf:"bytes,7,opt,name=ua,proto3" json:"ua,omitempty"`
	// Referrer
	R         string                 `protobuf:"bytes,8,opt,name=r,proto3" json:"r,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetD 

func (x *Event) GetD() string

func (*Event) GetH 

func (x *Event) GetH() bool

func (*Event) GetIp 

func (x *Event) GetIp() string

func (*Event) GetN 

func (x *Event) GetN() string

func (*Event) GetR 

func (x *Event) GetR() string

func (*Event) GetTimestamp 

func (x *Event) GetTimestamp() *timestamppb.Timestamp

func (*Event) GetU 

func (x *Event) GetU() string

func (*Event) GetUa 

func (x *Event) GetUa() string

func (*Event) GetW 

func (x *Event) GetW() int32

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type Filter 

type Filter struct {
	Property Property  `protobuf:"varint,1,opt,name=property,proto3,enum=v1.Property" json:"property,omitempty"`
	Op       Filter_OP `protobuf:"varint,2,opt,name=op,proto3,enum=v1.Filter_OP" json:"op,omitempty"`
	Value    string    `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Filter) Descriptor deprecated 

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

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetOp 

func (x *Filter) GetOp() Filter_OP

func (*Filter) GetProperty 

func (x *Filter) GetProperty() Property

func (*Filter) GetValue 

func (x *Filter) GetValue() string

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_OP 

type Filter_OP int32
const (
	Filter_equal        Filter_OP = 0
	Filter_not_equal    Filter_OP = 1
	Filter_re_equal     Filter_OP = 2
	Filter_re_not_equal Filter_OP = 3
)

func (Filter_OP) Descriptor 

func (Filter_OP) Descriptor() protoreflect.EnumDescriptor

func (Filter_OP) Enum 

func (x Filter_OP) Enum() *Filter_OP

func (Filter_OP) EnumDescriptor deprecated 

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

Deprecated: Use Filter_OP.Descriptor instead.

func (Filter_OP) Number 

func (x Filter_OP) Number() protoreflect.EnumNumber

func (Filter_OP) String 

func (x Filter_OP) String() string

func (Filter_OP) Type 

func (Filter_OP) Type() protoreflect.EnumType

type Filters 

type Filters struct {
	List []*Filter `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	// columns returned
	Projection []Filters_Projection `protobuf:"varint,2,rep,packed,name=projection,proto3,enum=v1.Filters_Projection" json:"projection,omitempty"`
	// contains filtered or unexported fields
}

func (*Filters) Descriptor deprecated 

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

Deprecated: Use Filters.ProtoReflect.Descriptor instead.

func (*Filters) GetList 

func (x *Filters) GetList() []*Filter

func (*Filters) GetProjection 

func (x *Filters) GetProjection() []Filters_Projection

func (*Filters) ProtoMessage 

func (*Filters) ProtoMessage()

func (*Filters) ProtoReflect 

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

func (*Filters) Reset 

func (x *Filters) Reset()

func (*Filters) String 

func (x *Filters) String() string

type Filters_Projection 

type Filters_Projection int32
const (
	Filters_unknown         Filters_Projection = 0
	Filters_timestamp       Filters_Projection = 1
	Filters_id              Filters_Projection = 2
	Filters_bounce          Filters_Projection = 3
	Filters_session         Filters_Projection = 4
	Filters_view            Filters_Projection = 5
	Filters_duration        Filters_Projection = 6
	Filters_browser         Filters_Projection = 7
	Filters_browser_version Filters_Projection = 8
	Filters_city            Filters_Projection = 9
	Filters_country         Filters_Projection = 10
	Filters_device          Filters_Projection = 11
	Filters_domain          Filters_Projection = 12
	Filters_entry_page      Filters_Projection = 13
	Filters_event           Filters_Projection = 14
	Filters_exit_page       Filters_Projection = 15
	Filters_host            Filters_Projection = 16
	Filters_os              Filters_Projection = 17
	Filters_os_version      Filters_Projection = 18
	Filters_page            Filters_Projection = 19
	Filters_referrer        Filters_Projection = 20
	Filters_region          Filters_Projection = 21
	Filters_source          Filters_Projection = 22
	Filters_tenant_id       Filters_Projection = 23
	Filters_utm_campaign    Filters_Projection = 24
	Filters_utm_content     Filters_Projection = 25
	Filters_utm_medium      Filters_Projection = 26
	Filters_utm_source      Filters_Projection = 27
	Filters_utm_term        Filters_Projection = 28
)

func (Filters_Projection) Descriptor 

func (Filters_Projection) Descriptor() protoreflect.EnumDescriptor

func (Filters_Projection) Enum 

func (x Filters_Projection) Enum() *Filters_Projection

func (Filters_Projection) EnumDescriptor deprecated 

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

Deprecated: Use Filters_Projection.Descriptor instead.

func (Filters_Projection) Number 

func (x Filters_Projection) Number() protoreflect.EnumNumber

func (Filters_Projection) String 

func (x Filters_Projection) String() string

func (Filters_Projection) Type 

func (Filters_Projection) Type() protoreflect.EnumType

type GetDomainResponse 

type GetDomainResponse struct {
	Domains []*Domain `protobuf:"bytes,1,rep,name=domains,proto3" json:"domains,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDomainResponse) Descriptor deprecated 

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

Deprecated: Use GetDomainResponse.ProtoReflect.Descriptor instead.

func (*GetDomainResponse) GetDomains 

func (x *GetDomainResponse) GetDomains() []*Domain

func (*GetDomainResponse) ProtoMessage 

func (*GetDomainResponse) ProtoMessage()

func (*GetDomainResponse) ProtoReflect 

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

func (*GetDomainResponse) Reset 

func (x *GetDomainResponse) Reset()

func (*GetDomainResponse) String 

func (x *GetDomainResponse) String() string

type Granule 

type Granule struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,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"`
	Size   uint64 `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	Rows   uint64 `protobuf:"varint,5,opt,name=rows,proto3" json:"rows,omitempty"`
	Tenant string `protobuf:"bytes,6,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// contains filtered or unexported fields
}

func (*Granule) Descriptor deprecated 

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

Deprecated: Use Granule.ProtoReflect.Descriptor instead.

func (*Granule) GetId 

func (x *Granule) GetId() string

func (*Granule) GetMax 

func (x *Granule) GetMax() int64

func (*Granule) GetMin 

func (x *Granule) GetMin() int64

func (*Granule) GetRows 

func (x *Granule) GetRows() uint64

func (*Granule) GetSize 

func (x *Granule) GetSize() uint64

func (*Granule) GetTenant 

func (x *Granule) GetTenant() string

func (*Granule) ProtoMessage 

func (*Granule) ProtoMessage()

func (*Granule) ProtoReflect 

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

func (*Granule) Reset 

func (x *Granule) Reset()

func (*Granule) String 

func (x *Granule) String() string

type InstallSnapshotRequest 

type InstallSnapshotRequest struct {
	RpcHeader          *RPCHeader `protobuf:"bytes,1,opt,name=rpc_header,json=rpcHeader,proto3" json:"rpc_header,omitempty"`
	SnapshotVersion    int64      `protobuf:"varint,11,opt,name=snapshot_version,json=snapshotVersion,proto3" json:"snapshot_version,omitempty"`
	Term               uint64     `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
	Leader             []byte     `protobuf:"bytes,3,opt,name=leader,proto3" json:"leader,omitempty"`
	LastLogIndex       uint64     `protobuf:"varint,4,opt,name=last_log_index,json=lastLogIndex,proto3" json:"last_log_index,omitempty"`
	LastLogTerm        uint64     `protobuf:"varint,5,opt,name=last_log_term,json=lastLogTerm,proto3" json:"last_log_term,omitempty"`
	Peers              []byte     `protobuf:"bytes,6,opt,name=peers,proto3" json:"peers,omitempty"`
	Configuration      []byte     `protobuf:"bytes,7,opt,name=configuration,proto3" json:"configuration,omitempty"`
	ConfigurationIndex uint64     `protobuf:"varint,8,opt,name=configuration_index,json=configurationIndex,proto3" json:"configuration_index,omitempty"`
	Size               int64      `protobuf:"varint,9,opt,name=size,proto3" json:"size,omitempty"`
	Data               []byte     `protobuf:"bytes,10,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The first InstallSnapshotRequest on the stream contains all the metadata. All further messages contain only data.

func (*InstallSnapshotRequest) Descriptor deprecated 

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

Deprecated: Use InstallSnapshotRequest.ProtoReflect.Descriptor instead.

func (*InstallSnapshotRequest) GetConfiguration 

func (x *InstallSnapshotRequest) GetConfiguration() []byte

func (*InstallSnapshotRequest) GetConfigurationIndex 

func (x *InstallSnapshotRequest) GetConfigurationIndex() uint64

func (*InstallSnapshotRequest) GetData 

func (x *InstallSnapshotRequest) GetData() []byte

func (*InstallSnapshotRequest) GetLastLogIndex 

func (x *InstallSnapshotRequest) GetLastLogIndex() uint64

func (*InstallSnapshotRequest) GetLastLogTerm 

func (x *InstallSnapshotRequest) GetLastLogTerm() uint64

func (*InstallSnapshotRequest) GetLeader 

func (x *InstallSnapshotRequest) GetLeader() []byte

func (*InstallSnapshotRequest) GetPeers 

func (x *InstallSnapshotRequest) GetPeers() []byte

func (*InstallSnapshotRequest) GetRpcHeader 

func (x *InstallSnapshotRequest) GetRpcHeader() *RPCHeader

func (*InstallSnapshotRequest) GetSize 

func (x *InstallSnapshotRequest) GetSize() int64

func (*InstallSnapshotRequest) GetSnapshotVersion 

func (x *InstallSnapshotRequest) GetSnapshotVersion() int64

func (*InstallSnapshotRequest) GetTerm 

func (x *InstallSnapshotRequest) GetTerm() uint64

func (*InstallSnapshotRequest) ProtoMessage 

func (*InstallSnapshotRequest) ProtoMessage()

func (*InstallSnapshotRequest) ProtoReflect 

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

func (*InstallSnapshotRequest) Reset 

func (x *InstallSnapshotRequest) Reset()

func (*InstallSnapshotRequest) String 

func (x *InstallSnapshotRequest) String() string

type InstallSnapshotResponse 

type InstallSnapshotResponse struct {
	RpcHeader *RPCHeader `protobuf:"bytes,1,opt,name=rpc_header,json=rpcHeader,proto3" json:"rpc_header,omitempty"`
	Term      uint64     `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
	Success   bool       `protobuf:"varint,3,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*InstallSnapshotResponse) Descriptor deprecated 

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

Deprecated: Use InstallSnapshotResponse.ProtoReflect.Descriptor instead.

func (*InstallSnapshotResponse) GetRpcHeader 

func (x *InstallSnapshotResponse) GetRpcHeader() *RPCHeader

func (*InstallSnapshotResponse) GetSuccess 

func (x *InstallSnapshotResponse) GetSuccess() bool

func (*InstallSnapshotResponse) GetTerm 

func (x *InstallSnapshotResponse) GetTerm() uint64

func (*InstallSnapshotResponse) ProtoMessage 

func (*InstallSnapshotResponse) ProtoMessage()

func (*InstallSnapshotResponse) ProtoReflect 

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

func (*InstallSnapshotResponse) Reset 

func (x *InstallSnapshotResponse) Reset()

func (*InstallSnapshotResponse) String 

func (x *InstallSnapshotResponse) String() string

type InternalCLusterClient 

type InternalCLusterClient interface {
	Join(ctx context.Context, in *Join_Request, opts ...grpc.CallOption) (*Join_Response, error)
	Load(ctx context.Context, in *Load_Request, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Backup(ctx context.Context, in *Backup_Request, opts ...grpc.CallOption) (InternalCLuster_BackupClient, error)
	RemoveNode(ctx context.Context, in *RemoveNode_Request, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Notify(ctx context.Context, in *Notify_Request, opts ...grpc.CallOption) (*emptypb.Empty, error)
	NodeAPI(ctx context.Context, in *NodeAPIRequest, opts ...grpc.CallOption) (*NodeMeta, error)
	SendData(ctx context.Context, in *Data, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Realtime(ctx context.Context, in *Realtime_Request, opts ...grpc.CallOption) (*Realtime_Response, error)
	Aggregate(ctx context.Context, in *Aggregate_Request, opts ...grpc.CallOption) (*Aggregate_Response, error)
	Timeseries(ctx context.Context, in *Timeseries_Request, opts ...grpc.CallOption) (*Timeseries_Response, error)
	BreakDown(ctx context.Context, in *BreakDown_Request, opts ...grpc.CallOption) (*BreakDown_Response, error)
}

InternalCLusterClient is the client API for InternalCLuster service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewInternalCLusterClient 

func NewInternalCLusterClient(cc grpc.ClientConnInterface) InternalCLusterClient

type InternalCLusterServer 

type InternalCLusterServer interface {
	Join(context.Context, *Join_Request) (*Join_Response, error)
	Load(context.Context, *Load_Request) (*emptypb.Empty, error)
	Backup(*Backup_Request, InternalCLuster_BackupServer) error
	RemoveNode(context.Context, *RemoveNode_Request) (*emptypb.Empty, error)
	Notify(context.Context, *Notify_Request) (*emptypb.Empty, error)
	NodeAPI(context.Context, *NodeAPIRequest) (*NodeMeta, error)
	SendData(context.Context, *Data) (*emptypb.Empty, error)
	Realtime(context.Context, *Realtime_Request) (*Realtime_Response, error)
	Aggregate(context.Context, *Aggregate_Request) (*Aggregate_Response, error)
	Timeseries(context.Context, *Timeseries_Request) (*Timeseries_Response, error)
	BreakDown(context.Context, *BreakDown_Request) (*BreakDown_Response, error)
	// contains filtered or unexported methods
}

InternalCLusterServer is the server API for InternalCLuster service. All implementations must embed UnimplementedInternalCLusterServer for forward compatibility

type InternalCLuster_BackupClient 

type InternalCLuster_BackupClient interface {
	Recv() (*Backup_Response, error)
	grpc.ClientStream
}

type InternalCLuster_BackupServer 

type InternalCLuster_BackupServer interface {
	Send(*Backup_Response) error
	grpc.ServerStream
}

type Interval 

type Interval int32
const (
	Interval_date   Interval = 0
	Interval_minute Interval = 1
	Interval_hour   Interval = 2
	Interval_week   Interval = 3
	Interval_month  Interval = 4
)

func (Interval) Descriptor 

func (Interval) Descriptor() protoreflect.EnumDescriptor

func (Interval) Enum 

func (x Interval) Enum() *Interval

func (Interval) EnumDescriptor deprecated 

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

Deprecated: Use Interval.Descriptor instead.

func (Interval) Number 

func (x Interval) Number() protoreflect.EnumNumber

func (Interval) String 

func (x Interval) String() string

func (Interval) Type 

func (Interval) Type() protoreflect.EnumType

type Join 

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

func (*Join) Descriptor deprecated 

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

Deprecated: Use Join.ProtoReflect.Descriptor instead.

func (*Join) ProtoMessage 

func (*Join) ProtoMessage()

func (*Join) ProtoReflect 

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

func (*Join) Reset 

func (x *Join) Reset()

func (*Join) String 

func (x *Join) String() string

type Join_Request 

type Join_Request struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Voter   bool   `protobuf:"varint,3,opt,name=voter,proto3" json:"voter,omitempty"`
	// contains filtered or unexported fields
}

func (*Join_Request) Descriptor deprecated 

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

Deprecated: Use Join_Request.ProtoReflect.Descriptor instead.

func (*Join_Request) GetAddress 

func (x *Join_Request) GetAddress() string

func (*Join_Request) GetId 

func (x *Join_Request) GetId() string

func (*Join_Request) GetVoter 

func (x *Join_Request) GetVoter() bool

func (*Join_Request) ProtoMessage 

func (*Join_Request) ProtoMessage()

func (*Join_Request) ProtoReflect 

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

func (*Join_Request) Reset 

func (x *Join_Request) Reset()

func (*Join_Request) String 

func (x *Join_Request) String() string

type Join_Response 

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

func (*Join_Response) Descriptor deprecated 

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

Deprecated: Use Join_Response.ProtoReflect.Descriptor instead.

func (*Join_Response) GetLeader 

func (x *Join_Response) GetLeader() string

func (*Join_Response) ProtoMessage 

func (*Join_Response) ProtoMessage()

func (*Join_Response) ProtoReflect 

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

func (*Join_Response) Reset 

func (x *Join_Response) Reset()

func (*Join_Response) String 

func (x *Join_Response) String() string

type Load 

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

func (*Load) Descriptor deprecated 

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

Deprecated: Use Load.ProtoReflect.Descriptor instead.

func (*Load) ProtoMessage 

func (*Load) ProtoMessage()

func (*Load) ProtoReflect 

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

func (*Load) Reset 

func (x *Load) Reset()

func (*Load) String 

func (x *Load) String() string

type Load_Request 

type Load_Request struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Load_Request) Descriptor deprecated 

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

Deprecated: Use Load_Request.ProtoReflect.Descriptor instead.

func (*Load_Request) GetData 

func (x *Load_Request) GetData() []byte

func (*Load_Request) ProtoMessage 

func (*Load_Request) ProtoMessage()

func (*Load_Request) ProtoReflect 

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

func (*Load_Request) Reset 

func (x *Load_Request) Reset()

func (*Load_Request) String 

func (x *Load_Request) String() string

type Log 

type Log struct {
	Index      uint64                 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Term       uint64                 `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
	Type       Log_LogType            `protobuf:"varint,3,opt,name=type,proto3,enum=v1.Log_LogType" json:"type,omitempty"`
	Data       []byte                 `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	Extensions []byte                 `protobuf:"bytes,5,opt,name=extensions,proto3" json:"extensions,omitempty"`
	AppendedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=appended_at,json=appendedAt,proto3" json:"appended_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Log) Descriptor deprecated 

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

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetAppendedAt 

func (x *Log) GetAppendedAt() *timestamppb.Timestamp

func (*Log) GetData 

func (x *Log) GetData() []byte

func (*Log) GetExtensions 

func (x *Log) GetExtensions() []byte

func (*Log) GetIndex 

func (x *Log) GetIndex() uint64

func (*Log) GetTerm 

func (x *Log) GetTerm() uint64

func (*Log) GetType 

func (x *Log) GetType() Log_LogType

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) ProtoReflect 

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

func (*Log) Reset 

func (x *Log) Reset()

func (*Log) String 

func (x *Log) String() string

type Log_LogType 

type Log_LogType int32
const (
	Log_LOG_COMMAND                Log_LogType = 0
	Log_LOG_NOOP                   Log_LogType = 1
	Log_LOG_ADD_PEER_DEPRECATED    Log_LogType = 2
	Log_LOG_REMOVE_PEER_DEPRECATED Log_LogType = 3
	Log_LOG_BARRIER                Log_LogType = 4
	Log_LOG_CONFIGURATION          Log_LogType = 5
)

func (Log_LogType) Descriptor 

func (Log_LogType) Descriptor() protoreflect.EnumDescriptor

func (Log_LogType) Enum 

func (x Log_LogType) Enum() *Log_LogType

func (Log_LogType) EnumDescriptor deprecated 

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

Deprecated: Use Log_LogType.Descriptor instead.

func (Log_LogType) Number 

func (x Log_LogType) Number() protoreflect.EnumNumber

func (Log_LogType) String 

func (x Log_LogType) String() string

func (Log_LogType) Type 

func (Log_LogType) Type() protoreflect.EnumType

type Metadata 

type Metadata struct {
	Columns []*Metadata_Column `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	Min     uint64             `protobuf:"varint,2,opt,name=min,proto3" json:"min,omitempty"`
	Max     uint64             `protobuf:"varint,3,opt,name=max,proto3" json:"max,omitempty"`
	Id      string             `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata) Descriptor deprecated 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetColumns 

func (x *Metadata) GetColumns() []*Metadata_Column

func (*Metadata) GetId 

func (x *Metadata) GetId() string

func (*Metadata) GetMax 

func (x *Metadata) GetMax() uint64

func (*Metadata) GetMin 

func (x *Metadata) GetMin() uint64

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 Metadata_Chunk 

type Metadata_Chunk struct {
	Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Size   uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata_Chunk) Descriptor deprecated 

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

Deprecated: Use Metadata_Chunk.ProtoReflect.Descriptor instead.

func (*Metadata_Chunk) GetOffset 

func (x *Metadata_Chunk) GetOffset() uint64

func (*Metadata_Chunk) GetSize 

func (x *Metadata_Chunk) GetSize() uint64

func (*Metadata_Chunk) ProtoMessage 

func (*Metadata_Chunk) ProtoMessage()

func (*Metadata_Chunk) ProtoReflect 

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

func (*Metadata_Chunk) Reset 

func (x *Metadata_Chunk) Reset()

func (*Metadata_Chunk) String 

func (x *Metadata_Chunk) String() string

type Metadata_Column 

type Metadata_Column struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	NumRows   uint32 `protobuf:"varint,2,opt,name=num_rows,json=numRows,proto3" json:"num_rows,omitempty"`
	FstOffset uint32 `protobuf:"varint,4,opt,name=fst_offset,json=fstOffset,proto3" json:"fst_offset,omitempty"`
	Offset    uint64 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`
	Size      uint32 `protobuf:"varint,6,opt,name=size,proto3" json:"size,omitempty"`
	RawSize   uint32 `protobuf:"varint,7,opt,name=raw_size,json=rawSize,proto3" json:"raw_size,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata_Column) Descriptor deprecated 

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

Deprecated: Use Metadata_Column.ProtoReflect.Descriptor instead.

func (*Metadata_Column) GetFstOffset 

func (x *Metadata_Column) GetFstOffset() uint32

func (*Metadata_Column) GetName 

func (x *Metadata_Column) GetName() string

func (*Metadata_Column) GetNumRows 

func (x *Metadata_Column) GetNumRows() uint32

func (*Metadata_Column) GetOffset 

func (x *Metadata_Column) GetOffset() uint64

func (*Metadata_Column) GetRawSize 

func (x *Metadata_Column) GetRawSize() uint32

func (*Metadata_Column) GetSize 

func (x *Metadata_Column) GetSize() uint32

func (*Metadata_Column) ProtoMessage 

func (*Metadata_Column) ProtoMessage()

func (*Metadata_Column) ProtoReflect 

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

func (*Metadata_Column) Reset 

func (x *Metadata_Column) Reset()

func (*Metadata_Column) String 

func (x *Metadata_Column) String() string

type Metric 

type Metric int32
const (
	Metric_unknown_metric  Metric = 0
	Metric_visitors        Metric = 1
	Metric_visits          Metric = 2
	Metric_pageviews       Metric = 3
	Metric_views_per_visit Metric = 4
	Metric_bounce_rate     Metric = 5
	Metric_visit_duration  Metric = 6
	Metric_events          Metric = 7
)

func (Metric) Descriptor 

func (Metric) Descriptor() protoreflect.EnumDescriptor

func (Metric) Enum 

func (x Metric) Enum() *Metric

func (Metric) EnumDescriptor deprecated 

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

Deprecated: Use Metric.Descriptor instead.

func (Metric) Number 

func (x Metric) Number() protoreflect.EnumNumber

func (Metric) String 

func (x Metric) String() string

func (Metric) Type 

func (Metric) Type() protoreflect.EnumType

type Node 

type Node struct {
	Id        string  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ApiAddr   string  `protobuf:"bytes,2,opt,name=api_addr,json=apiAddr,proto3" json:"api_addr,omitempty"`
	Addr      string  `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"`
	Voter     bool    `protobuf:"varint,4,opt,name=voter,proto3" json:"voter,omitempty"`
	Reachable bool    `protobuf:"varint,5,opt,name=reachable,proto3" json:"reachable,omitempty"`
	Time      float64 `protobuf:"fixed64,6,opt,name=time,proto3" json:"time,omitempty"`
	TimeS     string  `protobuf:"bytes,7,opt,name=time_s,json=timeS,proto3" json:"time_s,omitempty"`
	Error     string  `protobuf:"bytes,8,opt,name=error,proto3" json:"error,omitempty"`
	Leader    bool    `protobuf:"varint,9,opt,name=leader,proto3" json:"leader,omitempty"`
	// contains filtered or unexported fields
}

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetAddr 

func (x *Node) GetAddr() string

func (*Node) GetApiAddr 

func (x *Node) GetApiAddr() string

func (*Node) GetError 

func (x *Node) GetError() string

func (*Node) GetId 

func (x *Node) GetId() string

func (*Node) GetLeader 

func (x *Node) GetLeader() bool

func (*Node) GetReachable 

func (x *Node) GetReachable() bool

func (*Node) GetTime 

func (x *Node) GetTime() float64

func (*Node) GetTimeS 

func (x *Node) GetTimeS() string

func (*Node) GetVoter 

func (x *Node) GetVoter() bool

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

type NodeAPIRequest 

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

func (*NodeAPIRequest) Descriptor deprecated 

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

Deprecated: Use NodeAPIRequest.ProtoReflect.Descriptor instead.

func (*NodeAPIRequest) ProtoMessage 

func (*NodeAPIRequest) ProtoMessage()

func (*NodeAPIRequest) ProtoReflect 

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

func (*NodeAPIRequest) Reset 

func (x *NodeAPIRequest) Reset()

func (*NodeAPIRequest) String 

func (x *NodeAPIRequest) String() string

type NodeMeta 

type NodeMeta struct {
	Url         string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	CommitIndex uint64 `protobuf:"varint,2,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeMeta) Descriptor deprecated 

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

Deprecated: Use NodeMeta.ProtoReflect.Descriptor instead.

func (*NodeMeta) GetCommitIndex 

func (x *NodeMeta) GetCommitIndex() uint64

func (*NodeMeta) GetUrl 

func (x *NodeMeta) GetUrl() string

func (*NodeMeta) ProtoMessage 

func (*NodeMeta) ProtoMessage()

func (*NodeMeta) ProtoReflect 

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

func (*NodeMeta) Reset 

func (x *NodeMeta) Reset()

func (*NodeMeta) String 

func (x *NodeMeta) String() string

type Node_List 

type Node_List struct {
	Items []*Node `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*Node_List) Descriptor deprecated 

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

Deprecated: Use Node_List.ProtoReflect.Descriptor instead.

func (*Node_List) GetItems 

func (x *Node_List) GetItems() []*Node

func (*Node_List) ProtoMessage 

func (*Node_List) ProtoMessage()

func (*Node_List) ProtoReflect 

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

func (*Node_List) Reset 

func (x *Node_List) Reset()

func (*Node_List) String 

func (x *Node_List) String() string

type Notify 

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

func (*Notify) Descriptor deprecated 

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

Deprecated: Use Notify.ProtoReflect.Descriptor instead.

func (*Notify) ProtoMessage 

func (*Notify) ProtoMessage()

func (*Notify) ProtoReflect 

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

func (*Notify) Reset 

func (x *Notify) Reset()

func (*Notify) String 

func (x *Notify) String() string

type Notify_Request 

type Notify_Request struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*Notify_Request) Descriptor deprecated 

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

Deprecated: Use Notify_Request.ProtoReflect.Descriptor instead.

func (*Notify_Request) GetAddress 

func (x *Notify_Request) GetAddress() string

func (*Notify_Request) GetId 

func (x *Notify_Request) GetId() string

func (*Notify_Request) ProtoMessage 

func (*Notify_Request) ProtoMessage()

func (*Notify_Request) ProtoReflect 

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

func (*Notify_Request) Reset 

func (x *Notify_Request) Reset()

func (*Notify_Request) String 

func (x *Notify_Request) String() string

type PrimaryIndex 

type PrimaryIndex struct {
	Resources map[string]*PrimaryIndex_Resource `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PrimaryIndex) Descriptor deprecated 

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

Deprecated: Use PrimaryIndex.ProtoReflect.Descriptor instead.

func (*PrimaryIndex) GetResources 

func (x *PrimaryIndex) GetResources() map[string]*PrimaryIndex_Resource

func (*PrimaryIndex) ProtoMessage 

func (*PrimaryIndex) ProtoMessage()

func (*PrimaryIndex) ProtoReflect 

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

func (*PrimaryIndex) Reset 

func (x *PrimaryIndex) Reset()

func (*PrimaryIndex) String 

func (x *PrimaryIndex) String() string

type PrimaryIndex_Resource 

type PrimaryIndex_Resource struct {
	Name     string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Granules map[string]*Granule `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PrimaryIndex_Resource) Descriptor deprecated 

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

Deprecated: Use PrimaryIndex_Resource.ProtoReflect.Descriptor instead.

func (*PrimaryIndex_Resource) GetGranules 

func (x *PrimaryIndex_Resource) GetGranules() map[string]*Granule

func (*PrimaryIndex_Resource) GetName 

func (x *PrimaryIndex_Resource) GetName() string

func (*PrimaryIndex_Resource) ProtoMessage 

func (*PrimaryIndex_Resource) ProtoMessage()

func (*PrimaryIndex_Resource) ProtoReflect 

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

func (*PrimaryIndex_Resource) Reset 

func (x *PrimaryIndex_Resource) Reset()

func (*PrimaryIndex_Resource) String 

func (x *PrimaryIndex_Resource) String() string

type Property 

type Property int32
const (
	Property_event           Property = 0
	Property_browser         Property = 7
	Property_browser_version Property = 8
	Property_city            Property = 9
	Property_country         Property = 10
	Property_device          Property = 11
	Property_domain          Property = 12
	Property_entry_page      Property = 13
	Property_exit_page       Property = 15
	Property_host            Property = 16
	Property_os              Property = 17
	Property_os_version      Property = 18
	Property_page            Property = 19
	Property_referrer        Property = 20
	Property_region          Property = 21
	Property_source          Property = 22
	Property_tenant_id       Property = 23
	Property_utm_campaign    Property = 24
	Property_utm_content     Property = 25
	Property_utm_medium      Property = 26
	Property_utm_source      Property = 27
	Property_utm_term        Property = 28
)

func (Property) Descriptor 

func (Property) Descriptor() protoreflect.EnumDescriptor

func (Property) Enum 

func (x Property) Enum() *Property

func (Property) EnumDescriptor deprecated 

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

Deprecated: Use Property.Descriptor instead.

func (Property) Number 

func (x Property) Number() protoreflect.EnumNumber

func (Property) String 

func (x Property) String() string

func (Property) Type 

func (Property) Type() protoreflect.EnumType

type RPCHeader 

type RPCHeader struct {
	ProtocolVersion int64  `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	Id              []byte `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Addr            []byte `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"`
	// contains filtered or unexported fields
}

func (*RPCHeader) Descriptor deprecated 

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

Deprecated: Use RPCHeader.ProtoReflect.Descriptor instead.

func (*RPCHeader) GetAddr 

func (x *RPCHeader) GetAddr() []byte

func (*RPCHeader) GetId 

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

func (*RPCHeader) GetProtocolVersion 

func (x *RPCHeader) GetProtocolVersion() int64

func (*RPCHeader) ProtoMessage 

func (*RPCHeader) ProtoMessage()

func (*RPCHeader) ProtoReflect 

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

func (*RPCHeader) Reset 

func (x *RPCHeader) Reset()

func (*RPCHeader) String 

func (x *RPCHeader) String() string

type RaftNode 

type RaftNode struct {
	Id               string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Ca               string   `protobuf:"bytes,2,opt,name=ca,proto3" json:"ca,omitempty"`
	Cert             string   `protobuf:"bytes,3,opt,name=cert,proto3" json:"cert,omitempty"`
	Key              string   `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	Verify           bool     `protobuf:"varint,5,opt,name=verify,proto3" json:"verify,omitempty"`
	VerifyClient     bool     `protobuf:"varint,6,opt,name=verify_client,json=verifyClient,proto3" json:"verify_client,omitempty"`
	VerifyServerName bool     `protobuf:"varint,7,opt,name=verify_server_name,json=verifyServerName,proto3" json:"verify_server_name,omitempty"`
	Advertise        string   `protobuf:"bytes,8,opt,name=advertise,proto3" json:"advertise,omitempty"`
	Joins            []string `protobuf:"bytes,9,rep,name=joins,proto3" json:"joins,omitempty"`
	NonVoter         bool     `protobuf:"varint,10,opt,name=non_voter,json=nonVoter,proto3" json:"non_voter,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftNode) Descriptor deprecated 

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

Deprecated: Use RaftNode.ProtoReflect.Descriptor instead.

func (*RaftNode) GetAdvertise 

func (x *RaftNode) GetAdvertise() string

func (*RaftNode) GetCa 

func (x *RaftNode) GetCa() string

func (*RaftNode) GetCert 

func (x *RaftNode) GetCert() string

func (*RaftNode) GetId 

func (x *RaftNode) GetId() string

func (*RaftNode) GetJoins 

func (x *RaftNode) GetJoins() []string

func (*RaftNode) GetKey 

func (x *RaftNode) GetKey() string

func (*RaftNode) GetNonVoter 

func (x *RaftNode) GetNonVoter() bool

func (*RaftNode) GetVerify 

func (x *RaftNode) GetVerify() bool

func (*RaftNode) GetVerifyClient 

func (x *RaftNode) GetVerifyClient() bool

func (*RaftNode) GetVerifyServerName 

func (x *RaftNode) GetVerifyServerName() bool

func (*RaftNode) ProtoMessage 

func (*RaftNode) ProtoMessage()

func (*RaftNode) ProtoReflect 

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

func (*RaftNode) Reset 

func (x *RaftNode) Reset()

func (*RaftNode) String 

func (x *RaftNode) String() string

type RaftTransportClient 

type RaftTransportClient interface {
	// AppendEntriesPipeline opens an AppendEntries message stream.
	AppendEntriesPipeline(ctx context.Context, opts ...grpc.CallOption) (RaftTransport_AppendEntriesPipelineClient, error)
	// AppendEntries performs a single append entries request / response.
	AppendEntries(ctx context.Context, in *AppendEntriesRequest, opts ...grpc.CallOption) (*AppendEntriesResponse, error)
	// RequestVote is the command used by a candidate to ask a Raft peer for a
	// vote in an election.
	RequestVote(ctx context.Context, in *RequestVoteRequest, opts ...grpc.CallOption) (*RequestVoteResponse, error)
	// TimeoutNow is used to start a leadership transfer to the target node.
	TimeoutNow(ctx context.Context, in *TimeoutNowRequest, opts ...grpc.CallOption) (*TimeoutNowResponse, error)
	// InstallSnapshot is the command sent to a Raft peer to bootstrap its log
	// (and state machine) from a snapshot on another peer.
	InstallSnapshot(ctx context.Context, opts ...grpc.CallOption) (RaftTransport_InstallSnapshotClient, error)
}

RaftTransportClient is the client API for RaftTransport service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRaftTransportClient 

func NewRaftTransportClient(cc grpc.ClientConnInterface) RaftTransportClient

type RaftTransportServer 

type RaftTransportServer interface {
	// AppendEntriesPipeline opens an AppendEntries message stream.
	AppendEntriesPipeline(RaftTransport_AppendEntriesPipelineServer) error
	// AppendEntries performs a single append entries request / response.
	AppendEntries(context.Context, *AppendEntriesRequest) (*AppendEntriesResponse, error)
	// RequestVote is the command used by a candidate to ask a Raft peer for a
	// vote in an election.
	RequestVote(context.Context, *RequestVoteRequest) (*RequestVoteResponse, error)
	// TimeoutNow is used to start a leadership transfer to the target node.
	TimeoutNow(context.Context, *TimeoutNowRequest) (*TimeoutNowResponse, error)
	// InstallSnapshot is the command sent to a Raft peer to bootstrap its log
	// (and state machine) from a snapshot on another peer.
	InstallSnapshot(RaftTransport_InstallSnapshotServer) error
	// contains filtered or unexported methods
}

RaftTransportServer is the server API for RaftTransport service. All implementations must embed UnimplementedRaftTransportServer for forward compatibility

type RaftTransport_AppendEntriesPipelineClient 

type RaftTransport_AppendEntriesPipelineClient interface {
	Send(*AppendEntriesRequest) error
	Recv() (*AppendEntriesResponse, error)
	grpc.ClientStream
}

type RaftTransport_AppendEntriesPipelineServer 

type RaftTransport_AppendEntriesPipelineServer interface {
	Send(*AppendEntriesResponse) error
	Recv() (*AppendEntriesRequest, error)
	grpc.ServerStream
}

type RaftTransport_InstallSnapshotClient 

type RaftTransport_InstallSnapshotClient interface {
	Send(*InstallSnapshotRequest) error
	CloseAndRecv() (*InstallSnapshotResponse, error)
	grpc.ClientStream
}

type RaftTransport_InstallSnapshotServer 

type RaftTransport_InstallSnapshotServer interface {
	SendAndClose(*InstallSnapshotResponse) error
	Recv() (*InstallSnapshotRequest, error)
	grpc.ServerStream
}

type Realtime 

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

func (*Realtime) Descriptor deprecated 

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

Deprecated: Use Realtime.ProtoReflect.Descriptor instead.

func (*Realtime) ProtoMessage 

func (*Realtime) ProtoMessage()

func (*Realtime) ProtoReflect 

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

func (*Realtime) Reset 

func (x *Realtime) Reset()

func (*Realtime) String 

func (x *Realtime) String() string

type Realtime_Request 

type Realtime_Request struct {
	SiteId   string `protobuf:"bytes,1,opt,name=site_id,json=siteId,proto3" json:"site_id,omitempty"`
	TenantId string `protobuf:"bytes,2,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Realtime_Request) Descriptor deprecated 

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

Deprecated: Use Realtime_Request.ProtoReflect.Descriptor instead.

func (*Realtime_Request) GetSiteId 

func (x *Realtime_Request) GetSiteId() string

func (*Realtime_Request) GetTenantId 

func (x *Realtime_Request) GetTenantId() string

func (*Realtime_Request) ProtoMessage 

func (*Realtime_Request) ProtoMessage()

func (*Realtime_Request) ProtoReflect 

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

func (*Realtime_Request) Reset 

func (x *Realtime_Request) Reset()

func (*Realtime_Request) String 

func (x *Realtime_Request) String() string

type Realtime_Response 

type Realtime_Response struct {
	Visitors uint64 `protobuf:"varint,1,opt,name=visitors,proto3" json:"visitors,omitempty"`
	// contains filtered or unexported fields
}

func (*Realtime_Response) Descriptor deprecated 

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

Deprecated: Use Realtime_Response.ProtoReflect.Descriptor instead.

func (*Realtime_Response) GetVisitors 

func (x *Realtime_Response) GetVisitors() uint64

func (*Realtime_Response) ProtoMessage 

func (*Realtime_Response) ProtoMessage()

func (*Realtime_Response) ProtoReflect 

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

func (*Realtime_Response) Reset 

func (x *Realtime_Response) Reset()

func (*Realtime_Response) String 

func (x *Realtime_Response) String() string

type RemoveNode 

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

func (*RemoveNode) Descriptor deprecated 

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

Deprecated: Use RemoveNode.ProtoReflect.Descriptor instead.

func (*RemoveNode) ProtoMessage 

func (*RemoveNode) ProtoMessage()

func (*RemoveNode) ProtoReflect 

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

func (*RemoveNode) Reset 

func (x *RemoveNode) Reset()

func (*RemoveNode) String 

func (x *RemoveNode) String() string

type RemoveNode_Request 

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

func (*RemoveNode_Request) Descriptor deprecated 

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

Deprecated: Use RemoveNode_Request.ProtoReflect.Descriptor instead.

func (*RemoveNode_Request) GetId 

func (x *RemoveNode_Request) GetId() string

func (*RemoveNode_Request) ProtoMessage 

func (*RemoveNode_Request) ProtoMessage()

func (*RemoveNode_Request) ProtoReflect 

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

func (*RemoveNode_Request) Reset 

func (x *RemoveNode_Request) Reset()

func (*RemoveNode_Request) String 

func (x *RemoveNode_Request) String() string

type RequestVoteRequest 

type RequestVoteRequest struct {
	RpcHeader          *RPCHeader `protobuf:"bytes,1,opt,name=rpc_header,json=rpcHeader,proto3" json:"rpc_header,omitempty"`
	Term               uint64     `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
	Candidate          []byte     `protobuf:"bytes,3,opt,name=candidate,proto3" json:"candidate,omitempty"`
	LastLogIndex       uint64     `protobuf:"varint,4,opt,name=last_log_index,json=lastLogIndex,proto3" json:"last_log_index,omitempty"`
	LastLogTerm        uint64     `protobuf:"varint,5,opt,name=last_log_term,json=lastLogTerm,proto3" json:"last_log_term,omitempty"`
	LeadershipTransfer bool       `protobuf:"varint,6,opt,name=leadership_transfer,json=leadershipTransfer,proto3" json:"leadership_transfer,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestVoteRequest) Descriptor deprecated 

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

Deprecated: Use RequestVoteRequest.ProtoReflect.Descriptor instead.

func (*RequestVoteRequest) GetCandidate 

func (x *RequestVoteRequest) GetCandidate() []byte

func (*RequestVoteRequest) GetLastLogIndex 

func (x *RequestVoteRequest) GetLastLogIndex() uint64

func (*RequestVoteRequest) GetLastLogTerm 

func (x *RequestVoteRequest) GetLastLogTerm() uint64

func (*RequestVoteRequest) GetLeadershipTransfer 

func (x *RequestVoteRequest) GetLeadershipTransfer() bool

func (*RequestVoteRequest) GetRpcHeader 

func (x *RequestVoteRequest) GetRpcHeader() *RPCHeader

func (*RequestVoteRequest) GetTerm 

func (x *RequestVoteRequest) GetTerm() uint64

func (*RequestVoteRequest) ProtoMessage 

func (*RequestVoteRequest) ProtoMessage()

func (*RequestVoteRequest) ProtoReflect 

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

func (*RequestVoteRequest) Reset 

func (x *RequestVoteRequest) Reset()

func (*RequestVoteRequest) String 

func (x *RequestVoteRequest) String() string

type RequestVoteResponse 

type RequestVoteResponse struct {
	RpcHeader *RPCHeader `protobuf:"bytes,1,opt,name=rpc_header,json=rpcHeader,proto3" json:"rpc_header,omitempty"`
	Term      uint64     `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
	Peers     []byte     `protobuf:"bytes,3,opt,name=peers,proto3" json:"peers,omitempty"`
	Granted   bool       `protobuf:"varint,4,opt,name=granted,proto3" json:"granted,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestVoteResponse) Descriptor deprecated 

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

Deprecated: Use RequestVoteResponse.ProtoReflect.Descriptor instead.

func (*RequestVoteResponse) GetGranted 

func (x *RequestVoteResponse) GetGranted() bool

func (*RequestVoteResponse) GetPeers 

func (x *RequestVoteResponse) GetPeers() []byte

func (*RequestVoteResponse) GetRpcHeader 

func (x *RequestVoteResponse) GetRpcHeader() *RPCHeader

func (*RequestVoteResponse) GetTerm 

func (x *RequestVoteResponse) GetTerm() uint64

func (*RequestVoteResponse) ProtoMessage 

func (*RequestVoteResponse) ProtoMessage()

func (*RequestVoteResponse) ProtoReflect 

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

func (*RequestVoteResponse) Reset 

func (x *RequestVoteResponse) Reset()

func (*RequestVoteResponse) String 

func (x *RequestVoteResponse) String() string

type SendEventResponse 

type SendEventResponse struct {
	Dropped bool `protobuf:"varint,1,opt,name=dropped,proto3" json:"dropped,omitempty"`
	// contains filtered or unexported fields
}

func (*SendEventResponse) Descriptor deprecated 

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

Deprecated: Use SendEventResponse.ProtoReflect.Descriptor instead.

func (*SendEventResponse) GetDropped 

func (x *SendEventResponse) GetDropped() bool

func (*SendEventResponse) ProtoMessage 

func (*SendEventResponse) ProtoMessage()

func (*SendEventResponse) ProtoReflect 

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

func (*SendEventResponse) Reset 

func (x *SendEventResponse) Reset()

func (*SendEventResponse) String 

func (x *SendEventResponse) String() string

type Server 

type Server struct {
	Id       string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Addr     string          `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	Suffrage Server_Suffrage `protobuf:"varint,3,opt,name=suffrage,proto3,enum=v1.Server_Suffrage" json:"suffrage,omitempty"`
	// contains filtered or unexported fields
}

func (*Server) Descriptor deprecated 

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

Deprecated: Use Server.ProtoReflect.Descriptor instead.

func (*Server) GetAddr 

func (x *Server) GetAddr() string

func (*Server) GetId 

func (x *Server) GetId() string

func (*Server) GetSuffrage 

func (x *Server) GetSuffrage() Server_Suffrage

func (*Server) ProtoMessage 

func (*Server) ProtoMessage()

func (*Server) ProtoReflect 

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

func (*Server) Reset 

func (x *Server) Reset()

func (*Server) String 

func (x *Server) String() string

type Server_List 

type Server_List struct {
	Items []*Server `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*Server_List) Descriptor deprecated 

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

Deprecated: Use Server_List.ProtoReflect.Descriptor instead.

func (*Server_List) GetItems 

func (x *Server_List) GetItems() []*Server

func (*Server_List) ProtoMessage 

func (*Server_List) ProtoMessage()

func (*Server_List) ProtoReflect 

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

func (*Server_List) Reset 

func (x *Server_List) Reset()

func (*Server_List) String 

func (x *Server_List) String() string

type Server_Suffrage 

type Server_Suffrage int32
const (
	Server_Voter    Server_Suffrage = 0
	Server_NotVoter Server_Suffrage = 1
	Server_Staging  Server_Suffrage = 2
)

func (Server_Suffrage) Descriptor 

func (Server_Suffrage) Descriptor() protoreflect.EnumDescriptor

func (Server_Suffrage) Enum 

func (x Server_Suffrage) Enum() *Server_Suffrage

func (Server_Suffrage) EnumDescriptor deprecated 

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

Deprecated: Use Server_Suffrage.Descriptor instead.

func (Server_Suffrage) Number 

func (x Server_Suffrage) Number() protoreflect.EnumNumber

func (Server_Suffrage) String 

func (x Server_Suffrage) String() string

func (Server_Suffrage) Type 

func (Server_Suffrage) Type() protoreflect.EnumType

type Status 

type Status struct {
	Os      *Status_Os      `protobuf:"bytes,1,opt,name=os,proto3" json:"os,omitempty"`
	Runtime *Status_Runtime `protobuf:"bytes,2,opt,name=runtime,proto3" json:"runtime,omitempty"`
	Store   *Status_Store   `protobuf:"bytes,3,opt,name=store,proto3" json:"store,omitempty"`
	Http    *Status_HTTP    `protobuf:"bytes,4,opt,name=http,proto3" json:"http,omitempty"`
	Node    *Status_Node    `protobuf:"bytes,5,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetHttp 

func (x *Status) GetHttp() *Status_HTTP

func (*Status) GetNode 

func (x *Status) GetNode() *Status_Node

func (*Status) GetOs 

func (x *Status) GetOs() *Status_Os

func (*Status) GetRuntime 

func (x *Status) GetRuntime() *Status_Runtime

func (*Status) GetStore 

func (x *Status) GetStore() *Status_Store

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

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

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type Status_Cluster 

type Status_Cluster struct {
	Timeout          *durationpb.Duration `protobuf:"bytes,1,opt,name=timeout,proto3" json:"timeout,omitempty"`
	LocalNodeAddress string               `protobuf:"bytes,2,opt,name=local_node_address,json=localNodeAddress,proto3" json:"local_node_address,omitempty"`
	// contains filtered or unexported fields
}

func (*Status_Cluster) Descriptor deprecated 

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

Deprecated: Use Status_Cluster.ProtoReflect.Descriptor instead.

func (*Status_Cluster) GetLocalNodeAddress 

func (x *Status_Cluster) GetLocalNodeAddress() string

func (*Status_Cluster) GetTimeout 

func (x *Status_Cluster) GetTimeout() *durationpb.Duration

func (*Status_Cluster) ProtoMessage 

func (*Status_Cluster) ProtoMessage()

func (*Status_Cluster) ProtoReflect 

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

func (*Status_Cluster) Reset 

func (x *Status_Cluster) Reset()

func (*Status_Cluster) String 

func (x *Status_Cluster) String() string

type Status_HTTP 

type Status_HTTP struct {
	EnabledAuth bool            `protobuf:"varint,2,opt,name=enabled_auth,json=enabledAuth,proto3" json:"enabled_auth,omitempty"`
	Cluster     *Status_Cluster `protobuf:"bytes,4,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*Status_HTTP) Descriptor deprecated 

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

Deprecated: Use Status_HTTP.ProtoReflect.Descriptor instead.

func (*Status_HTTP) GetCluster 

func (x *Status_HTTP) GetCluster() *Status_Cluster

func (*Status_HTTP) GetEnabledAuth 

func (x *Status_HTTP) GetEnabledAuth() bool

func (*Status_HTTP) ProtoMessage 

func (*Status_HTTP) ProtoMessage()

func (*Status_HTTP) ProtoReflect 

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

func (*Status_HTTP) Reset 

func (x *Status_HTTP) Reset()

func (*Status_HTTP) String 

func (x *Status_HTTP) String() string

type Status_Node 

type Status_Node struct {
	StartTime   *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	CurrentTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=current_time,json=currentTime,proto3" json:"current_time,omitempty"`
	Uptime      *durationpb.Duration   `protobuf:"bytes,3,opt,name=uptime,proto3" json:"uptime,omitempty"`
	// contains filtered or unexported fields
}

func (*Status_Node) Descriptor deprecated 

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

Deprecated: Use Status_Node.ProtoReflect.Descriptor instead.

func (*Status_Node) GetCurrentTime 

func (x *Status_Node) GetCurrentTime() *timestamppb.Timestamp

func (*Status_Node) GetStartTime 

func (x *Status_Node) GetStartTime() *timestamppb.Timestamp

func (*Status_Node) GetUptime 

func (x *Status_Node) GetUptime() *durationpb.Duration

func (*Status_Node) ProtoMessage 

func (*Status_Node) ProtoMessage()

func (*Status_Node) ProtoReflect 

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

func (*Status_Node) Reset 

func (x *Status_Node) Reset()

func (*Status_Node) String 

func (x *Status_Node) String() string

type Status_Os 

type Status_Os struct {
	Pid        int32  `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	Ppid       int32  `protobuf:"varint,2,opt,name=ppid,proto3" json:"ppid,omitempty"`
	PageSize   int32  `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	Executable string `protobuf:"bytes,4,opt,name=executable,proto3" json:"executable,omitempty"`
	Hostname   string `protobuf:"bytes,5,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

func (*Status_Os) Descriptor deprecated 

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

Deprecated: Use Status_Os.ProtoReflect.Descriptor instead.

func (*Status_Os) GetExecutable 

func (x *Status_Os) GetExecutable() string

func (*Status_Os) GetHostname 

func (x *Status_Os) GetHostname() string

func (*Status_Os) GetPageSize 

func (x *Status_Os) GetPageSize() int32

func (*Status_Os) GetPid 

func (x *Status_Os) GetPid() int32

func (*Status_Os) GetPpid 

func (x *Status_Os) GetPpid() int32

func (*Status_Os) ProtoMessage 

func (*Status_Os) ProtoMessage()

func (*Status_Os) ProtoReflect 

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

func (*Status_Os) Reset 

func (x *Status_Os) Reset()

func (*Status_Os) String 

func (x *Status_Os) String() string

type Status_Runtime 

type Status_Runtime struct {
	Os       string `protobuf:"bytes,1,opt,name=os,proto3" json:"os,omitempty"`
	Arch     string `protobuf:"bytes,2,opt,name=arch,proto3" json:"arch,omitempty"`
	MaxProcs int32  `protobuf:"varint,3,opt,name=max_procs,json=maxProcs,proto3" json:"max_procs,omitempty"`
	NumCpu   int32  `protobuf:"varint,4,opt,name=num_cpu,json=numCpu,proto3" json:"num_cpu,omitempty"`
	Version  string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*Status_Runtime) Descriptor deprecated 

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

Deprecated: Use Status_Runtime.ProtoReflect.Descriptor instead.

func (*Status_Runtime) GetArch 

func (x *Status_Runtime) GetArch() string

func (*Status_Runtime) GetMaxProcs 

func (x *Status_Runtime) GetMaxProcs() int32

func (*Status_Runtime) GetNumCpu 

func (x *Status_Runtime) GetNumCpu() int32

func (*Status_Runtime) GetOs 

func (x *Status_Runtime) GetOs() string

func (*Status_Runtime) GetVersion 

func (x *Status_Runtime) GetVersion() string

func (*Status_Runtime) ProtoMessage 

func (*Status_Runtime) ProtoMessage()

func (*Status_Runtime) ProtoReflect 

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

func (*Status_Runtime) Reset 

func (x *Status_Runtime) Reset()

func (*Status_Runtime) String 

func (x *Status_Runtime) String() string

type Status_Store 

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

func (*Status_Store) Descriptor deprecated 

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

Deprecated: Use Status_Store.ProtoReflect.Descriptor instead.

func (*Status_Store) ProtoMessage 

func (*Status_Store) ProtoMessage()

func (*Status_Store) ProtoReflect 

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

func (*Status_Store) Reset 

func (x *Status_Store) Reset()

func (*Status_Store) String 

func (x *Status_Store) String() string

type Status_TLS 

type Status_TLS struct {
	Enabled    bool     `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	ClientAuth string   `protobuf:"bytes,2,opt,name=client_auth,json=clientAuth,proto3" json:"client_auth,omitempty"`
	CertFile   string   `protobuf:"bytes,3,opt,name=cert_file,json=certFile,proto3" json:"cert_file,omitempty"`
	KeyFile    string   `protobuf:"bytes,4,opt,name=key_file,json=keyFile,proto3" json:"key_file,omitempty"`
	CaFile     string   `protobuf:"bytes,5,opt,name=ca_file,json=caFile,proto3" json:"ca_file,omitempty"`
	NextProtos []string `protobuf:"bytes,6,rep,name=next_protos,json=nextProtos,proto3" json:"next_protos,omitempty"`
	// contains filtered or unexported fields
}

func (*Status_TLS) Descriptor deprecated 

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

Deprecated: Use Status_TLS.ProtoReflect.Descriptor instead.

func (*Status_TLS) GetCaFile 

func (x *Status_TLS) GetCaFile() string

func (*Status_TLS) GetCertFile 

func (x *Status_TLS) GetCertFile() string

func (*Status_TLS) GetClientAuth 

func (x *Status_TLS) GetClientAuth() string

func (*Status_TLS) GetEnabled 

func (x *Status_TLS) GetEnabled() bool

func (*Status_TLS) GetKeyFile 

func (x *Status_TLS) GetKeyFile() string

func (*Status_TLS) GetNextProtos 

func (x *Status_TLS) GetNextProtos() []string

func (*Status_TLS) ProtoMessage 

func (*Status_TLS) ProtoMessage()

func (*Status_TLS) ProtoReflect 

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

func (*Status_TLS) Reset 

func (x *Status_TLS) Reset()

func (*Status_TLS) String 

func (x *Status_TLS) String() string

type Tenant 

type Tenant struct {
	Id      string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Domains []*Domain `protobuf:"bytes,2,rep,name=domains,proto3" json:"domains,omitempty"`
	// contains filtered or unexported fields
}

func (*Tenant) Descriptor deprecated 

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

Deprecated: Use Tenant.ProtoReflect.Descriptor instead.

func (*Tenant) GetDomains 

func (x *Tenant) GetDomains() []*Domain

func (*Tenant) GetId 

func (x *Tenant) GetId() string

func (*Tenant) ProtoMessage 

func (*Tenant) ProtoMessage()

func (*Tenant) ProtoReflect 

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

func (*Tenant) Reset 

func (x *Tenant) Reset()

func (*Tenant) String 

func (x *Tenant) String() string

type TimePeriod 

type TimePeriod struct {

	// Types that are assignable to Value:
	//
	//	*TimePeriod_Base_
	//	*TimePeriod_Custom_
	Value isTimePeriod_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*TimePeriod) Descriptor deprecated 

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

Deprecated: Use TimePeriod.ProtoReflect.Descriptor instead.

func (*TimePeriod) GetBase 

func (x *TimePeriod) GetBase() TimePeriod_Base

func (*TimePeriod) GetCustom 

func (x *TimePeriod) GetCustom() *TimePeriod_Custom

func (*TimePeriod) GetValue 

func (m *TimePeriod) GetValue() isTimePeriod_Value

func (*TimePeriod) ProtoMessage 

func (*TimePeriod) ProtoMessage()

func (*TimePeriod) ProtoReflect 

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

func (*TimePeriod) Reset 

func (x *TimePeriod) Reset()

func (*TimePeriod) String 

func (x *TimePeriod) String() string

type TimePeriod_Base 

type TimePeriod_Base int32
const (
	TimePeriod_day   TimePeriod_Base = 0
	TimePeriod__7d   TimePeriod_Base = 1
	TimePeriod__30d  TimePeriod_Base = 3
	TimePeriod_mo    TimePeriod_Base = 4
	TimePeriod__6mo  TimePeriod_Base = 5
	TimePeriod__12mo TimePeriod_Base = 6
	TimePeriod_year  TimePeriod_Base = 7
)

func (TimePeriod_Base) Descriptor 

func (TimePeriod_Base) Descriptor() protoreflect.EnumDescriptor

func (TimePeriod_Base) Enum 

func (x TimePeriod_Base) Enum() *TimePeriod_Base

func (TimePeriod_Base) EnumDescriptor deprecated 

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

Deprecated: Use TimePeriod_Base.Descriptor instead.

func (TimePeriod_Base) Number 

func (x TimePeriod_Base) Number() protoreflect.EnumNumber

func (TimePeriod_Base) String 

func (x TimePeriod_Base) String() string

func (TimePeriod_Base) Type 

func (TimePeriod_Base) Type() protoreflect.EnumType

type TimePeriod_Base_ 

type TimePeriod_Base_ struct {
	Base TimePeriod_Base `protobuf:"varint,1,opt,name=base,proto3,enum=v1.TimePeriod_Base,oneof"`
}

type TimePeriod_Custom 

type TimePeriod_Custom struct {
	Start *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	End   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*TimePeriod_Custom) Descriptor deprecated 

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

Deprecated: Use TimePeriod_Custom.ProtoReflect.Descriptor instead.

func (*TimePeriod_Custom) GetEnd 

func (x *TimePeriod_Custom) GetEnd() *timestamppb.Timestamp

func (*TimePeriod_Custom) GetStart 

func (x *TimePeriod_Custom) GetStart() *timestamppb.Timestamp

func (*TimePeriod_Custom) ProtoMessage 

func (*TimePeriod_Custom) ProtoMessage()

func (*TimePeriod_Custom) ProtoReflect 

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

func (*TimePeriod_Custom) Reset 

func (x *TimePeriod_Custom) Reset()

func (*TimePeriod_Custom) String 

func (x *TimePeriod_Custom) String() string

type TimePeriod_Custom_ 

type TimePeriod_Custom_ struct {
	Custom *TimePeriod_Custom `protobuf:"bytes,2,opt,name=custom,proto3,oneof"`
}

type TimeoutNowRequest 

type TimeoutNowRequest struct {
	RpcHeader *RPCHeader `protobuf:"bytes,1,opt,name=rpc_header,json=rpcHeader,proto3" json:"rpc_header,omitempty"`
	// contains filtered or unexported fields
}

func (*TimeoutNowRequest) Descriptor deprecated 

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

Deprecated: Use TimeoutNowRequest.ProtoReflect.Descriptor instead.

func (*TimeoutNowRequest) GetRpcHeader 

func (x *TimeoutNowRequest) GetRpcHeader() *RPCHeader

func (*TimeoutNowRequest) ProtoMessage 

func (*TimeoutNowRequest) ProtoMessage()

func (*TimeoutNowRequest) ProtoReflect 

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

func (*TimeoutNowRequest) Reset 

func (x *TimeoutNowRequest) Reset()

func (*TimeoutNowRequest) String 

func (x *TimeoutNowRequest) String() string

type TimeoutNowResponse 

type TimeoutNowResponse struct {
	RpcHeader *RPCHeader `protobuf:"bytes,1,opt,name=rpc_header,json=rpcHeader,proto3" json:"rpc_header,omitempty"`
	// contains filtered or unexported fields
}

func (*TimeoutNowResponse) Descriptor deprecated 

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

Deprecated: Use TimeoutNowResponse.ProtoReflect.Descriptor instead.

func (*TimeoutNowResponse) GetRpcHeader 

func (x *TimeoutNowResponse) GetRpcHeader() *RPCHeader

func (*TimeoutNowResponse) ProtoMessage 

func (*TimeoutNowResponse) ProtoMessage()

func (*TimeoutNowResponse) ProtoReflect 

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

func (*TimeoutNowResponse) Reset 

func (x *TimeoutNowResponse) Reset()

func (*TimeoutNowResponse) String 

func (x *TimeoutNowResponse) String() string

type Timeseries 

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

func (*Timeseries) Descriptor deprecated 

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

Deprecated: Use Timeseries.ProtoReflect.Descriptor instead.

func (*Timeseries) ProtoMessage 

func (*Timeseries) ProtoMessage()

func (*Timeseries) ProtoReflect 

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

func (*Timeseries) Reset 

func (x *Timeseries) Reset()

func (*Timeseries) String 

func (x *Timeseries) String() string

type Timeseries_Bucket 

type Timeseries_Bucket struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Values    map[string]float64     `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Timeseries_Bucket) Descriptor deprecated 

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

Deprecated: Use Timeseries_Bucket.ProtoReflect.Descriptor instead.

func (*Timeseries_Bucket) GetTimestamp 

func (x *Timeseries_Bucket) GetTimestamp() *timestamppb.Timestamp

func (*Timeseries_Bucket) GetValues 

func (x *Timeseries_Bucket) GetValues() map[string]float64

func (*Timeseries_Bucket) ProtoMessage 

func (*Timeseries_Bucket) ProtoMessage()

func (*Timeseries_Bucket) ProtoReflect 

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

func (*Timeseries_Bucket) Reset 

func (x *Timeseries_Bucket) Reset()

func (*Timeseries_Bucket) String 

func (x *Timeseries_Bucket) String() string

type Timeseries_Request 

type Timeseries_Request struct {
	SiteId   string                 `protobuf:"bytes,1,opt,name=site_id,json=siteId,proto3" json:"site_id,omitempty"`
	TenantId string                 `protobuf:"bytes,2,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Period   *TimePeriod            `protobuf:"bytes,3,opt,name=period,proto3" json:"period,omitempty"`
	Metrics  []Metric               `protobuf:"varint,4,rep,packed,name=metrics,proto3,enum=v1.Metric" json:"metrics,omitempty"`
	Interval Interval               `protobuf:"varint,5,opt,name=interval,proto3,enum=v1.Interval" json:"interval,omitempty"`
	Filters  []*Filter              `protobuf:"bytes,6,rep,name=filters,proto3" json:"filters,omitempty"`
	Date     *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=date,proto3" json:"date,omitempty"`
	// contains filtered or unexported fields
}

func (*Timeseries_Request) Descriptor deprecated 

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

Deprecated: Use Timeseries_Request.ProtoReflect.Descriptor instead.

func (*Timeseries_Request) GetDate 

func (x *Timeseries_Request) GetDate() *timestamppb.Timestamp

func (*Timeseries_Request) GetFilters 

func (x *Timeseries_Request) GetFilters() []*Filter

func (*Timeseries_Request) GetInterval 

func (x *Timeseries_Request) GetInterval() Interval

func (*Timeseries_Request) GetMetrics 

func (x *Timeseries_Request) GetMetrics() []Metric

func (*Timeseries_Request) GetPeriod 

func (x *Timeseries_Request) GetPeriod() *TimePeriod

func (*Timeseries_Request) GetSiteId 

func (x *Timeseries_Request) GetSiteId() string

func (*Timeseries_Request) GetTenantId 

func (x *Timeseries_Request) GetTenantId() string

func (*Timeseries_Request) ProtoMessage 

func (*Timeseries_Request) ProtoMessage()

func (*Timeseries_Request) ProtoReflect 

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

func (*Timeseries_Request) Reset 

func (x *Timeseries_Request) Reset()

func (*Timeseries_Request) String 

func (x *Timeseries_Request) String() string

type Timeseries_Response 

type Timeseries_Response struct {
	Results []*Timeseries_Bucket `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*Timeseries_Response) Descriptor deprecated 

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

Deprecated: Use Timeseries_Response.ProtoReflect.Descriptor instead.

func (*Timeseries_Response) GetResults 

func (x *Timeseries_Response) GetResults() []*Timeseries_Bucket

func (*Timeseries_Response) ProtoMessage 

func (*Timeseries_Response) ProtoMessage()

func (*Timeseries_Response) ProtoReflect 

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

func (*Timeseries_Response) Reset 

func (x *Timeseries_Response) Reset()

func (*Timeseries_Response) String 

func (x *Timeseries_Response) String() string

type UnimplementedInternalCLusterServer 

type UnimplementedInternalCLusterServer struct {
}

UnimplementedInternalCLusterServer must be embedded to have forward compatible implementations.

func (UnimplementedInternalCLusterServer) Aggregate 

func (UnimplementedInternalCLusterServer) Aggregate(context.Context, *Aggregate_Request) (*Aggregate_Response, error)

func (UnimplementedInternalCLusterServer) Backup 

func (UnimplementedInternalCLusterServer) Backup(*Backup_Request, InternalCLuster_BackupServer) error

func (UnimplementedInternalCLusterServer) BreakDown 

func (UnimplementedInternalCLusterServer) BreakDown(context.Context, *BreakDown_Request) (*BreakDown_Response, error)

func (UnimplementedInternalCLusterServer) Join 

func (UnimplementedInternalCLusterServer) Join(context.Context, *Join_Request) (*Join_Response, error)

func (UnimplementedInternalCLusterServer) Load 

func (UnimplementedInternalCLusterServer) Load(context.Context, *Load_Request) (*emptypb.Empty, error)

func (UnimplementedInternalCLusterServer) NodeAPI 

func (UnimplementedInternalCLusterServer) NodeAPI(context.Context, *NodeAPIRequest) (*NodeMeta, error)

func (UnimplementedInternalCLusterServer) Notify 

func (UnimplementedInternalCLusterServer) Notify(context.Context, *Notify_Request) (*emptypb.Empty, error)

func (UnimplementedInternalCLusterServer) Realtime 

func (UnimplementedInternalCLusterServer) Realtime(context.Context, *Realtime_Request) (*Realtime_Response, error)

func (UnimplementedInternalCLusterServer) RemoveNode 

func (UnimplementedInternalCLusterServer) RemoveNode(context.Context, *RemoveNode_Request) (*emptypb.Empty, error)

func (UnimplementedInternalCLusterServer) SendData 

func (UnimplementedInternalCLusterServer) SendData(context.Context, *Data) (*emptypb.Empty, error)

func (UnimplementedInternalCLusterServer) Timeseries 

func (UnimplementedInternalCLusterServer) Timeseries(context.Context, *Timeseries_Request) (*Timeseries_Response, error)

type UnimplementedRaftTransportServer 

type UnimplementedRaftTransportServer struct {
}

UnimplementedRaftTransportServer must be embedded to have forward compatible implementations.

func (UnimplementedRaftTransportServer) AppendEntries 

func (UnimplementedRaftTransportServer) AppendEntries(context.Context, *AppendEntriesRequest) (*AppendEntriesResponse, error)

func (UnimplementedRaftTransportServer) AppendEntriesPipeline 

func (UnimplementedRaftTransportServer) AppendEntriesPipeline(RaftTransport_AppendEntriesPipelineServer) error

func (UnimplementedRaftTransportServer) InstallSnapshot 

func (UnimplementedRaftTransportServer) InstallSnapshot(RaftTransport_InstallSnapshotServer) error

func (UnimplementedRaftTransportServer) RequestVote 

func (UnimplementedRaftTransportServer) RequestVote(context.Context, *RequestVoteRequest) (*RequestVoteResponse, error)

func (UnimplementedRaftTransportServer) TimeoutNow 

func (UnimplementedRaftTransportServer) TimeoutNow(context.Context, *TimeoutNowRequest) (*TimeoutNowResponse, error)

type UnsafeInternalCLusterServer 

type UnsafeInternalCLusterServer interface {
	// contains filtered or unexported methods
}

UnsafeInternalCLusterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to InternalCLusterServer will result in compilation errors.

type UnsafeRaftTransportServer 

type UnsafeRaftTransportServer interface {
	// contains filtered or unexported methods
}

UnsafeRaftTransportServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RaftTransportServer will result in compilation errors.

type Version 

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

func (*Version) Descriptor deprecated 

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

Deprecated: Use Version.ProtoReflect.Descriptor instead.

func (*Version) GetVersion 

func (x *Version) GetVersion() string

func (*Version) ProtoMessage 

func (*Version) ProtoMessage()

func (*Version) ProtoReflect 

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

func (*Version) Reset 

func (x *Version) Reset()

func (*Version) String 

func (x *Version) String() string

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.