v1

package
v0.0.67 Latest Latest
Warning

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

Go to latest
Published: Mar 21, 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) Enum

func (Credential_Permission) EnumDescriptor deprecated

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

Deprecated: Use Credential_Permission.Descriptor instead.

func (Credential_Permission) Number

func (Credential_Permission) String

func (x Credential_Permission) String() string

func (Credential_Permission) Type

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

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) Enum

func (Filters_Projection) EnumDescriptor deprecated

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

Deprecated: Use Filters_Projection.Descriptor instead.

func (Filters_Projection) Number

func (Filters_Projection) String

func (x Filters_Projection) String() string

func (Filters_Projection) Type

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.

type InternalCLusterServer

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

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) 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

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

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.

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) 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 (Server_Suffrage) String

func (x Server_Suffrage) String() string

func (Server_Suffrage) Type

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) 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 (TimePeriod_Base) String

func (x TimePeriod_Base) String() string

func (TimePeriod_Base) Type

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 (*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 (*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) Backup

func (UnimplementedInternalCLusterServer) BreakDown

func (UnimplementedInternalCLusterServer) Join

func (UnimplementedInternalCLusterServer) Load

func (UnimplementedInternalCLusterServer) NodeAPI

func (UnimplementedInternalCLusterServer) Notify

func (UnimplementedInternalCLusterServer) Realtime

func (UnimplementedInternalCLusterServer) RemoveNode

func (UnimplementedInternalCLusterServer) SendData

func (UnimplementedInternalCLusterServer) Timeseries

type UnimplementedRaftTransportServer

type UnimplementedRaftTransportServer struct {
}

UnimplementedRaftTransportServer must be embedded to have forward compatible implementations.

func (UnimplementedRaftTransportServer) AppendEntries

func (UnimplementedRaftTransportServer) AppendEntriesPipeline

func (UnimplementedRaftTransportServer) InstallSnapshot

func (UnimplementedRaftTransportServer) RequestVote

func (UnimplementedRaftTransportServer) TimeoutNow

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

Jump to

Keyboard shortcuts

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