Documentation ¶
Overview ¶
Package v1 is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Package v1 is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func RegisterStaplesHandler(ctx context.Context, mux *runtime.ServeMux, conn grpc.ClientConnInterface) error
- func RegisterStaplesHandlerClient(ctx context.Context, mux *runtime.ServeMux, client StaplesClient) error
- func RegisterStaplesHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterStaplesHandlerServer(ctx context.Context, mux *runtime.ServeMux, server StaplesServer) error
- func RegisterStaplesServer(s grpc.ServiceRegistrar, srv StaplesServer)
- func RegisterStatsHandler(ctx context.Context, mux *runtime.ServeMux, conn grpc.ClientConnInterface) error
- func RegisterStatsHandlerClient(ctx context.Context, mux *runtime.ServeMux, client StatsClient) error
- func RegisterStatsHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterStatsHandlerServer(ctx context.Context, mux *runtime.ServeMux, server StatsServer) error
- func RegisterStatsServer(s grpc.ServiceRegistrar, srv StatsServer)
- type Aggregate
- type Aggregate_Request
- func (*Aggregate_Request) Descriptor() ([]byte, []int)deprecated
- func (x *Aggregate_Request) GetCompare() bool
- func (x *Aggregate_Request) GetFilters() []*Filter
- func (x *Aggregate_Request) GetMetrics() []Metric
- func (x *Aggregate_Request) GetPeriod() *TimePeriod
- func (x *Aggregate_Request) GetSiteId() string
- func (*Aggregate_Request) ProtoMessage()
- func (x *Aggregate_Request) ProtoReflect() protoreflect.Message
- func (x *Aggregate_Request) Reset()
- func (x *Aggregate_Request) String() string
- type Aggregate_Response
- func (*Aggregate_Response) Descriptor() ([]byte, []int)deprecated
- func (x *Aggregate_Response) GetResults() []*Value
- func (*Aggregate_Response) ProtoMessage()
- func (x *Aggregate_Response) ProtoReflect() protoreflect.Message
- func (x *Aggregate_Response) Reset()
- func (x *Aggregate_Response) String() string
- type BreakDown
- type BreakDown_Request
- func (*BreakDown_Request) Descriptor() ([]byte, []int)deprecated
- func (x *BreakDown_Request) GetFilters() []*Filter
- func (x *BreakDown_Request) GetLimit() uint32
- func (x *BreakDown_Request) GetMetrics() []Metric
- func (x *BreakDown_Request) GetPeriod() *TimePeriod
- func (x *BreakDown_Request) GetProperty() []Property
- func (x *BreakDown_Request) GetSiteId() string
- func (*BreakDown_Request) ProtoMessage()
- func (x *BreakDown_Request) ProtoReflect() protoreflect.Message
- func (x *BreakDown_Request) Reset()
- func (x *BreakDown_Request) String() string
- type BreakDown_Response
- func (*BreakDown_Response) Descriptor() ([]byte, []int)deprecated
- func (x *BreakDown_Response) GetResults() []*BreakDown_Response_Result
- func (*BreakDown_Response) ProtoMessage()
- func (x *BreakDown_Response) ProtoReflect() protoreflect.Message
- func (x *BreakDown_Response) Reset()
- func (x *BreakDown_Response) String() string
- type BreakDown_Response_Group
- func (*BreakDown_Response_Group) Descriptor() ([]byte, []int)deprecated
- func (x *BreakDown_Response_Group) GetKey() string
- func (x *BreakDown_Response_Group) GetValues() []*Value
- func (*BreakDown_Response_Group) ProtoMessage()
- func (x *BreakDown_Response_Group) ProtoReflect() protoreflect.Message
- func (x *BreakDown_Response_Group) Reset()
- func (x *BreakDown_Response_Group) String() string
- type BreakDown_Response_Result
- func (*BreakDown_Response_Result) Descriptor() ([]byte, []int)deprecated
- func (x *BreakDown_Response_Result) GetGroups() []*BreakDown_Response_Group
- func (x *BreakDown_Response_Result) GetProperty() Property
- func (*BreakDown_Response_Result) ProtoMessage()
- func (x *BreakDown_Response_Result) ProtoReflect() protoreflect.Message
- func (x *BreakDown_Response_Result) Reset()
- func (x *BreakDown_Response_Result) String() string
- type Config
- func (*Config) Descriptor() ([]byte, []int)deprecated
- func (x *Config) GetData() string
- func (x *Config) GetDomains() []string
- func (x *Config) GetGeoipDbPath() string
- func (x *Config) GetGranuleSize() int64
- func (x *Config) GetListen() string
- func (x *Config) GetRateLimit() float64
- func (x *Config) GetRetentionPeriod() *durationpb.Duration
- func (*Config) ProtoMessage()
- func (x *Config) ProtoReflect() protoreflect.Message
- func (x *Config) Reset()
- func (x *Config) String() string
- type Domain
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetD() string
- func (x *Event) GetH() bool
- func (x *Event) GetIp() string
- func (x *Event) GetN() string
- func (x *Event) GetR() string
- func (x *Event) GetTimestamp() *timestamppb.Timestamp
- func (x *Event) GetUa() string
- func (x *Event) GetUrl() string
- func (x *Event) GetW() int32
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) String() string
- type Filter
- func (*Filter) Descriptor() ([]byte, []int)deprecated
- func (x *Filter) GetOp() Filter_OP
- func (x *Filter) GetProperty() Property
- func (x *Filter) GetValue() string
- func (*Filter) ProtoMessage()
- func (x *Filter) ProtoReflect() protoreflect.Message
- func (x *Filter) Reset()
- func (x *Filter) String() string
- type Filter_OP
- type Filters
- type Filters_Projection
- func (Filters_Projection) Descriptor() protoreflect.EnumDescriptor
- func (x Filters_Projection) Enum() *Filters_Projection
- func (Filters_Projection) EnumDescriptor() ([]byte, []int)deprecated
- func (x Filters_Projection) Number() protoreflect.EnumNumber
- func (x Filters_Projection) String() string
- func (Filters_Projection) Type() protoreflect.EnumType
- type GetDomainRequest
- type GetDomainResponse
- func (*GetDomainResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetDomainResponse) GetDomains() []*Domain
- func (*GetDomainResponse) ProtoMessage()
- func (x *GetDomainResponse) ProtoReflect() protoreflect.Message
- func (x *GetDomainResponse) Reset()
- func (x *GetDomainResponse) String() string
- type Granule
- func (*Granule) Descriptor() ([]byte, []int)deprecated
- func (x *Granule) GetId() string
- func (x *Granule) GetMax() int64
- func (x *Granule) GetMin() int64
- func (x *Granule) GetRows() uint64
- func (x *Granule) GetSize() uint64
- func (*Granule) ProtoMessage()
- func (x *Granule) ProtoReflect() protoreflect.Message
- func (x *Granule) Reset()
- func (x *Granule) String() string
- type Interval
- type KeyValue
- type Metric
- type PrimaryIndex
- type PrimaryIndex_Resource
- func (*PrimaryIndex_Resource) Descriptor() ([]byte, []int)deprecated
- func (x *PrimaryIndex_Resource) GetGranules() map[string]*Granule
- func (x *PrimaryIndex_Resource) GetName() string
- func (*PrimaryIndex_Resource) ProtoMessage()
- func (x *PrimaryIndex_Resource) ProtoReflect() protoreflect.Message
- func (x *PrimaryIndex_Resource) Reset()
- func (x *PrimaryIndex_Resource) String() string
- type Property
- type Realtime
- type Realtime_Request
- type Realtime_Response
- type ScanRequest
- func (*ScanRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ScanRequest) GetFilters() *Filters
- func (x *ScanRequest) GetTimestamp() *TimeRange
- func (*ScanRequest) ProtoMessage()
- func (x *ScanRequest) ProtoReflect() protoreflect.Message
- func (x *ScanRequest) Reset()
- func (x *ScanRequest) String() string
- type ScanResponse
- type SendEventResponse
- type StaplesClient
- type StaplesServer
- type StatsClient
- type StatsServer
- type TimePeriod
- func (*TimePeriod) Descriptor() ([]byte, []int)deprecated
- func (x *TimePeriod) GetBase() TimePeriod_Base
- func (x *TimePeriod) GetCustom() *TimePeriod_Custom
- func (m *TimePeriod) GetValue() isTimePeriod_Value
- func (*TimePeriod) ProtoMessage()
- func (x *TimePeriod) ProtoReflect() protoreflect.Message
- func (x *TimePeriod) Reset()
- func (x *TimePeriod) String() string
- type TimePeriod_Base
- func (TimePeriod_Base) Descriptor() protoreflect.EnumDescriptor
- func (x TimePeriod_Base) Enum() *TimePeriod_Base
- func (TimePeriod_Base) EnumDescriptor() ([]byte, []int)deprecated
- func (x TimePeriod_Base) Number() protoreflect.EnumNumber
- func (x TimePeriod_Base) String() string
- func (TimePeriod_Base) Type() protoreflect.EnumType
- type TimePeriod_Base_
- type TimePeriod_Custom
- func (*TimePeriod_Custom) Descriptor() ([]byte, []int)deprecated
- func (x *TimePeriod_Custom) GetEnd() *timestamppb.Timestamp
- func (x *TimePeriod_Custom) GetStart() *timestamppb.Timestamp
- func (*TimePeriod_Custom) ProtoMessage()
- func (x *TimePeriod_Custom) ProtoReflect() protoreflect.Message
- func (x *TimePeriod_Custom) Reset()
- func (x *TimePeriod_Custom) String() string
- type TimePeriod_Custom_
- type TimeRange
- func (*TimeRange) Descriptor() ([]byte, []int)deprecated
- func (x *TimeRange) GetEnd() *timestamppb.Timestamp
- func (x *TimeRange) GetStart() *timestamppb.Timestamp
- func (*TimeRange) ProtoMessage()
- func (x *TimeRange) ProtoReflect() protoreflect.Message
- func (x *TimeRange) Reset()
- func (x *TimeRange) String() string
- type Timeseries
- type Timeseries_Bucket
- func (*Timeseries_Bucket) Descriptor() ([]byte, []int)deprecated
- func (x *Timeseries_Bucket) GetTimestamp() *timestamppb.Timestamp
- func (x *Timeseries_Bucket) GetValues() []*Value
- func (*Timeseries_Bucket) ProtoMessage()
- func (x *Timeseries_Bucket) ProtoReflect() protoreflect.Message
- func (x *Timeseries_Bucket) Reset()
- func (x *Timeseries_Bucket) String() string
- type Timeseries_Request
- func (*Timeseries_Request) Descriptor() ([]byte, []int)deprecated
- func (x *Timeseries_Request) GetFilters() []*Filter
- func (x *Timeseries_Request) GetInterval() Interval
- func (x *Timeseries_Request) GetMetrics() []Metric
- func (x *Timeseries_Request) GetPeriod() *TimePeriod
- func (x *Timeseries_Request) GetSiteId() string
- func (*Timeseries_Request) ProtoMessage()
- func (x *Timeseries_Request) ProtoReflect() protoreflect.Message
- func (x *Timeseries_Request) Reset()
- func (x *Timeseries_Request) String() string
- type Timeseries_Response
- func (*Timeseries_Response) Descriptor() ([]byte, []int)deprecated
- func (x *Timeseries_Response) GetResults() []*Timeseries_Bucket
- func (*Timeseries_Response) ProtoMessage()
- func (x *Timeseries_Response) ProtoReflect() protoreflect.Message
- func (x *Timeseries_Response) Reset()
- func (x *Timeseries_Response) String() string
- type UnimplementedStaplesServer
- func (UnimplementedStaplesServer) GetDomains(context.Context, *GetDomainRequest) (*GetDomainResponse, error)
- func (UnimplementedStaplesServer) GetVersion(context.Context, *emptypb.Empty) (*Version, error)
- func (UnimplementedStaplesServer) SendEvent(context.Context, *Event) (*SendEventResponse, error)
- type UnimplementedStatsServer
- func (UnimplementedStatsServer) Aggregate(context.Context, *Aggregate_Request) (*Aggregate_Response, error)
- func (UnimplementedStatsServer) BreakDown(context.Context, *BreakDown_Request) (*BreakDown_Response, error)
- func (UnimplementedStatsServer) RealtimeVisitors(context.Context, *Realtime_Request) (*Realtime_Response, error)
- func (UnimplementedStatsServer) Timeseries(context.Context, *Timeseries_Request) (*Timeseries_Response, error)
- type UnsafeStaplesServer
- type UnsafeStatsServer
- type Value
- type Version
Constants ¶
const ( Staples_GetVersion_FullMethodName = "/v1.Staples/GetVersion" Staples_GetDomains_FullMethodName = "/v1.Staples/GetDomains" Staples_SendEvent_FullMethodName = "/v1.Staples/SendEvent" )
const ( Stats_RealtimeVisitors_FullMethodName = "/v1.Stats/RealtimeVisitors" Stats_Aggregate_FullMethodName = "/v1.Stats/Aggregate" Stats_Timeseries_FullMethodName = "/v1.Stats/Timeseries" Stats_BreakDown_FullMethodName = "/v1.Stats/BreakDown" )
Variables ¶
var ( Filters_Projection_name = map[int32]string{ 0: "Timestamp", 1: "ID", 2: "Bounce", 3: "Session", 4: "Duration", 5: "Browser", 6: "BrowserVersion", 7: "City", 8: "Country", 9: "Domain", 10: "EntryPage", 11: "ExitPage", 12: "Host", 13: "Event", 14: "Os", 15: "OsVersion", 16: "Path", 17: "Referrer", 18: "ReferrerSource", 19: "Region", 20: "Screen", 21: "UtmCampaign", 22: "UtmContent", 23: "UtmMedium", 24: "UtmSource", 25: "UtmTerm", } Filters_Projection_value = map[string]int32{ "Timestamp": 0, "ID": 1, "Bounce": 2, "Session": 3, "Duration": 4, "Browser": 5, "BrowserVersion": 6, "City": 7, "Country": 8, "Domain": 9, "EntryPage": 10, "ExitPage": 11, "Host": 12, "Event": 13, "Os": 14, "OsVersion": 15, "Path": 16, "Referrer": 17, "ReferrerSource": 18, "Region": 19, "Screen": 20, "UtmCampaign": 21, "UtmContent": 22, "UtmMedium": 23, "UtmSource": 24, "UtmTerm": 25, } )
Enum value maps for Filters_Projection.
var ( Interval_name = map[int32]string{ 0: "minute", 1: "hour", 2: "date", 3: "week", 4: "month", } Interval_value = map[string]int32{ "minute": 0, "hour": 1, "date": 2, "week": 3, "month": 4, } )
Enum value maps for Interval.
var ( Metric_name = map[int32]string{ 0: "visitors", 2: "visits", 3: "pageviews", 4: "views_per_visit", 5: "bounce_rate", 6: "visit_duration", 7: "events", } Metric_value = map[string]int32{ "visitors": 0, "visits": 2, "pageviews": 3, "views_per_visit": 4, "bounce_rate": 5, "visit_duration": 6, "events": 7, } )
Enum value maps for Metric.
var ( Property_name = map[int32]string{ 0: "event", 2: "page", 3: "entry_page", 4: "exit_page", 5: "source", 6: "referrer", 7: "utm_source", 8: "utm_medium", 9: "utm_campaign", 10: "utm_content", 11: "utm_term", 12: "device", 13: "browser", 14: "browser_version", 15: "os", 16: "os_version", 17: "country", 18: "region", 19: "domain", 20: "city", } Property_value = map[string]int32{ "event": 0, "page": 2, "entry_page": 3, "exit_page": 4, "source": 5, "referrer": 6, "utm_source": 7, "utm_medium": 8, "utm_campaign": 9, "utm_content": 10, "utm_term": 11, "device": 12, "browser": 13, "browser_version": 14, "os": 15, "os_version": 16, "country": 17, "region": 18, "domain": 19, "city": 20, } )
Enum value maps for Property.
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.
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.
var File_staples_v1_scan_proto protoreflect.FileDescriptor
var File_staples_v1_staples_proto protoreflect.FileDescriptor
var File_staples_v1_stats_proto protoreflect.FileDescriptor
var Staples_ServiceDesc = grpc.ServiceDesc{ ServiceName: "v1.Staples", HandlerType: (*StaplesServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetVersion", Handler: _Staples_GetVersion_Handler, }, { MethodName: "GetDomains", Handler: _Staples_GetDomains_Handler, }, { MethodName: "SendEvent", Handler: _Staples_SendEvent_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "staples/v1/staples.proto", }
Staples_ServiceDesc is the grpc.ServiceDesc for Staples service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Stats_ServiceDesc = grpc.ServiceDesc{ ServiceName: "v1.Stats", HandlerType: (*StatsServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RealtimeVisitors", Handler: _Stats_RealtimeVisitors_Handler, }, { MethodName: "Aggregate", Handler: _Stats_Aggregate_Handler, }, { MethodName: "Timeseries", Handler: _Stats_Timeseries_Handler, }, { MethodName: "BreakDown", Handler: _Stats_BreakDown_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "staples/v1/stats.proto", }
Stats_ServiceDesc is the grpc.ServiceDesc for Stats service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterStaplesHandler ¶
func RegisterStaplesHandler(ctx context.Context, mux *runtime.ServeMux, conn grpc.ClientConnInterface) error
RegisterStaplesHandler registers the http handlers for service Staples to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterStaplesHandlerClient ¶
func RegisterStaplesHandlerClient(ctx context.Context, mux *runtime.ServeMux, client StaplesClient) error
RegisterStaplesHandlerClient registers the http handlers for service Staples to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "StaplesClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "StaplesClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "StaplesClient" to call the correct interceptors.
func RegisterStaplesHandlerFromEndpoint ¶
func RegisterStaplesHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterStaplesHandlerFromEndpoint is same as RegisterStaplesHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterStaplesHandlerServer ¶
func RegisterStaplesHandlerServer(ctx context.Context, mux *runtime.ServeMux, server StaplesServer) error
RegisterStaplesHandlerServer registers the http handlers for service Staples to "mux". UnaryRPC :call StaplesServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterStaplesHandlerFromEndpoint instead.
func RegisterStaplesServer ¶
func RegisterStaplesServer(s grpc.ServiceRegistrar, srv StaplesServer)
func RegisterStatsHandler ¶
func RegisterStatsHandler(ctx context.Context, mux *runtime.ServeMux, conn grpc.ClientConnInterface) error
RegisterStatsHandler registers the http handlers for service Stats to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterStatsHandlerClient ¶
func RegisterStatsHandlerClient(ctx context.Context, mux *runtime.ServeMux, client StatsClient) error
RegisterStatsHandlerClient registers the http handlers for service Stats to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "StatsClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "StatsClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "StatsClient" to call the correct interceptors.
func RegisterStatsHandlerFromEndpoint ¶
func RegisterStatsHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterStatsHandlerFromEndpoint is same as RegisterStatsHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterStatsHandlerServer ¶
func RegisterStatsHandlerServer(ctx context.Context, mux *runtime.ServeMux, server StatsServer) error
RegisterStatsHandlerServer registers the http handlers for service Stats to "mux". UnaryRPC :call StatsServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterStatsHandlerFromEndpoint instead.
func RegisterStatsServer ¶
func RegisterStatsServer(s grpc.ServiceRegistrar, srv StatsServer)
Types ¶
type Aggregate ¶
type Aggregate struct {
// contains filtered or unexported fields
}
func (*Aggregate) Descriptor
deprecated
func (*Aggregate) ProtoMessage ¶
func (*Aggregate) ProtoMessage()
func (*Aggregate) ProtoReflect ¶
func (x *Aggregate) ProtoReflect() protoreflect.Message
type Aggregate_Request ¶
type Aggregate_Request struct { SiteId string `protobuf:"bytes,1,opt,name=site_id,json=siteId,proto3" json:"site_id,omitempty"` Period *TimePeriod `protobuf:"bytes,2,opt,name=period,proto3" json:"period,omitempty"` Metrics []Metric `protobuf:"varint,3,rep,packed,name=metrics,proto3,enum=v1.Metric" json:"metrics,omitempty"` Compare bool `protobuf:"varint,4,opt,name=compare,proto3" json:"compare,omitempty"` Filters []*Filter `protobuf:"bytes,5,rep,name=filters,proto3" json:"filters,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) GetCompare ¶
func (x *Aggregate_Request) GetCompare() bool
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) 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 { Results []*Value `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"` // 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() []*Value
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 BreakDown ¶
type BreakDown struct {
// contains filtered or unexported fields
}
func (*BreakDown) Descriptor
deprecated
func (*BreakDown) ProtoMessage ¶
func (*BreakDown) ProtoMessage()
func (*BreakDown) ProtoReflect ¶
func (x *BreakDown) ProtoReflect() protoreflect.Message
type BreakDown_Request ¶
type BreakDown_Request struct { SiteId string `protobuf:"bytes,1,opt,name=site_id,json=siteId,proto3" json:"site_id,omitempty"` Property []Property `protobuf:"varint,2,rep,packed,name=property,proto3,enum=v1.Property" json:"property,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"` Limit uint32 `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"` Filters []*Filter `protobuf:"bytes,6,rep,name=filters,proto3" json:"filters,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) GetFilters ¶
func (x *BreakDown_Request) GetFilters() []*Filter
func (*BreakDown_Request) GetLimit ¶
func (x *BreakDown_Request) GetLimit() uint32
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) 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_Response_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_Response_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_Response_Group ¶
type BreakDown_Response_Group struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Values []*Value `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"` // contains filtered or unexported fields }
func (*BreakDown_Response_Group) Descriptor
deprecated
func (*BreakDown_Response_Group) Descriptor() ([]byte, []int)
Deprecated: Use BreakDown_Response_Group.ProtoReflect.Descriptor instead.
func (*BreakDown_Response_Group) GetKey ¶
func (x *BreakDown_Response_Group) GetKey() string
func (*BreakDown_Response_Group) GetValues ¶
func (x *BreakDown_Response_Group) GetValues() []*Value
func (*BreakDown_Response_Group) ProtoMessage ¶
func (*BreakDown_Response_Group) ProtoMessage()
func (*BreakDown_Response_Group) ProtoReflect ¶
func (x *BreakDown_Response_Group) ProtoReflect() protoreflect.Message
func (*BreakDown_Response_Group) Reset ¶
func (x *BreakDown_Response_Group) Reset()
func (*BreakDown_Response_Group) String ¶
func (x *BreakDown_Response_Group) String() string
type BreakDown_Response_Result ¶
type BreakDown_Response_Result struct { Property Property `protobuf:"varint,1,opt,name=property,proto3,enum=v1.Property" json:"property,omitempty"` Groups []*BreakDown_Response_Group `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups,omitempty"` // contains filtered or unexported fields }
func (*BreakDown_Response_Result) Descriptor
deprecated
func (*BreakDown_Response_Result) Descriptor() ([]byte, []int)
Deprecated: Use BreakDown_Response_Result.ProtoReflect.Descriptor instead.
func (*BreakDown_Response_Result) GetGroups ¶
func (x *BreakDown_Response_Result) GetGroups() []*BreakDown_Response_Group
func (*BreakDown_Response_Result) GetProperty ¶
func (x *BreakDown_Response_Result) GetProperty() Property
func (*BreakDown_Response_Result) ProtoMessage ¶
func (*BreakDown_Response_Result) ProtoMessage()
func (*BreakDown_Response_Result) ProtoReflect ¶
func (x *BreakDown_Response_Result) ProtoReflect() protoreflect.Message
func (*BreakDown_Response_Result) Reset ¶
func (x *BreakDown_Response_Result) Reset()
func (*BreakDown_Response_Result) String ¶
func (x *BreakDown_Response_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"` Domains []string `protobuf:"bytes,9,rep,name=domains,proto3" json:"domains,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"` // contains filtered or unexported fields }
func (*Config) Descriptor
deprecated
func (*Config) GetDomains ¶
func (*Config) GetGeoipDbPath ¶
func (*Config) GetGranuleSize ¶
func (*Config) GetRateLimit ¶
func (*Config) GetRetentionPeriod ¶
func (x *Config) GetRetentionPeriod() *durationpb.Duration
func (*Config) ProtoMessage ¶
func (*Config) ProtoMessage()
func (*Config) ProtoReflect ¶
func (x *Config) ProtoReflect() protoreflect.Message
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) ProtoMessage ¶
func (*Domain) ProtoMessage()
func (*Domain) ProtoReflect ¶
func (x *Domain) ProtoReflect() protoreflect.Message
type Event ¶
type Event struct { // / EventName N string `protobuf:"bytes,1,opt,name=n,proto3" json:"n,omitempty"` Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,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) GetTimestamp ¶
func (x *Event) GetTimestamp() *timestamppb.Timestamp
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
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) GetProperty ¶
func (*Filter) ProtoMessage ¶
func (*Filter) ProtoMessage()
func (*Filter) ProtoReflect ¶
func (x *Filter) ProtoReflect() protoreflect.Message
type Filter_OP ¶
type Filter_OP int32
func (Filter_OP) Descriptor ¶
func (Filter_OP) Descriptor() protoreflect.EnumDescriptor
func (Filter_OP) EnumDescriptor
deprecated
func (Filter_OP) Number ¶
func (x Filter_OP) Number() protoreflect.EnumNumber
func (Filter_OP) Type ¶
func (Filter_OP) Type() protoreflect.EnumType
type Filters ¶
type Filters struct { List []*Filter `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"` // columns returned Projection []Filters_Projection `protobuf:"varint,2,rep,packed,name=projection,proto3,enum=v1.Filters_Projection" json:"projection,omitempty"` // contains filtered or unexported fields }
func (*Filters) Descriptor
deprecated
func (*Filters) GetProjection ¶
func (x *Filters) GetProjection() []Filters_Projection
func (*Filters) ProtoMessage ¶
func (*Filters) ProtoMessage()
func (*Filters) ProtoReflect ¶
func (x *Filters) ProtoReflect() protoreflect.Message
type Filters_Projection ¶
type Filters_Projection int32
const ( Filters_Timestamp Filters_Projection = 0 Filters_ID Filters_Projection = 1 Filters_Bounce Filters_Projection = 2 Filters_Session Filters_Projection = 3 Filters_Duration Filters_Projection = 4 Filters_Browser Filters_Projection = 5 Filters_BrowserVersion Filters_Projection = 6 Filters_City Filters_Projection = 7 Filters_Country Filters_Projection = 8 Filters_Domain Filters_Projection = 9 Filters_EntryPage Filters_Projection = 10 Filters_ExitPage Filters_Projection = 11 Filters_Host Filters_Projection = 12 Filters_Event Filters_Projection = 13 Filters_Os Filters_Projection = 14 Filters_OsVersion Filters_Projection = 15 Filters_Path Filters_Projection = 16 Filters_Referrer Filters_Projection = 17 Filters_ReferrerSource Filters_Projection = 18 Filters_Region Filters_Projection = 19 Filters_Screen Filters_Projection = 20 Filters_UtmCampaign Filters_Projection = 21 Filters_UtmContent Filters_Projection = 22 Filters_UtmMedium Filters_Projection = 23 Filters_UtmSource Filters_Projection = 24 Filters_UtmTerm Filters_Projection = 25 )
func (Filters_Projection) Descriptor ¶
func (Filters_Projection) Descriptor() protoreflect.EnumDescriptor
func (Filters_Projection) Enum ¶
func (x Filters_Projection) Enum() *Filters_Projection
func (Filters_Projection) EnumDescriptor
deprecated
func (Filters_Projection) EnumDescriptor() ([]byte, []int)
Deprecated: Use Filters_Projection.Descriptor instead.
func (Filters_Projection) Number ¶
func (x Filters_Projection) Number() protoreflect.EnumNumber
func (Filters_Projection) String ¶
func (x Filters_Projection) String() string
func (Filters_Projection) Type ¶
func (Filters_Projection) Type() protoreflect.EnumType
type GetDomainRequest ¶
type GetDomainRequest struct {
// contains filtered or unexported fields
}
func (*GetDomainRequest) Descriptor
deprecated
func (*GetDomainRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDomainRequest.ProtoReflect.Descriptor instead.
func (*GetDomainRequest) ProtoMessage ¶
func (*GetDomainRequest) ProtoMessage()
func (*GetDomainRequest) ProtoReflect ¶
func (x *GetDomainRequest) ProtoReflect() protoreflect.Message
func (*GetDomainRequest) Reset ¶
func (x *GetDomainRequest) Reset()
func (*GetDomainRequest) String ¶
func (x *GetDomainRequest) String() string
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"` // contains filtered or unexported fields }
func (*Granule) Descriptor
deprecated
func (*Granule) ProtoMessage ¶
func (*Granule) ProtoMessage()
func (*Granule) ProtoReflect ¶
func (x *Granule) ProtoReflect() protoreflect.Message
type Interval ¶
type Interval int32
func (Interval) Descriptor ¶
func (Interval) Descriptor() protoreflect.EnumDescriptor
func (Interval) EnumDescriptor
deprecated
func (Interval) Number ¶
func (x Interval) Number() protoreflect.EnumNumber
func (Interval) Type ¶
func (Interval) Type() protoreflect.EnumType
type KeyValue ¶
type KeyValue struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*KeyValue) Descriptor
deprecated
func (*KeyValue) ProtoMessage ¶
func (*KeyValue) ProtoMessage()
func (*KeyValue) ProtoReflect ¶
func (x *KeyValue) ProtoReflect() protoreflect.Message
type Metric ¶
type Metric int32
func (Metric) Descriptor ¶
func (Metric) Descriptor() protoreflect.EnumDescriptor
func (Metric) EnumDescriptor
deprecated
func (Metric) Number ¶
func (x Metric) Number() protoreflect.EnumNumber
func (Metric) Type ¶
func (Metric) Type() protoreflect.EnumType
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_page Property = 2 Property_entry_page Property = 3 Property_exit_page Property = 4 Property_source Property = 5 Property_referrer Property = 6 Property_utm_source Property = 7 Property_utm_medium Property = 8 Property_utm_campaign Property = 9 Property_utm_content Property = 10 Property_utm_term Property = 11 Property_device Property = 12 Property_browser Property = 13 Property_browser_version Property = 14 Property_os Property = 15 Property_os_version Property = 16 Property_country Property = 17 Property_region Property = 18 Property_domain Property = 19 Property_city Property = 20 )
func (Property) Descriptor ¶
func (Property) Descriptor() protoreflect.EnumDescriptor
func (Property) EnumDescriptor
deprecated
func (Property) Number ¶
func (x Property) Number() protoreflect.EnumNumber
func (Property) Type ¶
func (Property) Type() protoreflect.EnumType
type Realtime ¶
type Realtime struct {
// contains filtered or unexported fields
}
func (*Realtime) Descriptor
deprecated
func (*Realtime) ProtoMessage ¶
func (*Realtime) ProtoMessage()
func (*Realtime) ProtoReflect ¶
func (x *Realtime) ProtoReflect() protoreflect.Message
type Realtime_Request ¶
type Realtime_Request struct { SiteId string `protobuf:"bytes,1,opt,name=site_id,json=siteId,proto3" json:"site_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) 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 ScanRequest ¶
type ScanRequest struct { Timestamp *TimeRange `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Filters *Filters `protobuf:"bytes,2,opt,name=filters,proto3" json:"filters,omitempty"` // contains filtered or unexported fields }
func (*ScanRequest) Descriptor
deprecated
func (*ScanRequest) Descriptor() ([]byte, []int)
Deprecated: Use ScanRequest.ProtoReflect.Descriptor instead.
func (*ScanRequest) GetFilters ¶
func (x *ScanRequest) GetFilters() *Filters
func (*ScanRequest) GetTimestamp ¶
func (x *ScanRequest) GetTimestamp() *TimeRange
func (*ScanRequest) ProtoMessage ¶
func (*ScanRequest) ProtoMessage()
func (*ScanRequest) ProtoReflect ¶
func (x *ScanRequest) ProtoReflect() protoreflect.Message
func (*ScanRequest) Reset ¶
func (x *ScanRequest) Reset()
func (*ScanRequest) String ¶
func (x *ScanRequest) String() string
type ScanResponse ¶
type ScanResponse struct { Record []byte `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` // contains filtered or unexported fields }
func (*ScanResponse) Descriptor
deprecated
func (*ScanResponse) Descriptor() ([]byte, []int)
Deprecated: Use ScanResponse.ProtoReflect.Descriptor instead.
func (*ScanResponse) GetRecord ¶
func (x *ScanResponse) GetRecord() []byte
func (*ScanResponse) ProtoMessage ¶
func (*ScanResponse) ProtoMessage()
func (*ScanResponse) ProtoReflect ¶
func (x *ScanResponse) ProtoReflect() protoreflect.Message
func (*ScanResponse) Reset ¶
func (x *ScanResponse) Reset()
func (*ScanResponse) String ¶
func (x *ScanResponse) 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 StaplesClient ¶
type StaplesClient interface { GetVersion(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Version, error) GetDomains(ctx context.Context, in *GetDomainRequest, opts ...grpc.CallOption) (*GetDomainResponse, error) SendEvent(ctx context.Context, in *Event, opts ...grpc.CallOption) (*SendEventResponse, error) }
StaplesClient is the client API for Staples service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewStaplesClient ¶
func NewStaplesClient(cc grpc.ClientConnInterface) StaplesClient
type StaplesServer ¶
type StaplesServer interface { GetVersion(context.Context, *emptypb.Empty) (*Version, error) GetDomains(context.Context, *GetDomainRequest) (*GetDomainResponse, error) SendEvent(context.Context, *Event) (*SendEventResponse, error) // contains filtered or unexported methods }
StaplesServer is the server API for Staples service. All implementations must embed UnimplementedStaplesServer for forward compatibility
type StatsClient ¶
type StatsClient interface { RealtimeVisitors(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) }
StatsClient is the client API for Stats service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewStatsClient ¶
func NewStatsClient(cc grpc.ClientConnInterface) StatsClient
type StatsServer ¶
type StatsServer interface { RealtimeVisitors(context.Context, *Realtime_Request) (*Realtime_Response, error) Aggregate(context.Context, *Aggregate_Request) (*Aggregate_Response, error) Timeseries(context.Context, *Timeseries_Request) (*Timeseries_Response, error) BreakDown(context.Context, *BreakDown_Request) (*BreakDown_Response, error) // contains filtered or unexported methods }
StatsServer is the server API for Stats service. All implementations must embed UnimplementedStatsServer for forward compatibility
type TimePeriod ¶
type TimePeriod struct { // Types that are assignable to Value: // // *TimePeriod_Base_ // *TimePeriod_Custom_ Value isTimePeriod_Value `protobuf_oneof:"value"` // contains filtered or unexported fields }
func (*TimePeriod) Descriptor
deprecated
func (*TimePeriod) Descriptor() ([]byte, []int)
Deprecated: Use TimePeriod.ProtoReflect.Descriptor instead.
func (*TimePeriod) GetBase ¶
func (x *TimePeriod) GetBase() TimePeriod_Base
func (*TimePeriod) GetCustom ¶
func (x *TimePeriod) GetCustom() *TimePeriod_Custom
func (*TimePeriod) GetValue ¶
func (m *TimePeriod) GetValue() isTimePeriod_Value
func (*TimePeriod) ProtoMessage ¶
func (*TimePeriod) ProtoMessage()
func (*TimePeriod) ProtoReflect ¶
func (x *TimePeriod) ProtoReflect() protoreflect.Message
func (*TimePeriod) Reset ¶
func (x *TimePeriod) Reset()
func (*TimePeriod) String ¶
func (x *TimePeriod) String() string
type TimePeriod_Base ¶
type TimePeriod_Base int32
const ( TimePeriod_day TimePeriod_Base = 0 TimePeriod__7d TimePeriod_Base = 1 TimePeriod__30d TimePeriod_Base = 3 TimePeriod_mo TimePeriod_Base = 4 TimePeriod__6mo TimePeriod_Base = 5 TimePeriod__12mo TimePeriod_Base = 6 TimePeriod_year TimePeriod_Base = 7 )
func (TimePeriod_Base) Descriptor ¶
func (TimePeriod_Base) Descriptor() protoreflect.EnumDescriptor
func (TimePeriod_Base) Enum ¶
func (x TimePeriod_Base) Enum() *TimePeriod_Base
func (TimePeriod_Base) EnumDescriptor
deprecated
func (TimePeriod_Base) EnumDescriptor() ([]byte, []int)
Deprecated: Use TimePeriod_Base.Descriptor instead.
func (TimePeriod_Base) Number ¶
func (x TimePeriod_Base) Number() protoreflect.EnumNumber
func (TimePeriod_Base) String ¶
func (x TimePeriod_Base) String() string
func (TimePeriod_Base) Type ¶
func (TimePeriod_Base) Type() protoreflect.EnumType
type TimePeriod_Base_ ¶
type TimePeriod_Base_ struct {
Base TimePeriod_Base `protobuf:"varint,1,opt,name=base,proto3,enum=v1.TimePeriod_Base,oneof"`
}
type TimePeriod_Custom ¶
type TimePeriod_Custom struct { Start *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"` End *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"` // contains filtered or unexported fields }
func (*TimePeriod_Custom) Descriptor
deprecated
func (*TimePeriod_Custom) Descriptor() ([]byte, []int)
Deprecated: Use TimePeriod_Custom.ProtoReflect.Descriptor instead.
func (*TimePeriod_Custom) GetEnd ¶
func (x *TimePeriod_Custom) GetEnd() *timestamppb.Timestamp
func (*TimePeriod_Custom) GetStart ¶
func (x *TimePeriod_Custom) GetStart() *timestamppb.Timestamp
func (*TimePeriod_Custom) ProtoMessage ¶
func (*TimePeriod_Custom) ProtoMessage()
func (*TimePeriod_Custom) ProtoReflect ¶
func (x *TimePeriod_Custom) ProtoReflect() protoreflect.Message
func (*TimePeriod_Custom) Reset ¶
func (x *TimePeriod_Custom) Reset()
func (*TimePeriod_Custom) String ¶
func (x *TimePeriod_Custom) String() string
type TimePeriod_Custom_ ¶
type TimePeriod_Custom_ struct {
Custom *TimePeriod_Custom `protobuf:"bytes,2,opt,name=custom,proto3,oneof"`
}
type TimeRange ¶
type TimeRange 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 (*TimeRange) Descriptor
deprecated
func (*TimeRange) GetEnd ¶
func (x *TimeRange) GetEnd() *timestamppb.Timestamp
func (*TimeRange) GetStart ¶
func (x *TimeRange) GetStart() *timestamppb.Timestamp
func (*TimeRange) ProtoMessage ¶
func (*TimeRange) ProtoMessage()
func (*TimeRange) ProtoReflect ¶
func (x *TimeRange) ProtoReflect() protoreflect.Message
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 []*Value `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"` // 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() []*Value
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"` Period *TimePeriod `protobuf:"bytes,2,opt,name=period,proto3" json:"period,omitempty"` Metrics []Metric `protobuf:"varint,3,rep,packed,name=metrics,proto3,enum=v1.Metric" json:"metrics,omitempty"` Interval Interval `protobuf:"varint,4,opt,name=interval,proto3,enum=v1.Interval" json:"interval,omitempty"` Filters []*Filter `protobuf:"bytes,5,rep,name=filters,proto3" json:"filters,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) 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) 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 UnimplementedStaplesServer ¶
type UnimplementedStaplesServer struct { }
UnimplementedStaplesServer must be embedded to have forward compatible implementations.
func (UnimplementedStaplesServer) GetDomains ¶
func (UnimplementedStaplesServer) GetDomains(context.Context, *GetDomainRequest) (*GetDomainResponse, error)
func (UnimplementedStaplesServer) GetVersion ¶
func (UnimplementedStaplesServer) SendEvent ¶
func (UnimplementedStaplesServer) SendEvent(context.Context, *Event) (*SendEventResponse, error)
type UnimplementedStatsServer ¶
type UnimplementedStatsServer struct { }
UnimplementedStatsServer must be embedded to have forward compatible implementations.
func (UnimplementedStatsServer) Aggregate ¶
func (UnimplementedStatsServer) Aggregate(context.Context, *Aggregate_Request) (*Aggregate_Response, error)
func (UnimplementedStatsServer) BreakDown ¶
func (UnimplementedStatsServer) BreakDown(context.Context, *BreakDown_Request) (*BreakDown_Response, error)
func (UnimplementedStatsServer) RealtimeVisitors ¶
func (UnimplementedStatsServer) RealtimeVisitors(context.Context, *Realtime_Request) (*Realtime_Response, error)
func (UnimplementedStatsServer) Timeseries ¶
func (UnimplementedStatsServer) Timeseries(context.Context, *Timeseries_Request) (*Timeseries_Response, error)
type UnsafeStaplesServer ¶
type UnsafeStaplesServer interface {
// contains filtered or unexported methods
}
UnsafeStaplesServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StaplesServer will result in compilation errors.
type UnsafeStatsServer ¶
type UnsafeStatsServer interface {
// contains filtered or unexported methods
}
UnsafeStatsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StatsServer will result in compilation errors.
type Value ¶
type Value struct { Metric Metric `protobuf:"varint,1,opt,name=metric,proto3,enum=v1.Metric" json:"metric,omitempty"` Value float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Value) Descriptor
deprecated
func (*Value) ProtoMessage ¶
func (*Value) ProtoMessage()
func (*Value) ProtoReflect ¶
func (x *Value) ProtoReflect() protoreflect.Message
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) GetVersion ¶
func (*Version) ProtoMessage ¶
func (*Version) ProtoMessage()
func (*Version) ProtoReflect ¶
func (x *Version) ProtoReflect() protoreflect.Message