Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterIntegrationsServer(s grpc.ServiceRegistrar, srv IntegrationsServer)
- func RegisterUsersServer(s grpc.ServiceRegistrar, srv UsersServer)
- type AggregateResponse
- type AttributeFilter
- func (*AttributeFilter) Descriptor() ([]byte, []int)deprecated
- func (x *AttributeFilter) GetName() string
- func (x *AttributeFilter) GetOperator() Operator
- func (x *AttributeFilter) GetValue() *structpb.Value
- func (*AttributeFilter) ProtoMessage()
- func (x *AttributeFilter) ProtoReflect() protoreflect.Message
- func (x *AttributeFilter) Reset()
- func (x *AttributeFilter) String() string
- type AttributeListResponse
- func (*AttributeListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AttributeListResponse) GetAttributes() *structpb.Struct
- func (x *AttributeListResponse) GetNextPageToken() string
- func (*AttributeListResponse) ProtoMessage()
- func (x *AttributeListResponse) ProtoReflect() protoreflect.Message
- func (x *AttributeListResponse) Reset()
- func (x *AttributeListResponse) String() string
- type AttributeRequest
- func (*AttributeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AttributeRequest) GetKey() string
- func (x *AttributeRequest) GetUserId() *UserID
- func (x *AttributeRequest) GetValue() *structpb.Value
- func (*AttributeRequest) ProtoMessage()
- func (x *AttributeRequest) ProtoReflect() protoreflect.Message
- func (x *AttributeRequest) Reset()
- func (x *AttributeRequest) String() string
- type AttributeResponse
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetData() []byte
- func (x *Event) GetDatacontenttype() string
- func (x *Event) GetDataschema() string
- func (x *Event) GetId() string
- func (x *Event) GetSessionKey() string
- func (x *Event) GetSource() string
- func (x *Event) GetSpecversion() string
- func (x *Event) GetSubject() string
- func (x *Event) GetTimestamp() *timestamppb.Timestamp
- func (x *Event) GetType() string
- func (x *Event) GetUserId() *UserID
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) String() string
- type EventListResponse
- type EventRequest
- type EventResponse
- type GetAggregateForUsersRequest
- func (*GetAggregateForUsersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetAggregateForUsersRequest) GetName() string
- func (x *GetAggregateForUsersRequest) GetType() string
- func (x *GetAggregateForUsersRequest) GetUserIds() []*UserID
- func (*GetAggregateForUsersRequest) ProtoMessage()
- func (x *GetAggregateForUsersRequest) ProtoReflect() protoreflect.Message
- func (x *GetAggregateForUsersRequest) Reset()
- func (x *GetAggregateForUsersRequest) String() string
- type GetSessionEventsRequest
- func (*GetSessionEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetSessionEventsRequest) GetBegin() *timestamppb.Timestamp
- func (x *GetSessionEventsRequest) GetEnd() *timestamppb.Timestamp
- func (x *GetSessionEventsRequest) GetLimit() int32
- func (x *GetSessionEventsRequest) GetOffset() int32
- func (x *GetSessionEventsRequest) GetOrderBy() string
- func (x *GetSessionEventsRequest) GetSessionKeys() []string
- func (x *GetSessionEventsRequest) GetUserId() *UserID
- func (*GetSessionEventsRequest) ProtoMessage()
- func (x *GetSessionEventsRequest) ProtoReflect() protoreflect.Message
- func (x *GetSessionEventsRequest) Reset()
- func (x *GetSessionEventsRequest) String() string
- type GetSessionsRequest
- func (*GetSessionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetSessionsRequest) GetBegin() *timestamppb.Timestamp
- func (x *GetSessionsRequest) GetEnd() *timestamppb.Timestamp
- func (x *GetSessionsRequest) GetLimit() int32
- func (x *GetSessionsRequest) GetOffset() int32
- func (x *GetSessionsRequest) GetOrderBy() string
- func (x *GetSessionsRequest) GetSessionKeys() []string
- func (x *GetSessionsRequest) GetUserId() *UserID
- func (*GetSessionsRequest) ProtoMessage()
- func (x *GetSessionsRequest) ProtoReflect() protoreflect.Message
- func (x *GetSessionsRequest) Reset()
- func (x *GetSessionsRequest) String() string
- type GetUsersByAggregatedTraitsRequest
- func (*GetUsersByAggregatedTraitsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetUsersByAggregatedTraitsRequest) GetBegin() *timestamppb.Timestamp
- func (x *GetUsersByAggregatedTraitsRequest) GetEnd() *timestamppb.Timestamp
- func (x *GetUsersByAggregatedTraitsRequest) GetLimit() int32
- func (x *GetUsersByAggregatedTraitsRequest) GetName() string
- func (x *GetUsersByAggregatedTraitsRequest) GetOperator() string
- func (x *GetUsersByAggregatedTraitsRequest) GetType() string
- func (x *GetUsersByAggregatedTraitsRequest) GetValue() float32
- func (*GetUsersByAggregatedTraitsRequest) ProtoMessage()
- func (x *GetUsersByAggregatedTraitsRequest) ProtoReflect() protoreflect.Message
- func (x *GetUsersByAggregatedTraitsRequest) Reset()
- func (x *GetUsersByAggregatedTraitsRequest) String() string
- type IdentifySessionRequest
- func (*IdentifySessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *IdentifySessionRequest) GetSessionKey() []string
- func (x *IdentifySessionRequest) GetUserId() *UserID
- func (*IdentifySessionRequest) ProtoMessage()
- func (x *IdentifySessionRequest) ProtoReflect() protoreflect.Message
- func (x *IdentifySessionRequest) Reset()
- func (x *IdentifySessionRequest) String() string
- type IdentifySessionResponse
- type Integration
- func (*Integration) Descriptor() ([]byte, []int)deprecated
- func (x *Integration) GetConfigPath() string
- func (x *Integration) GetEnabled() bool
- func (x *Integration) GetExecPath() string
- func (x *Integration) GetID() int32
- func (x *Integration) GetName() string
- func (x *Integration) GetSchedule() string
- func (x *Integration) GetSettings() *structpb.Struct
- func (*Integration) ProtoMessage()
- func (x *Integration) ProtoReflect() protoreflect.Message
- func (x *Integration) Reset()
- func (x *Integration) String() string
- type IntegrationAddRequest
- func (*IntegrationAddRequest) Descriptor() ([]byte, []int)deprecated
- func (x *IntegrationAddRequest) GetIntegration() *Integration
- func (*IntegrationAddRequest) ProtoMessage()
- func (x *IntegrationAddRequest) ProtoReflect() protoreflect.Message
- func (x *IntegrationAddRequest) Reset()
- func (x *IntegrationAddRequest) String() string
- type IntegrationAddResponse
- func (*IntegrationAddResponse) Descriptor() ([]byte, []int)deprecated
- func (x *IntegrationAddResponse) GetIntegration() *Integration
- func (*IntegrationAddResponse) ProtoMessage()
- func (x *IntegrationAddResponse) ProtoReflect() protoreflect.Message
- func (x *IntegrationAddResponse) Reset()
- func (x *IntegrationAddResponse) String() string
- type IntegrationGetRequest
- func (*IntegrationGetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *IntegrationGetRequest) GetID() int32
- func (x *IntegrationGetRequest) GetName() string
- func (*IntegrationGetRequest) ProtoMessage()
- func (x *IntegrationGetRequest) ProtoReflect() protoreflect.Message
- func (x *IntegrationGetRequest) Reset()
- func (x *IntegrationGetRequest) String() string
- type IntegrationGetResponse
- func (*IntegrationGetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *IntegrationGetResponse) GetIntegration() *Integration
- func (*IntegrationGetResponse) ProtoMessage()
- func (x *IntegrationGetResponse) ProtoReflect() protoreflect.Message
- func (x *IntegrationGetResponse) Reset()
- func (x *IntegrationGetResponse) String() string
- type IntegrationListRequest
- type IntegrationListResponse
- func (*IntegrationListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *IntegrationListResponse) GetIntegrations() []*Integration
- func (*IntegrationListResponse) ProtoMessage()
- func (x *IntegrationListResponse) ProtoReflect() protoreflect.Message
- func (x *IntegrationListResponse) Reset()
- func (x *IntegrationListResponse) String() string
- type IntegrationRemoveRequest
- func (*IntegrationRemoveRequest) Descriptor() ([]byte, []int)deprecated
- func (x *IntegrationRemoveRequest) GetName() string
- func (*IntegrationRemoveRequest) ProtoMessage()
- func (x *IntegrationRemoveRequest) ProtoReflect() protoreflect.Message
- func (x *IntegrationRemoveRequest) Reset()
- func (x *IntegrationRemoveRequest) String() string
- type IntegrationRemoveResponse
- type IntegrationUpdateRequest
- func (*IntegrationUpdateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *IntegrationUpdateRequest) GetIntegration() *Integration
- func (*IntegrationUpdateRequest) ProtoMessage()
- func (x *IntegrationUpdateRequest) ProtoReflect() protoreflect.Message
- func (x *IntegrationUpdateRequest) Reset()
- func (x *IntegrationUpdateRequest) String() string
- type IntegrationUpdateResponse
- func (*IntegrationUpdateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *IntegrationUpdateResponse) GetIntegration() *Integration
- func (*IntegrationUpdateResponse) ProtoMessage()
- func (x *IntegrationUpdateResponse) ProtoReflect() protoreflect.Message
- func (x *IntegrationUpdateResponse) Reset()
- func (x *IntegrationUpdateResponse) String() string
- type IntegrationsClient
- type IntegrationsServer
- type Job
- func (*Job) Descriptor() ([]byte, []int)deprecated
- func (x *Job) GetEnded() *timestamppb.Timestamp
- func (x *Job) GetError() string
- func (x *Job) GetID() int32
- func (x *Job) GetIntegrationName() string
- func (x *Job) GetStarted() *timestamppb.Timestamp
- func (x *Job) GetStatus() JobStatus
- func (*Job) ProtoMessage()
- func (x *Job) ProtoReflect() protoreflect.Message
- func (x *Job) Reset()
- func (x *Job) String() string
- type JobGetHistoryRequest
- func (*JobGetHistoryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *JobGetHistoryRequest) GetIntegrationName() string
- func (*JobGetHistoryRequest) ProtoMessage()
- func (x *JobGetHistoryRequest) ProtoReflect() protoreflect.Message
- func (x *JobGetHistoryRequest) Reset()
- func (x *JobGetHistoryRequest) String() string
- type JobGetHistoryResponse
- func (*JobGetHistoryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *JobGetHistoryResponse) GetJobHistory() []*Job
- func (*JobGetHistoryResponse) ProtoMessage()
- func (x *JobGetHistoryResponse) ProtoReflect() protoreflect.Message
- func (x *JobGetHistoryResponse) Reset()
- func (x *JobGetHistoryResponse) String() string
- type JobStatus
- type JobUpdateRequest
- type JobUpdateResponse
- type NaturalBreaksQueryRequest
- func (*NaturalBreaksQueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NaturalBreaksQueryRequest) GetBegin() *timestamppb.Timestamp
- func (x *NaturalBreaksQueryRequest) GetBreaks() uint32
- func (x *NaturalBreaksQueryRequest) GetEnd() *timestamppb.Timestamp
- func (x *NaturalBreaksQueryRequest) GetName() string
- func (*NaturalBreaksQueryRequest) ProtoMessage()
- func (x *NaturalBreaksQueryRequest) ProtoReflect() protoreflect.Message
- func (x *NaturalBreaksQueryRequest) Reset()
- func (x *NaturalBreaksQueryRequest) String() string
- type NaturalBreaksRequest
- func (*NaturalBreaksRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NaturalBreaksRequest) GetBreaks() uint32
- func (x *NaturalBreaksRequest) GetValues() []float64
- func (*NaturalBreaksRequest) ProtoMessage()
- func (x *NaturalBreaksRequest) ProtoReflect() protoreflect.Message
- func (x *NaturalBreaksRequest) Reset()
- func (x *NaturalBreaksRequest) String() string
- type NaturalBreaksResponse
- func (*NaturalBreaksResponse) Descriptor() ([]byte, []int)deprecated
- func (x *NaturalBreaksResponse) GetBreaks() []float64
- func (*NaturalBreaksResponse) ProtoMessage()
- func (x *NaturalBreaksResponse) ProtoReflect() protoreflect.Message
- func (x *NaturalBreaksResponse) Reset()
- func (x *NaturalBreaksResponse) String() string
- type NewUser
- func (*NewUser) Descriptor() ([]byte, []int)deprecated
- func (x *NewUser) GetAttributes() *structpb.Struct
- func (x *NewUser) GetExternalId() string
- func (x *NewUser) GetTraits() *structpb.Struct
- func (x *NewUser) GetUsername() string
- func (x *NewUser) GetUuid() string
- func (*NewUser) ProtoMessage()
- func (x *NewUser) ProtoReflect() protoreflect.Message
- func (x *NewUser) Reset()
- func (x *NewUser) String() string
- type Operator
- type QueryRequest
- type SearchEventsRequest
- func (*SearchEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SearchEventsRequest) GetBegin() *timestamppb.Timestamp
- func (x *SearchEventsRequest) GetEnd() *timestamppb.Timestamp
- func (x *SearchEventsRequest) GetLimit() int32
- func (x *SearchEventsRequest) GetNames() []string
- func (x *SearchEventsRequest) GetUserId() *UserID
- func (*SearchEventsRequest) ProtoMessage()
- func (x *SearchEventsRequest) ProtoReflect() protoreflect.Message
- func (x *SearchEventsRequest) Reset()
- func (x *SearchEventsRequest) String() string
- type SearchEventsResponse
- func (*SearchEventsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SearchEventsResponse) GetEvents() []*Event
- func (*SearchEventsResponse) ProtoMessage()
- func (x *SearchEventsResponse) ProtoReflect() protoreflect.Message
- func (x *SearchEventsResponse) Reset()
- func (x *SearchEventsResponse) String() string
- type SearchUserEventsRequest
- func (*SearchUserEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SearchUserEventsRequest) GetBegin() *timestamppb.Timestamp
- func (x *SearchUserEventsRequest) GetEnd() *timestamppb.Timestamp
- func (x *SearchUserEventsRequest) GetLimit() int32
- func (x *SearchUserEventsRequest) GetSchemas() []string
- func (x *SearchUserEventsRequest) GetSources() []string
- func (x *SearchUserEventsRequest) GetSubjects() []string
- func (x *SearchUserEventsRequest) GetTypes() []string
- func (*SearchUserEventsRequest) ProtoMessage()
- func (x *SearchUserEventsRequest) ProtoReflect() protoreflect.Message
- func (x *SearchUserEventsRequest) Reset()
- func (x *SearchUserEventsRequest) String() string
- type SearchUserTraitsRequest
- func (*SearchUserTraitsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SearchUserTraitsRequest) GetBegin() *timestamppb.Timestamp
- func (x *SearchUserTraitsRequest) GetEnd() *timestamppb.Timestamp
- func (x *SearchUserTraitsRequest) GetLatest() bool
- func (x *SearchUserTraitsRequest) GetLimit() int32
- func (x *SearchUserTraitsRequest) GetNames() []string
- func (x *SearchUserTraitsRequest) GetUserId() *UserID
- func (*SearchUserTraitsRequest) ProtoMessage()
- func (x *SearchUserTraitsRequest) ProtoReflect() protoreflect.Message
- func (x *SearchUserTraitsRequest) Reset()
- func (x *SearchUserTraitsRequest) String() string
- type SearchUserTraitsResponse
- func (*SearchUserTraitsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SearchUserTraitsResponse) GetTraits() []*structpb.Struct
- func (*SearchUserTraitsResponse) ProtoMessage()
- func (x *SearchUserTraitsResponse) ProtoReflect() protoreflect.Message
- func (x *SearchUserTraitsResponse) Reset()
- func (x *SearchUserTraitsResponse) String() string
- type Session
- func (*Session) Descriptor() ([]byte, []int)deprecated
- func (x *Session) GetKey() string
- func (x *Session) GetObject() *structpb.Struct
- func (x *Session) GetTimestamp() *timestamppb.Timestamp
- func (x *Session) GetUserId() *UserID
- func (*Session) ProtoMessage()
- func (x *Session) ProtoReflect() protoreflect.Message
- func (x *Session) Reset()
- func (x *Session) String() string
- type SessionEventRequest
- func (*SessionEventRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SessionEventRequest) GetEvent() *Event
- func (*SessionEventRequest) ProtoMessage()
- func (x *SessionEventRequest) ProtoReflect() protoreflect.Message
- func (x *SessionEventRequest) Reset()
- func (x *SessionEventRequest) String() string
- type SessionEventResponse
- func (*SessionEventResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SessionEventResponse) GetEvent() *Event
- func (*SessionEventResponse) ProtoMessage()
- func (x *SessionEventResponse) ProtoReflect() protoreflect.Message
- func (x *SessionEventResponse) Reset()
- func (x *SessionEventResponse) String() string
- type SessionListResponse
- func (*SessionListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SessionListResponse) GetSessions() []*Session
- func (*SessionListResponse) ProtoMessage()
- func (x *SessionListResponse) ProtoReflect() protoreflect.Message
- func (x *SessionListResponse) Reset()
- func (x *SessionListResponse) String() string
- type SessionRequest
- type SessionResponse
- type TraitFilter
- func (*TraitFilter) Descriptor() ([]byte, []int)deprecated
- func (x *TraitFilter) GetName() string
- func (x *TraitFilter) GetOperator() Operator
- func (x *TraitFilter) GetValue() *structpb.Value
- func (*TraitFilter) ProtoMessage()
- func (x *TraitFilter) ProtoReflect() protoreflect.Message
- func (x *TraitFilter) Reset()
- func (x *TraitFilter) String() string
- type TraitListResponse
- func (*TraitListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TraitListResponse) GetNextPageToken() string
- func (x *TraitListResponse) GetTraits() *structpb.Struct
- func (*TraitListResponse) ProtoMessage()
- func (x *TraitListResponse) ProtoReflect() protoreflect.Message
- func (x *TraitListResponse) Reset()
- func (x *TraitListResponse) String() string
- type TraitRequest
- func (*TraitRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TraitRequest) GetKey() string
- func (x *TraitRequest) GetUserId() *UserID
- func (x *TraitRequest) GetValue() *structpb.Value
- func (*TraitRequest) ProtoMessage()
- func (x *TraitRequest) ProtoReflect() protoreflect.Message
- func (x *TraitRequest) Reset()
- func (x *TraitRequest) String() string
- type TraitResponse
- type UnimplementedIntegrationsServer
- func (UnimplementedIntegrationsServer) AddIntegration(context.Context, *IntegrationAddRequest) (*IntegrationAddResponse, error)
- func (UnimplementedIntegrationsServer) GetIntegration(context.Context, *IntegrationGetRequest) (*IntegrationGetResponse, error)
- func (UnimplementedIntegrationsServer) GetJobHistory(context.Context, *JobGetHistoryRequest) (*JobGetHistoryResponse, error)
- func (UnimplementedIntegrationsServer) JobUpdate(context.Context, *JobUpdateRequest) (*JobUpdateResponse, error)
- func (UnimplementedIntegrationsServer) ListIntegrations(context.Context, *IntegrationListRequest) (*IntegrationListResponse, error)
- func (UnimplementedIntegrationsServer) RemoveIntegration(context.Context, *IntegrationRemoveRequest) (*IntegrationRemoveResponse, error)
- func (UnimplementedIntegrationsServer) UpdateIntegration(context.Context, *IntegrationUpdateRequest) (*IntegrationUpdateResponse, error)
- type UnimplementedUsersServer
- func (UnimplementedUsersServer) AddAttribute(context.Context, *AttributeRequest) (*AttributeResponse, error)
- func (UnimplementedUsersServer) AddSession(context.Context, *SessionRequest) (*SessionResponse, error)
- func (UnimplementedUsersServer) AddTrait(context.Context, *TraitRequest) (*TraitResponse, error)
- func (UnimplementedUsersServer) Create(context.Context, *NewUser) (*UserResponse, error)
- func (UnimplementedUsersServer) Delete(context.Context, *UserRequest) (*UserResponse, error)
- func (UnimplementedUsersServer) DeleteAttribute(context.Context, *AttributeRequest) (*AttributeResponse, error)
- func (UnimplementedUsersServer) DeleteTrait(context.Context, *TraitRequest) (*TraitResponse, error)
- func (UnimplementedUsersServer) Find(context.Context, *UserQuery) (*UserListResponse, error)
- func (UnimplementedUsersServer) Get(context.Context, *UserRequest) (*UserResponse, error)
- func (UnimplementedUsersServer) GetAggregateForUsers(context.Context, *GetAggregateForUsersRequest) (*AggregateResponse, error)
- func (UnimplementedUsersServer) GetSessionEvents(context.Context, *GetSessionEventsRequest) (*EventListResponse, error)
- func (UnimplementedUsersServer) GetSessions(context.Context, *GetSessionsRequest) (*SessionListResponse, error)
- func (UnimplementedUsersServer) GetUsersByAggregatedTraits(context.Context, *GetUsersByAggregatedTraitsRequest) (*UserListResponse, error)
- func (UnimplementedUsersServer) GetUsersByEvents(context.Context, *SearchUserEventsRequest) (*UserListResponse, error)
- func (UnimplementedUsersServer) GetUsersByTraits(context.Context, *SearchUserTraitsRequest) (*UserListResponse, error)
- func (UnimplementedUsersServer) IdentifySession(context.Context, *IdentifySessionRequest) (*IdentifySessionResponse, error)
- func (UnimplementedUsersServer) LogEvent(context.Context, *EventRequest) (*EventResponse, error)
- func (UnimplementedUsersServer) LogSessionEvent(context.Context, *SessionEventRequest) (*SessionEventResponse, error)
- func (UnimplementedUsersServer) NaturalBreaks(context.Context, *NaturalBreaksRequest) (*NaturalBreaksResponse, error)
- func (UnimplementedUsersServer) NaturalBreaksQueried(context.Context, *NaturalBreaksQueryRequest) (*NaturalBreaksResponse, error)
- func (UnimplementedUsersServer) QueryAttributes(context.Context, *QueryRequest) (*AttributeListResponse, error)
- func (UnimplementedUsersServer) QueryEvents(context.Context, *QueryRequest) (*SearchEventsResponse, error)
- func (UnimplementedUsersServer) QueryTraits(context.Context, *QueryRequest) (*TraitListResponse, error)
- func (UnimplementedUsersServer) QueryUsers(context.Context, *QueryRequest) (*UserListResponse, error)
- func (UnimplementedUsersServer) SearchEvents(context.Context, *SearchEventsRequest) (*SearchEventsResponse, error)
- func (UnimplementedUsersServer) SearchUserTraits(context.Context, *SearchUserTraitsRequest) (*SearchUserTraitsResponse, error)
- func (UnimplementedUsersServer) Update(context.Context, *UserRequest) (*UserResponse, error)
- type UnsafeIntegrationsServer
- type UnsafeUsersServer
- type UserID
- func (*UserID) Descriptor() ([]byte, []int)deprecated
- func (x *UserID) GetExternalId() string
- func (x *UserID) GetId() uint64
- func (x *UserID) GetUuid() string
- func (*UserID) ProtoMessage()
- func (x *UserID) ProtoReflect() protoreflect.Message
- func (x *UserID) Reset()
- func (x *UserID) String() string
- type UserListResponse
- func (*UserListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UserListResponse) GetNextPageToken() string
- func (x *UserListResponse) GetUsers() []*UserResponse
- func (*UserListResponse) ProtoMessage()
- func (x *UserListResponse) ProtoReflect() protoreflect.Message
- func (x *UserListResponse) Reset()
- func (x *UserListResponse) String() string
- type UserQuery
- func (*UserQuery) Descriptor() ([]byte, []int)deprecated
- func (x *UserQuery) GetAttributeFilters() []*AttributeFilter
- func (x *UserQuery) GetOrderBy() string
- func (x *UserQuery) GetPageSize() int32
- func (x *UserQuery) GetPageToken() string
- func (x *UserQuery) GetTraitFilters() []*TraitFilter
- func (x *UserQuery) GetUserId() *UserID
- func (x *UserQuery) GetUsername() string
- func (*UserQuery) ProtoMessage()
- func (x *UserQuery) ProtoReflect() protoreflect.Message
- func (x *UserQuery) Reset()
- func (x *UserQuery) String() string
- type UserRequest
- func (*UserRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UserRequest) GetAttributes() *structpb.Struct
- func (x *UserRequest) GetId() *UserID
- func (x *UserRequest) GetTraits() *structpb.Struct
- func (x *UserRequest) GetUsername() string
- func (*UserRequest) ProtoMessage()
- func (x *UserRequest) ProtoReflect() protoreflect.Message
- func (x *UserRequest) Reset()
- func (x *UserRequest) String() string
- type UserResponse
- func (*UserResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UserResponse) GetAttributes() *structpb.Struct
- func (x *UserResponse) GetId() *UserID
- func (x *UserResponse) GetTraits() *structpb.Struct
- func (x *UserResponse) GetUsername() string
- func (*UserResponse) ProtoMessage()
- func (x *UserResponse) ProtoReflect() protoreflect.Message
- func (x *UserResponse) Reset()
- func (x *UserResponse) String() string
- type UsersClient
- type UsersServer
Constants ¶
const ( Users_Create_FullMethodName = "/userapi.Users/Create" Users_Get_FullMethodName = "/userapi.Users/Get" Users_Update_FullMethodName = "/userapi.Users/Update" Users_Find_FullMethodName = "/userapi.Users/Find" Users_Delete_FullMethodName = "/userapi.Users/Delete" Users_LogEvent_FullMethodName = "/userapi.Users/LogEvent" Users_AddAttribute_FullMethodName = "/userapi.Users/AddAttribute" Users_AddTrait_FullMethodName = "/userapi.Users/AddTrait" Users_DeleteAttribute_FullMethodName = "/userapi.Users/DeleteAttribute" Users_DeleteTrait_FullMethodName = "/userapi.Users/DeleteTrait" Users_SearchUserTraits_FullMethodName = "/userapi.Users/SearchUserTraits" Users_GetUsersByTraits_FullMethodName = "/userapi.Users/GetUsersByTraits" Users_GetUsersByAggregatedTraits_FullMethodName = "/userapi.Users/GetUsersByAggregatedTraits" Users_GetAggregateForUsers_FullMethodName = "/userapi.Users/GetAggregateForUsers" Users_GetUsersByEvents_FullMethodName = "/userapi.Users/GetUsersByEvents" Users_SearchEvents_FullMethodName = "/userapi.Users/SearchEvents" Users_NaturalBreaks_FullMethodName = "/userapi.Users/NaturalBreaks" Users_NaturalBreaksQueried_FullMethodName = "/userapi.Users/NaturalBreaksQueried" Users_QueryUsers_FullMethodName = "/userapi.Users/QueryUsers" Users_QueryAttributes_FullMethodName = "/userapi.Users/QueryAttributes" Users_QueryTraits_FullMethodName = "/userapi.Users/QueryTraits" Users_QueryEvents_FullMethodName = "/userapi.Users/QueryEvents" Users_AddSession_FullMethodName = "/userapi.Users/AddSession" Users_IdentifySession_FullMethodName = "/userapi.Users/IdentifySession" Users_GetSessions_FullMethodName = "/userapi.Users/GetSessions" Users_LogSessionEvent_FullMethodName = "/userapi.Users/LogSessionEvent" Users_GetSessionEvents_FullMethodName = "/userapi.Users/GetSessionEvents" )
const ( Integrations_ListIntegrations_FullMethodName = "/userapi.Integrations/ListIntegrations" Integrations_GetIntegration_FullMethodName = "/userapi.Integrations/GetIntegration" Integrations_AddIntegration_FullMethodName = "/userapi.Integrations/AddIntegration" Integrations_UpdateIntegration_FullMethodName = "/userapi.Integrations/UpdateIntegration" Integrations_RemoveIntegration_FullMethodName = "/userapi.Integrations/RemoveIntegration" Integrations_JobUpdate_FullMethodName = "/userapi.Integrations/JobUpdate" Integrations_GetJobHistory_FullMethodName = "/userapi.Integrations/GetJobHistory" )
Variables ¶
var ( Operator_name = map[int32]string{ 0: "EQUALS", 1: "NOT_EQUALS", 2: "GREATER_THAN", 3: "GREATER_THAN_OR_EQUALS", 4: "LESS_THAN", 5: "LESS_THAN_OR_EQUALS", 6: "IN", 7: "NOT_IN", 8: "CONTAINS", 9: "NOT_CONTAINS", } Operator_value = map[string]int32{ "EQUALS": 0, "NOT_EQUALS": 1, "GREATER_THAN": 2, "GREATER_THAN_OR_EQUALS": 3, "LESS_THAN": 4, "LESS_THAN_OR_EQUALS": 5, "IN": 6, "NOT_IN": 7, "CONTAINS": 8, "NOT_CONTAINS": 9, } )
Enum value maps for Operator.
var ( JobStatus_name = map[int32]string{ 0: "SCHEDULED", 1: "STARTED", 2: "COMPLETE", 3: "ERROR", } JobStatus_value = map[string]int32{ "SCHEDULED": 0, "STARTED": 1, "COMPLETE": 2, "ERROR": 3, } )
Enum value maps for JobStatus.
var File_user_proto protoreflect.FileDescriptor
var Integrations_ServiceDesc = grpc.ServiceDesc{ ServiceName: "userapi.Integrations", HandlerType: (*IntegrationsServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ListIntegrations", Handler: _Integrations_ListIntegrations_Handler, }, { MethodName: "GetIntegration", Handler: _Integrations_GetIntegration_Handler, }, { MethodName: "AddIntegration", Handler: _Integrations_AddIntegration_Handler, }, { MethodName: "UpdateIntegration", Handler: _Integrations_UpdateIntegration_Handler, }, { MethodName: "RemoveIntegration", Handler: _Integrations_RemoveIntegration_Handler, }, { MethodName: "JobUpdate", Handler: _Integrations_JobUpdate_Handler, }, { MethodName: "GetJobHistory", Handler: _Integrations_GetJobHistory_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "user.proto", }
Integrations_ServiceDesc is the grpc.ServiceDesc for Integrations service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Users_ServiceDesc = grpc.ServiceDesc{ ServiceName: "userapi.Users", HandlerType: (*UsersServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _Users_Create_Handler, }, { MethodName: "Get", Handler: _Users_Get_Handler, }, { MethodName: "Update", Handler: _Users_Update_Handler, }, { MethodName: "Find", Handler: _Users_Find_Handler, }, { MethodName: "Delete", Handler: _Users_Delete_Handler, }, { MethodName: "LogEvent", Handler: _Users_LogEvent_Handler, }, { MethodName: "AddAttribute", Handler: _Users_AddAttribute_Handler, }, { MethodName: "AddTrait", Handler: _Users_AddTrait_Handler, }, { MethodName: "DeleteAttribute", Handler: _Users_DeleteAttribute_Handler, }, { MethodName: "DeleteTrait", Handler: _Users_DeleteTrait_Handler, }, { MethodName: "SearchUserTraits", Handler: _Users_SearchUserTraits_Handler, }, { MethodName: "GetUsersByTraits", Handler: _Users_GetUsersByTraits_Handler, }, { MethodName: "GetUsersByAggregatedTraits", Handler: _Users_GetUsersByAggregatedTraits_Handler, }, { MethodName: "GetAggregateForUsers", Handler: _Users_GetAggregateForUsers_Handler, }, { MethodName: "GetUsersByEvents", Handler: _Users_GetUsersByEvents_Handler, }, { MethodName: "SearchEvents", Handler: _Users_SearchEvents_Handler, }, { MethodName: "NaturalBreaks", Handler: _Users_NaturalBreaks_Handler, }, { MethodName: "NaturalBreaksQueried", Handler: _Users_NaturalBreaksQueried_Handler, }, { MethodName: "QueryUsers", Handler: _Users_QueryUsers_Handler, }, { MethodName: "QueryAttributes", Handler: _Users_QueryAttributes_Handler, }, { MethodName: "QueryTraits", Handler: _Users_QueryTraits_Handler, }, { MethodName: "QueryEvents", Handler: _Users_QueryEvents_Handler, }, { MethodName: "AddSession", Handler: _Users_AddSession_Handler, }, { MethodName: "IdentifySession", Handler: _Users_IdentifySession_Handler, }, { MethodName: "GetSessions", Handler: _Users_GetSessions_Handler, }, { MethodName: "LogSessionEvent", Handler: _Users_LogSessionEvent_Handler, }, { MethodName: "GetSessionEvents", Handler: _Users_GetSessionEvents_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "user.proto", }
Users_ServiceDesc is the grpc.ServiceDesc for Users service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterIntegrationsServer ¶
func RegisterIntegrationsServer(s grpc.ServiceRegistrar, srv IntegrationsServer)
func RegisterUsersServer ¶
func RegisterUsersServer(s grpc.ServiceRegistrar, srv UsersServer)
Types ¶
type AggregateResponse ¶
type AggregateResponse struct { Value float32 `protobuf:"fixed32,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*AggregateResponse) Descriptor
deprecated
func (*AggregateResponse) Descriptor() ([]byte, []int)
Deprecated: Use AggregateResponse.ProtoReflect.Descriptor instead.
func (*AggregateResponse) GetValue ¶
func (x *AggregateResponse) GetValue() float32
func (*AggregateResponse) ProtoMessage ¶
func (*AggregateResponse) ProtoMessage()
func (*AggregateResponse) ProtoReflect ¶
func (x *AggregateResponse) ProtoReflect() protoreflect.Message
func (*AggregateResponse) Reset ¶
func (x *AggregateResponse) Reset()
func (*AggregateResponse) String ¶
func (x *AggregateResponse) String() string
type AttributeFilter ¶
type AttributeFilter struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Operator Operator `protobuf:"varint,2,opt,name=operator,proto3,enum=userapi.Operator" json:"operator,omitempty"` Value *structpb.Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*AttributeFilter) Descriptor
deprecated
func (*AttributeFilter) Descriptor() ([]byte, []int)
Deprecated: Use AttributeFilter.ProtoReflect.Descriptor instead.
func (*AttributeFilter) GetName ¶
func (x *AttributeFilter) GetName() string
func (*AttributeFilter) GetOperator ¶
func (x *AttributeFilter) GetOperator() Operator
func (*AttributeFilter) GetValue ¶
func (x *AttributeFilter) GetValue() *structpb.Value
func (*AttributeFilter) ProtoMessage ¶
func (*AttributeFilter) ProtoMessage()
func (*AttributeFilter) ProtoReflect ¶
func (x *AttributeFilter) ProtoReflect() protoreflect.Message
func (*AttributeFilter) Reset ¶
func (x *AttributeFilter) Reset()
func (*AttributeFilter) String ¶
func (x *AttributeFilter) String() string
type AttributeListResponse ¶
type AttributeListResponse struct { Attributes *structpb.Struct `protobuf:"bytes,1,opt,name=attributes,proto3" json:"attributes,omitempty"` NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
func (*AttributeListResponse) Descriptor
deprecated
func (*AttributeListResponse) Descriptor() ([]byte, []int)
Deprecated: Use AttributeListResponse.ProtoReflect.Descriptor instead.
func (*AttributeListResponse) GetAttributes ¶
func (x *AttributeListResponse) GetAttributes() *structpb.Struct
func (*AttributeListResponse) GetNextPageToken ¶
func (x *AttributeListResponse) GetNextPageToken() string
func (*AttributeListResponse) ProtoMessage ¶
func (*AttributeListResponse) ProtoMessage()
func (*AttributeListResponse) ProtoReflect ¶
func (x *AttributeListResponse) ProtoReflect() protoreflect.Message
func (*AttributeListResponse) Reset ¶
func (x *AttributeListResponse) Reset()
func (*AttributeListResponse) String ¶
func (x *AttributeListResponse) String() string
type AttributeRequest ¶
type AttributeRequest struct { UserId *UserID `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Value *structpb.Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*AttributeRequest) Descriptor
deprecated
func (*AttributeRequest) Descriptor() ([]byte, []int)
Deprecated: Use AttributeRequest.ProtoReflect.Descriptor instead.
func (*AttributeRequest) GetKey ¶
func (x *AttributeRequest) GetKey() string
func (*AttributeRequest) GetUserId ¶
func (x *AttributeRequest) GetUserId() *UserID
func (*AttributeRequest) GetValue ¶
func (x *AttributeRequest) GetValue() *structpb.Value
func (*AttributeRequest) ProtoMessage ¶
func (*AttributeRequest) ProtoMessage()
func (*AttributeRequest) ProtoReflect ¶
func (x *AttributeRequest) ProtoReflect() protoreflect.Message
func (*AttributeRequest) Reset ¶
func (x *AttributeRequest) Reset()
func (*AttributeRequest) String ¶
func (x *AttributeRequest) String() string
type AttributeResponse ¶
type AttributeResponse struct {
// contains filtered or unexported fields
}
func (*AttributeResponse) Descriptor
deprecated
func (*AttributeResponse) Descriptor() ([]byte, []int)
Deprecated: Use AttributeResponse.ProtoReflect.Descriptor instead.
func (*AttributeResponse) ProtoMessage ¶
func (*AttributeResponse) ProtoMessage()
func (*AttributeResponse) ProtoReflect ¶
func (x *AttributeResponse) ProtoReflect() protoreflect.Message
func (*AttributeResponse) Reset ¶
func (x *AttributeResponse) Reset()
func (*AttributeResponse) String ¶
func (x *AttributeResponse) String() string
type Event ¶
type Event struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` Specversion string `protobuf:"bytes,4,opt,name=specversion,proto3" json:"specversion,omitempty"` Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"` Datacontenttype string `protobuf:"bytes,6,opt,name=datacontenttype,proto3" json:"datacontenttype,omitempty"` Dataschema string `protobuf:"bytes,7,opt,name=dataschema,proto3" json:"dataschema,omitempty"` Subject string `protobuf:"bytes,8,opt,name=subject,proto3" json:"subject,omitempty"` Data []byte `protobuf:"bytes,9,opt,name=data,proto3" json:"data,omitempty"` UserId *UserID `protobuf:"bytes,10,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` SessionKey string `protobuf:"bytes,11,opt,name=session_key,json=sessionKey,proto3" json:"session_key,omitempty"` // contains filtered or unexported fields }
func (*Event) Descriptor
deprecated
func (*Event) GetDatacontenttype ¶
func (*Event) GetDataschema ¶
func (*Event) GetSessionKey ¶
func (*Event) GetSpecversion ¶
func (*Event) GetSubject ¶
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 EventListResponse ¶
type EventListResponse struct { Events []*Event `protobuf:"bytes,1,rep,name=Events,proto3" json:"Events,omitempty"` // contains filtered or unexported fields }
func (*EventListResponse) Descriptor
deprecated
func (*EventListResponse) Descriptor() ([]byte, []int)
Deprecated: Use EventListResponse.ProtoReflect.Descriptor instead.
func (*EventListResponse) GetEvents ¶
func (x *EventListResponse) GetEvents() []*Event
func (*EventListResponse) ProtoMessage ¶
func (*EventListResponse) ProtoMessage()
func (*EventListResponse) ProtoReflect ¶
func (x *EventListResponse) ProtoReflect() protoreflect.Message
func (*EventListResponse) Reset ¶
func (x *EventListResponse) Reset()
func (*EventListResponse) String ¶
func (x *EventListResponse) String() string
type EventRequest ¶
type EventRequest struct { Event *Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"` // contains filtered or unexported fields }
func (*EventRequest) Descriptor
deprecated
func (*EventRequest) Descriptor() ([]byte, []int)
Deprecated: Use EventRequest.ProtoReflect.Descriptor instead.
func (*EventRequest) GetEvent ¶
func (x *EventRequest) GetEvent() *Event
func (*EventRequest) ProtoMessage ¶
func (*EventRequest) ProtoMessage()
func (*EventRequest) ProtoReflect ¶
func (x *EventRequest) ProtoReflect() protoreflect.Message
func (*EventRequest) Reset ¶
func (x *EventRequest) Reset()
func (*EventRequest) String ¶
func (x *EventRequest) String() string
type EventResponse ¶
type EventResponse struct { Event *Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"` // contains filtered or unexported fields }
func (*EventResponse) Descriptor
deprecated
func (*EventResponse) Descriptor() ([]byte, []int)
Deprecated: Use EventResponse.ProtoReflect.Descriptor instead.
func (*EventResponse) GetEvent ¶
func (x *EventResponse) GetEvent() *Event
func (*EventResponse) ProtoMessage ¶
func (*EventResponse) ProtoMessage()
func (*EventResponse) ProtoReflect ¶
func (x *EventResponse) ProtoReflect() protoreflect.Message
func (*EventResponse) Reset ¶
func (x *EventResponse) Reset()
func (*EventResponse) String ¶
func (x *EventResponse) String() string
type GetAggregateForUsersRequest ¶
type GetAggregateForUsersRequest struct { UserIds []*UserID `protobuf:"bytes,1,rep,name=user_ids,json=userIds,proto3" json:"user_ids,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*GetAggregateForUsersRequest) Descriptor
deprecated
func (*GetAggregateForUsersRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetAggregateForUsersRequest.ProtoReflect.Descriptor instead.
func (*GetAggregateForUsersRequest) GetName ¶
func (x *GetAggregateForUsersRequest) GetName() string
func (*GetAggregateForUsersRequest) GetType ¶
func (x *GetAggregateForUsersRequest) GetType() string
func (*GetAggregateForUsersRequest) GetUserIds ¶
func (x *GetAggregateForUsersRequest) GetUserIds() []*UserID
func (*GetAggregateForUsersRequest) ProtoMessage ¶
func (*GetAggregateForUsersRequest) ProtoMessage()
func (*GetAggregateForUsersRequest) ProtoReflect ¶
func (x *GetAggregateForUsersRequest) ProtoReflect() protoreflect.Message
func (*GetAggregateForUsersRequest) Reset ¶
func (x *GetAggregateForUsersRequest) Reset()
func (*GetAggregateForUsersRequest) String ¶
func (x *GetAggregateForUsersRequest) String() string
type GetSessionEventsRequest ¶
type GetSessionEventsRequest struct { SessionKeys []string `protobuf:"bytes,1,rep,name=session_keys,json=sessionKeys,proto3" json:"session_keys,omitempty"` UserId *UserID `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` Begin *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=begin,proto3" json:"begin,omitempty"` End *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end,proto3" json:"end,omitempty"` Offset int32 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"` Limit int32 `protobuf:"varint,6,opt,name=limit,proto3" json:"limit,omitempty"` OrderBy string `protobuf:"bytes,7,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"` // contains filtered or unexported fields }
func (*GetSessionEventsRequest) Descriptor
deprecated
func (*GetSessionEventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSessionEventsRequest.ProtoReflect.Descriptor instead.
func (*GetSessionEventsRequest) GetBegin ¶
func (x *GetSessionEventsRequest) GetBegin() *timestamppb.Timestamp
func (*GetSessionEventsRequest) GetEnd ¶
func (x *GetSessionEventsRequest) GetEnd() *timestamppb.Timestamp
func (*GetSessionEventsRequest) GetLimit ¶
func (x *GetSessionEventsRequest) GetLimit() int32
func (*GetSessionEventsRequest) GetOffset ¶
func (x *GetSessionEventsRequest) GetOffset() int32
func (*GetSessionEventsRequest) GetOrderBy ¶
func (x *GetSessionEventsRequest) GetOrderBy() string
func (*GetSessionEventsRequest) GetSessionKeys ¶
func (x *GetSessionEventsRequest) GetSessionKeys() []string
func (*GetSessionEventsRequest) GetUserId ¶
func (x *GetSessionEventsRequest) GetUserId() *UserID
func (*GetSessionEventsRequest) ProtoMessage ¶
func (*GetSessionEventsRequest) ProtoMessage()
func (*GetSessionEventsRequest) ProtoReflect ¶
func (x *GetSessionEventsRequest) ProtoReflect() protoreflect.Message
func (*GetSessionEventsRequest) Reset ¶
func (x *GetSessionEventsRequest) Reset()
func (*GetSessionEventsRequest) String ¶
func (x *GetSessionEventsRequest) String() string
type GetSessionsRequest ¶
type GetSessionsRequest struct { SessionKeys []string `protobuf:"bytes,1,rep,name=session_keys,json=sessionKeys,proto3" json:"session_keys,omitempty"` UserId *UserID `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` Begin *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=begin,proto3" json:"begin,omitempty"` End *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end,proto3" json:"end,omitempty"` Offset int32 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"` Limit int32 `protobuf:"varint,6,opt,name=limit,proto3" json:"limit,omitempty"` OrderBy string `protobuf:"bytes,7,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"` // contains filtered or unexported fields }
func (*GetSessionsRequest) Descriptor
deprecated
func (*GetSessionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSessionsRequest.ProtoReflect.Descriptor instead.
func (*GetSessionsRequest) GetBegin ¶
func (x *GetSessionsRequest) GetBegin() *timestamppb.Timestamp
func (*GetSessionsRequest) GetEnd ¶
func (x *GetSessionsRequest) GetEnd() *timestamppb.Timestamp
func (*GetSessionsRequest) GetLimit ¶
func (x *GetSessionsRequest) GetLimit() int32
func (*GetSessionsRequest) GetOffset ¶
func (x *GetSessionsRequest) GetOffset() int32
func (*GetSessionsRequest) GetOrderBy ¶
func (x *GetSessionsRequest) GetOrderBy() string
func (*GetSessionsRequest) GetSessionKeys ¶
func (x *GetSessionsRequest) GetSessionKeys() []string
func (*GetSessionsRequest) GetUserId ¶
func (x *GetSessionsRequest) GetUserId() *UserID
func (*GetSessionsRequest) ProtoMessage ¶
func (*GetSessionsRequest) ProtoMessage()
func (*GetSessionsRequest) ProtoReflect ¶
func (x *GetSessionsRequest) ProtoReflect() protoreflect.Message
func (*GetSessionsRequest) Reset ¶
func (x *GetSessionsRequest) Reset()
func (*GetSessionsRequest) String ¶
func (x *GetSessionsRequest) String() string
type GetUsersByAggregatedTraitsRequest ¶
type GetUsersByAggregatedTraitsRequest struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Operator string `protobuf:"bytes,3,opt,name=operator,proto3" json:"operator,omitempty"` Value float32 `protobuf:"fixed32,4,opt,name=value,proto3" json:"value,omitempty"` Begin *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=begin,proto3" json:"begin,omitempty"` End *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=end,proto3" json:"end,omitempty"` Limit int32 `protobuf:"varint,7,opt,name=limit,proto3" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*GetUsersByAggregatedTraitsRequest) Descriptor
deprecated
func (*GetUsersByAggregatedTraitsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetUsersByAggregatedTraitsRequest.ProtoReflect.Descriptor instead.
func (*GetUsersByAggregatedTraitsRequest) GetBegin ¶
func (x *GetUsersByAggregatedTraitsRequest) GetBegin() *timestamppb.Timestamp
func (*GetUsersByAggregatedTraitsRequest) GetEnd ¶
func (x *GetUsersByAggregatedTraitsRequest) GetEnd() *timestamppb.Timestamp
func (*GetUsersByAggregatedTraitsRequest) GetLimit ¶
func (x *GetUsersByAggregatedTraitsRequest) GetLimit() int32
func (*GetUsersByAggregatedTraitsRequest) GetName ¶
func (x *GetUsersByAggregatedTraitsRequest) GetName() string
func (*GetUsersByAggregatedTraitsRequest) GetOperator ¶
func (x *GetUsersByAggregatedTraitsRequest) GetOperator() string
func (*GetUsersByAggregatedTraitsRequest) GetType ¶
func (x *GetUsersByAggregatedTraitsRequest) GetType() string
func (*GetUsersByAggregatedTraitsRequest) GetValue ¶
func (x *GetUsersByAggregatedTraitsRequest) GetValue() float32
func (*GetUsersByAggregatedTraitsRequest) ProtoMessage ¶
func (*GetUsersByAggregatedTraitsRequest) ProtoMessage()
func (*GetUsersByAggregatedTraitsRequest) ProtoReflect ¶
func (x *GetUsersByAggregatedTraitsRequest) ProtoReflect() protoreflect.Message
func (*GetUsersByAggregatedTraitsRequest) Reset ¶
func (x *GetUsersByAggregatedTraitsRequest) Reset()
func (*GetUsersByAggregatedTraitsRequest) String ¶
func (x *GetUsersByAggregatedTraitsRequest) String() string
type IdentifySessionRequest ¶
type IdentifySessionRequest struct { SessionKey []string `protobuf:"bytes,1,rep,name=session_key,json=sessionKey,proto3" json:"session_key,omitempty"` UserId *UserID `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` // contains filtered or unexported fields }
func (*IdentifySessionRequest) Descriptor
deprecated
func (*IdentifySessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use IdentifySessionRequest.ProtoReflect.Descriptor instead.
func (*IdentifySessionRequest) GetSessionKey ¶
func (x *IdentifySessionRequest) GetSessionKey() []string
func (*IdentifySessionRequest) GetUserId ¶
func (x *IdentifySessionRequest) GetUserId() *UserID
func (*IdentifySessionRequest) ProtoMessage ¶
func (*IdentifySessionRequest) ProtoMessage()
func (*IdentifySessionRequest) ProtoReflect ¶
func (x *IdentifySessionRequest) ProtoReflect() protoreflect.Message
func (*IdentifySessionRequest) Reset ¶
func (x *IdentifySessionRequest) Reset()
func (*IdentifySessionRequest) String ¶
func (x *IdentifySessionRequest) String() string
type IdentifySessionResponse ¶
type IdentifySessionResponse struct {
// contains filtered or unexported fields
}
func (*IdentifySessionResponse) Descriptor
deprecated
func (*IdentifySessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use IdentifySessionResponse.ProtoReflect.Descriptor instead.
func (*IdentifySessionResponse) ProtoMessage ¶
func (*IdentifySessionResponse) ProtoMessage()
func (*IdentifySessionResponse) ProtoReflect ¶
func (x *IdentifySessionResponse) ProtoReflect() protoreflect.Message
func (*IdentifySessionResponse) Reset ¶
func (x *IdentifySessionResponse) Reset()
func (*IdentifySessionResponse) String ¶
func (x *IdentifySessionResponse) String() string
type Integration ¶
type Integration struct { ID int32 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"` Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"` Schedule string `protobuf:"bytes,3,opt,name=Schedule,proto3" json:"Schedule,omitempty"` ExecPath string `protobuf:"bytes,4,opt,name=ExecPath,proto3" json:"ExecPath,omitempty"` ConfigPath string `protobuf:"bytes,5,opt,name=ConfigPath,proto3" json:"ConfigPath,omitempty"` Enabled bool `protobuf:"varint,6,opt,name=Enabled,proto3" json:"Enabled,omitempty"` Settings *structpb.Struct `protobuf:"bytes,7,opt,name=Settings,proto3" json:"Settings,omitempty"` // contains filtered or unexported fields }
func (*Integration) Descriptor
deprecated
func (*Integration) Descriptor() ([]byte, []int)
Deprecated: Use Integration.ProtoReflect.Descriptor instead.
func (*Integration) GetConfigPath ¶
func (x *Integration) GetConfigPath() string
func (*Integration) GetEnabled ¶
func (x *Integration) GetEnabled() bool
func (*Integration) GetExecPath ¶
func (x *Integration) GetExecPath() string
func (*Integration) GetID ¶
func (x *Integration) GetID() int32
func (*Integration) GetName ¶
func (x *Integration) GetName() string
func (*Integration) GetSchedule ¶
func (x *Integration) GetSchedule() string
func (*Integration) GetSettings ¶
func (x *Integration) GetSettings() *structpb.Struct
func (*Integration) ProtoMessage ¶
func (*Integration) ProtoMessage()
func (*Integration) ProtoReflect ¶
func (x *Integration) ProtoReflect() protoreflect.Message
func (*Integration) Reset ¶
func (x *Integration) Reset()
func (*Integration) String ¶
func (x *Integration) String() string
type IntegrationAddRequest ¶
type IntegrationAddRequest struct { Integration *Integration `protobuf:"bytes,1,opt,name=integration,proto3" json:"integration,omitempty"` // contains filtered or unexported fields }
func (*IntegrationAddRequest) Descriptor
deprecated
func (*IntegrationAddRequest) Descriptor() ([]byte, []int)
Deprecated: Use IntegrationAddRequest.ProtoReflect.Descriptor instead.
func (*IntegrationAddRequest) GetIntegration ¶
func (x *IntegrationAddRequest) GetIntegration() *Integration
func (*IntegrationAddRequest) ProtoMessage ¶
func (*IntegrationAddRequest) ProtoMessage()
func (*IntegrationAddRequest) ProtoReflect ¶
func (x *IntegrationAddRequest) ProtoReflect() protoreflect.Message
func (*IntegrationAddRequest) Reset ¶
func (x *IntegrationAddRequest) Reset()
func (*IntegrationAddRequest) String ¶
func (x *IntegrationAddRequest) String() string
type IntegrationAddResponse ¶
type IntegrationAddResponse struct { Integration *Integration `protobuf:"bytes,1,opt,name=integration,proto3" json:"integration,omitempty"` // contains filtered or unexported fields }
func (*IntegrationAddResponse) Descriptor
deprecated
func (*IntegrationAddResponse) Descriptor() ([]byte, []int)
Deprecated: Use IntegrationAddResponse.ProtoReflect.Descriptor instead.
func (*IntegrationAddResponse) GetIntegration ¶
func (x *IntegrationAddResponse) GetIntegration() *Integration
func (*IntegrationAddResponse) ProtoMessage ¶
func (*IntegrationAddResponse) ProtoMessage()
func (*IntegrationAddResponse) ProtoReflect ¶
func (x *IntegrationAddResponse) ProtoReflect() protoreflect.Message
func (*IntegrationAddResponse) Reset ¶
func (x *IntegrationAddResponse) Reset()
func (*IntegrationAddResponse) String ¶
func (x *IntegrationAddResponse) String() string
type IntegrationGetRequest ¶
type IntegrationGetRequest struct { Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` ID int32 `protobuf:"varint,2,opt,name=ID,proto3" json:"ID,omitempty"` // contains filtered or unexported fields }
func (*IntegrationGetRequest) Descriptor
deprecated
func (*IntegrationGetRequest) Descriptor() ([]byte, []int)
Deprecated: Use IntegrationGetRequest.ProtoReflect.Descriptor instead.
func (*IntegrationGetRequest) GetID ¶
func (x *IntegrationGetRequest) GetID() int32
func (*IntegrationGetRequest) GetName ¶
func (x *IntegrationGetRequest) GetName() string
func (*IntegrationGetRequest) ProtoMessage ¶
func (*IntegrationGetRequest) ProtoMessage()
func (*IntegrationGetRequest) ProtoReflect ¶
func (x *IntegrationGetRequest) ProtoReflect() protoreflect.Message
func (*IntegrationGetRequest) Reset ¶
func (x *IntegrationGetRequest) Reset()
func (*IntegrationGetRequest) String ¶
func (x *IntegrationGetRequest) String() string
type IntegrationGetResponse ¶
type IntegrationGetResponse struct { Integration *Integration `protobuf:"bytes,1,opt,name=integration,proto3" json:"integration,omitempty"` // contains filtered or unexported fields }
func (*IntegrationGetResponse) Descriptor
deprecated
func (*IntegrationGetResponse) Descriptor() ([]byte, []int)
Deprecated: Use IntegrationGetResponse.ProtoReflect.Descriptor instead.
func (*IntegrationGetResponse) GetIntegration ¶
func (x *IntegrationGetResponse) GetIntegration() *Integration
func (*IntegrationGetResponse) ProtoMessage ¶
func (*IntegrationGetResponse) ProtoMessage()
func (*IntegrationGetResponse) ProtoReflect ¶
func (x *IntegrationGetResponse) ProtoReflect() protoreflect.Message
func (*IntegrationGetResponse) Reset ¶
func (x *IntegrationGetResponse) Reset()
func (*IntegrationGetResponse) String ¶
func (x *IntegrationGetResponse) String() string
type IntegrationListRequest ¶
type IntegrationListRequest struct {
// contains filtered or unexported fields
}
func (*IntegrationListRequest) Descriptor
deprecated
func (*IntegrationListRequest) Descriptor() ([]byte, []int)
Deprecated: Use IntegrationListRequest.ProtoReflect.Descriptor instead.
func (*IntegrationListRequest) ProtoMessage ¶
func (*IntegrationListRequest) ProtoMessage()
func (*IntegrationListRequest) ProtoReflect ¶
func (x *IntegrationListRequest) ProtoReflect() protoreflect.Message
func (*IntegrationListRequest) Reset ¶
func (x *IntegrationListRequest) Reset()
func (*IntegrationListRequest) String ¶
func (x *IntegrationListRequest) String() string
type IntegrationListResponse ¶
type IntegrationListResponse struct { Integrations []*Integration `protobuf:"bytes,1,rep,name=Integrations,proto3" json:"Integrations,omitempty"` // contains filtered or unexported fields }
func (*IntegrationListResponse) Descriptor
deprecated
func (*IntegrationListResponse) Descriptor() ([]byte, []int)
Deprecated: Use IntegrationListResponse.ProtoReflect.Descriptor instead.
func (*IntegrationListResponse) GetIntegrations ¶
func (x *IntegrationListResponse) GetIntegrations() []*Integration
func (*IntegrationListResponse) ProtoMessage ¶
func (*IntegrationListResponse) ProtoMessage()
func (*IntegrationListResponse) ProtoReflect ¶
func (x *IntegrationListResponse) ProtoReflect() protoreflect.Message
func (*IntegrationListResponse) Reset ¶
func (x *IntegrationListResponse) Reset()
func (*IntegrationListResponse) String ¶
func (x *IntegrationListResponse) String() string
type IntegrationRemoveRequest ¶
type IntegrationRemoveRequest struct { Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` // contains filtered or unexported fields }
func (*IntegrationRemoveRequest) Descriptor
deprecated
func (*IntegrationRemoveRequest) Descriptor() ([]byte, []int)
Deprecated: Use IntegrationRemoveRequest.ProtoReflect.Descriptor instead.
func (*IntegrationRemoveRequest) GetName ¶
func (x *IntegrationRemoveRequest) GetName() string
func (*IntegrationRemoveRequest) ProtoMessage ¶
func (*IntegrationRemoveRequest) ProtoMessage()
func (*IntegrationRemoveRequest) ProtoReflect ¶
func (x *IntegrationRemoveRequest) ProtoReflect() protoreflect.Message
func (*IntegrationRemoveRequest) Reset ¶
func (x *IntegrationRemoveRequest) Reset()
func (*IntegrationRemoveRequest) String ¶
func (x *IntegrationRemoveRequest) String() string
type IntegrationRemoveResponse ¶
type IntegrationRemoveResponse struct {
// contains filtered or unexported fields
}
func (*IntegrationRemoveResponse) Descriptor
deprecated
func (*IntegrationRemoveResponse) Descriptor() ([]byte, []int)
Deprecated: Use IntegrationRemoveResponse.ProtoReflect.Descriptor instead.
func (*IntegrationRemoveResponse) ProtoMessage ¶
func (*IntegrationRemoveResponse) ProtoMessage()
func (*IntegrationRemoveResponse) ProtoReflect ¶
func (x *IntegrationRemoveResponse) ProtoReflect() protoreflect.Message
func (*IntegrationRemoveResponse) Reset ¶
func (x *IntegrationRemoveResponse) Reset()
func (*IntegrationRemoveResponse) String ¶
func (x *IntegrationRemoveResponse) String() string
type IntegrationUpdateRequest ¶
type IntegrationUpdateRequest struct { Integration *Integration `protobuf:"bytes,1,opt,name=integration,proto3" json:"integration,omitempty"` // contains filtered or unexported fields }
func (*IntegrationUpdateRequest) Descriptor
deprecated
func (*IntegrationUpdateRequest) Descriptor() ([]byte, []int)
Deprecated: Use IntegrationUpdateRequest.ProtoReflect.Descriptor instead.
func (*IntegrationUpdateRequest) GetIntegration ¶
func (x *IntegrationUpdateRequest) GetIntegration() *Integration
func (*IntegrationUpdateRequest) ProtoMessage ¶
func (*IntegrationUpdateRequest) ProtoMessage()
func (*IntegrationUpdateRequest) ProtoReflect ¶
func (x *IntegrationUpdateRequest) ProtoReflect() protoreflect.Message
func (*IntegrationUpdateRequest) Reset ¶
func (x *IntegrationUpdateRequest) Reset()
func (*IntegrationUpdateRequest) String ¶
func (x *IntegrationUpdateRequest) String() string
type IntegrationUpdateResponse ¶
type IntegrationUpdateResponse struct { Integration *Integration `protobuf:"bytes,1,opt,name=integration,proto3" json:"integration,omitempty"` // contains filtered or unexported fields }
func (*IntegrationUpdateResponse) Descriptor
deprecated
func (*IntegrationUpdateResponse) Descriptor() ([]byte, []int)
Deprecated: Use IntegrationUpdateResponse.ProtoReflect.Descriptor instead.
func (*IntegrationUpdateResponse) GetIntegration ¶
func (x *IntegrationUpdateResponse) GetIntegration() *Integration
func (*IntegrationUpdateResponse) ProtoMessage ¶
func (*IntegrationUpdateResponse) ProtoMessage()
func (*IntegrationUpdateResponse) ProtoReflect ¶
func (x *IntegrationUpdateResponse) ProtoReflect() protoreflect.Message
func (*IntegrationUpdateResponse) Reset ¶
func (x *IntegrationUpdateResponse) Reset()
func (*IntegrationUpdateResponse) String ¶
func (x *IntegrationUpdateResponse) String() string
type IntegrationsClient ¶
type IntegrationsClient interface { ListIntegrations(ctx context.Context, in *IntegrationListRequest, opts ...grpc.CallOption) (*IntegrationListResponse, error) GetIntegration(ctx context.Context, in *IntegrationGetRequest, opts ...grpc.CallOption) (*IntegrationGetResponse, error) AddIntegration(ctx context.Context, in *IntegrationAddRequest, opts ...grpc.CallOption) (*IntegrationAddResponse, error) UpdateIntegration(ctx context.Context, in *IntegrationUpdateRequest, opts ...grpc.CallOption) (*IntegrationUpdateResponse, error) RemoveIntegration(ctx context.Context, in *IntegrationRemoveRequest, opts ...grpc.CallOption) (*IntegrationRemoveResponse, error) JobUpdate(ctx context.Context, in *JobUpdateRequest, opts ...grpc.CallOption) (*JobUpdateResponse, error) GetJobHistory(ctx context.Context, in *JobGetHistoryRequest, opts ...grpc.CallOption) (*JobGetHistoryResponse, error) }
IntegrationsClient is the client API for Integrations 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 NewIntegrationsClient ¶
func NewIntegrationsClient(cc grpc.ClientConnInterface) IntegrationsClient
type IntegrationsServer ¶
type IntegrationsServer interface { ListIntegrations(context.Context, *IntegrationListRequest) (*IntegrationListResponse, error) GetIntegration(context.Context, *IntegrationGetRequest) (*IntegrationGetResponse, error) AddIntegration(context.Context, *IntegrationAddRequest) (*IntegrationAddResponse, error) UpdateIntegration(context.Context, *IntegrationUpdateRequest) (*IntegrationUpdateResponse, error) RemoveIntegration(context.Context, *IntegrationRemoveRequest) (*IntegrationRemoveResponse, error) JobUpdate(context.Context, *JobUpdateRequest) (*JobUpdateResponse, error) GetJobHistory(context.Context, *JobGetHistoryRequest) (*JobGetHistoryResponse, error) // contains filtered or unexported methods }
IntegrationsServer is the server API for Integrations service. All implementations must embed UnimplementedIntegrationsServer for forward compatibility
type Job ¶
type Job struct { IntegrationName string `protobuf:"bytes,1,opt,name=IntegrationName,proto3" json:"IntegrationName,omitempty"` Started *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=Started,proto3" json:"Started,omitempty"` Ended *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=Ended,proto3" json:"Ended,omitempty"` Status JobStatus `protobuf:"varint,4,opt,name=Status,proto3,enum=userapi.JobStatus" json:"Status,omitempty"` Error string `protobuf:"bytes,5,opt,name=Error,proto3" json:"Error,omitempty"` ID int32 `protobuf:"varint,6,opt,name=ID,proto3" json:"ID,omitempty"` // contains filtered or unexported fields }
func (*Job) Descriptor
deprecated
func (*Job) GetEnded ¶
func (x *Job) GetEnded() *timestamppb.Timestamp
func (*Job) GetIntegrationName ¶
func (*Job) GetStarted ¶
func (x *Job) GetStarted() *timestamppb.Timestamp
func (*Job) ProtoMessage ¶
func (*Job) ProtoMessage()
func (*Job) ProtoReflect ¶
func (x *Job) ProtoReflect() protoreflect.Message
type JobGetHistoryRequest ¶
type JobGetHistoryRequest struct { IntegrationName string `protobuf:"bytes,1,opt,name=IntegrationName,proto3" json:"IntegrationName,omitempty"` // contains filtered or unexported fields }
func (*JobGetHistoryRequest) Descriptor
deprecated
func (*JobGetHistoryRequest) Descriptor() ([]byte, []int)
Deprecated: Use JobGetHistoryRequest.ProtoReflect.Descriptor instead.
func (*JobGetHistoryRequest) GetIntegrationName ¶
func (x *JobGetHistoryRequest) GetIntegrationName() string
func (*JobGetHistoryRequest) ProtoMessage ¶
func (*JobGetHistoryRequest) ProtoMessage()
func (*JobGetHistoryRequest) ProtoReflect ¶
func (x *JobGetHistoryRequest) ProtoReflect() protoreflect.Message
func (*JobGetHistoryRequest) Reset ¶
func (x *JobGetHistoryRequest) Reset()
func (*JobGetHistoryRequest) String ¶
func (x *JobGetHistoryRequest) String() string
type JobGetHistoryResponse ¶
type JobGetHistoryResponse struct { JobHistory []*Job `protobuf:"bytes,1,rep,name=jobHistory,proto3" json:"jobHistory,omitempty"` // contains filtered or unexported fields }
func (*JobGetHistoryResponse) Descriptor
deprecated
func (*JobGetHistoryResponse) Descriptor() ([]byte, []int)
Deprecated: Use JobGetHistoryResponse.ProtoReflect.Descriptor instead.
func (*JobGetHistoryResponse) GetJobHistory ¶
func (x *JobGetHistoryResponse) GetJobHistory() []*Job
func (*JobGetHistoryResponse) ProtoMessage ¶
func (*JobGetHistoryResponse) ProtoMessage()
func (*JobGetHistoryResponse) ProtoReflect ¶
func (x *JobGetHistoryResponse) ProtoReflect() protoreflect.Message
func (*JobGetHistoryResponse) Reset ¶
func (x *JobGetHistoryResponse) Reset()
func (*JobGetHistoryResponse) String ¶
func (x *JobGetHistoryResponse) String() string
type JobStatus ¶
type JobStatus int32
func (JobStatus) Descriptor ¶
func (JobStatus) Descriptor() protoreflect.EnumDescriptor
func (JobStatus) EnumDescriptor
deprecated
func (JobStatus) Number ¶
func (x JobStatus) Number() protoreflect.EnumNumber
func (JobStatus) Type ¶
func (JobStatus) Type() protoreflect.EnumType
type JobUpdateRequest ¶
type JobUpdateRequest struct { Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` // contains filtered or unexported fields }
func (*JobUpdateRequest) Descriptor
deprecated
func (*JobUpdateRequest) Descriptor() ([]byte, []int)
Deprecated: Use JobUpdateRequest.ProtoReflect.Descriptor instead.
func (*JobUpdateRequest) GetJob ¶
func (x *JobUpdateRequest) GetJob() *Job
func (*JobUpdateRequest) ProtoMessage ¶
func (*JobUpdateRequest) ProtoMessage()
func (*JobUpdateRequest) ProtoReflect ¶
func (x *JobUpdateRequest) ProtoReflect() protoreflect.Message
func (*JobUpdateRequest) Reset ¶
func (x *JobUpdateRequest) Reset()
func (*JobUpdateRequest) String ¶
func (x *JobUpdateRequest) String() string
type JobUpdateResponse ¶
type JobUpdateResponse struct { Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` // contains filtered or unexported fields }
func (*JobUpdateResponse) Descriptor
deprecated
func (*JobUpdateResponse) Descriptor() ([]byte, []int)
Deprecated: Use JobUpdateResponse.ProtoReflect.Descriptor instead.
func (*JobUpdateResponse) GetJob ¶
func (x *JobUpdateResponse) GetJob() *Job
func (*JobUpdateResponse) ProtoMessage ¶
func (*JobUpdateResponse) ProtoMessage()
func (*JobUpdateResponse) ProtoReflect ¶
func (x *JobUpdateResponse) ProtoReflect() protoreflect.Message
func (*JobUpdateResponse) Reset ¶
func (x *JobUpdateResponse) Reset()
func (*JobUpdateResponse) String ¶
func (x *JobUpdateResponse) String() string
type NaturalBreaksQueryRequest ¶
type NaturalBreaksQueryRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Breaks uint32 `protobuf:"varint,2,opt,name=breaks,proto3" json:"breaks,omitempty"` Begin *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=begin,proto3" json:"begin,omitempty"` End *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end,proto3" json:"end,omitempty"` // contains filtered or unexported fields }
func (*NaturalBreaksQueryRequest) Descriptor
deprecated
func (*NaturalBreaksQueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use NaturalBreaksQueryRequest.ProtoReflect.Descriptor instead.
func (*NaturalBreaksQueryRequest) GetBegin ¶
func (x *NaturalBreaksQueryRequest) GetBegin() *timestamppb.Timestamp
func (*NaturalBreaksQueryRequest) GetBreaks ¶
func (x *NaturalBreaksQueryRequest) GetBreaks() uint32
func (*NaturalBreaksQueryRequest) GetEnd ¶
func (x *NaturalBreaksQueryRequest) GetEnd() *timestamppb.Timestamp
func (*NaturalBreaksQueryRequest) GetName ¶
func (x *NaturalBreaksQueryRequest) GetName() string
func (*NaturalBreaksQueryRequest) ProtoMessage ¶
func (*NaturalBreaksQueryRequest) ProtoMessage()
func (*NaturalBreaksQueryRequest) ProtoReflect ¶
func (x *NaturalBreaksQueryRequest) ProtoReflect() protoreflect.Message
func (*NaturalBreaksQueryRequest) Reset ¶
func (x *NaturalBreaksQueryRequest) Reset()
func (*NaturalBreaksQueryRequest) String ¶
func (x *NaturalBreaksQueryRequest) String() string
type NaturalBreaksRequest ¶
type NaturalBreaksRequest struct { Values []float64 `protobuf:"fixed64,1,rep,packed,name=values,proto3" json:"values,omitempty"` Breaks uint32 `protobuf:"varint,2,opt,name=breaks,proto3" json:"breaks,omitempty"` // contains filtered or unexported fields }
func (*NaturalBreaksRequest) Descriptor
deprecated
func (*NaturalBreaksRequest) Descriptor() ([]byte, []int)
Deprecated: Use NaturalBreaksRequest.ProtoReflect.Descriptor instead.
func (*NaturalBreaksRequest) GetBreaks ¶
func (x *NaturalBreaksRequest) GetBreaks() uint32
func (*NaturalBreaksRequest) GetValues ¶
func (x *NaturalBreaksRequest) GetValues() []float64
func (*NaturalBreaksRequest) ProtoMessage ¶
func (*NaturalBreaksRequest) ProtoMessage()
func (*NaturalBreaksRequest) ProtoReflect ¶
func (x *NaturalBreaksRequest) ProtoReflect() protoreflect.Message
func (*NaturalBreaksRequest) Reset ¶
func (x *NaturalBreaksRequest) Reset()
func (*NaturalBreaksRequest) String ¶
func (x *NaturalBreaksRequest) String() string
type NaturalBreaksResponse ¶
type NaturalBreaksResponse struct { Breaks []float64 `protobuf:"fixed64,1,rep,packed,name=breaks,proto3" json:"breaks,omitempty"` // contains filtered or unexported fields }
func (*NaturalBreaksResponse) Descriptor
deprecated
func (*NaturalBreaksResponse) Descriptor() ([]byte, []int)
Deprecated: Use NaturalBreaksResponse.ProtoReflect.Descriptor instead.
func (*NaturalBreaksResponse) GetBreaks ¶
func (x *NaturalBreaksResponse) GetBreaks() []float64
func (*NaturalBreaksResponse) ProtoMessage ¶
func (*NaturalBreaksResponse) ProtoMessage()
func (*NaturalBreaksResponse) ProtoReflect ¶
func (x *NaturalBreaksResponse) ProtoReflect() protoreflect.Message
func (*NaturalBreaksResponse) Reset ¶
func (x *NaturalBreaksResponse) Reset()
func (*NaturalBreaksResponse) String ¶
func (x *NaturalBreaksResponse) String() string
type NewUser ¶
type NewUser struct { Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"` ExternalId string `protobuf:"bytes,3,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"` Attributes *structpb.Struct `protobuf:"bytes,4,opt,name=attributes,proto3" json:"attributes,omitempty"` Traits *structpb.Struct `protobuf:"bytes,5,opt,name=traits,proto3" json:"traits,omitempty"` // contains filtered or unexported fields }
func (*NewUser) Descriptor
deprecated
func (*NewUser) GetAttributes ¶
func (*NewUser) GetExternalId ¶
func (*NewUser) GetUsername ¶
func (*NewUser) ProtoMessage ¶
func (*NewUser) ProtoMessage()
func (*NewUser) ProtoReflect ¶
func (x *NewUser) ProtoReflect() protoreflect.Message
type Operator ¶
type Operator int32
const ( Operator_EQUALS Operator = 0 Operator_NOT_EQUALS Operator = 1 Operator_GREATER_THAN Operator = 2 Operator_GREATER_THAN_OR_EQUALS Operator = 3 Operator_LESS_THAN Operator = 4 Operator_LESS_THAN_OR_EQUALS Operator = 5 Operator_IN Operator = 6 Operator_NOT_IN Operator = 7 Operator_CONTAINS Operator = 8 Operator_NOT_CONTAINS Operator = 9 )
func (Operator) Descriptor ¶
func (Operator) Descriptor() protoreflect.EnumDescriptor
func (Operator) EnumDescriptor
deprecated
func (Operator) Number ¶
func (x Operator) Number() protoreflect.EnumNumber
func (Operator) Type ¶
func (Operator) Type() protoreflect.EnumType
type QueryRequest ¶
type QueryRequest struct { Query []byte `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` // contains filtered or unexported fields }
func (*QueryRequest) Descriptor
deprecated
func (*QueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.
func (*QueryRequest) GetQuery ¶
func (x *QueryRequest) GetQuery() []byte
func (*QueryRequest) ProtoMessage ¶
func (*QueryRequest) ProtoMessage()
func (*QueryRequest) ProtoReflect ¶
func (x *QueryRequest) ProtoReflect() protoreflect.Message
func (*QueryRequest) Reset ¶
func (x *QueryRequest) Reset()
func (*QueryRequest) String ¶
func (x *QueryRequest) String() string
type SearchEventsRequest ¶
type SearchEventsRequest struct { UserId *UserID `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` Names []string `protobuf:"bytes,2,rep,name=names,proto3" json:"names,omitempty"` Begin *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=begin,proto3" json:"begin,omitempty"` End *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end,proto3" json:"end,omitempty"` Limit int32 `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*SearchEventsRequest) Descriptor
deprecated
func (*SearchEventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use SearchEventsRequest.ProtoReflect.Descriptor instead.
func (*SearchEventsRequest) GetBegin ¶
func (x *SearchEventsRequest) GetBegin() *timestamppb.Timestamp
func (*SearchEventsRequest) GetEnd ¶
func (x *SearchEventsRequest) GetEnd() *timestamppb.Timestamp
func (*SearchEventsRequest) GetLimit ¶
func (x *SearchEventsRequest) GetLimit() int32
func (*SearchEventsRequest) GetNames ¶
func (x *SearchEventsRequest) GetNames() []string
func (*SearchEventsRequest) GetUserId ¶
func (x *SearchEventsRequest) GetUserId() *UserID
func (*SearchEventsRequest) ProtoMessage ¶
func (*SearchEventsRequest) ProtoMessage()
func (*SearchEventsRequest) ProtoReflect ¶
func (x *SearchEventsRequest) ProtoReflect() protoreflect.Message
func (*SearchEventsRequest) Reset ¶
func (x *SearchEventsRequest) Reset()
func (*SearchEventsRequest) String ¶
func (x *SearchEventsRequest) String() string
type SearchEventsResponse ¶
type SearchEventsResponse struct { Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"` // contains filtered or unexported fields }
func (*SearchEventsResponse) Descriptor
deprecated
func (*SearchEventsResponse) Descriptor() ([]byte, []int)
Deprecated: Use SearchEventsResponse.ProtoReflect.Descriptor instead.
func (*SearchEventsResponse) GetEvents ¶
func (x *SearchEventsResponse) GetEvents() []*Event
func (*SearchEventsResponse) ProtoMessage ¶
func (*SearchEventsResponse) ProtoMessage()
func (*SearchEventsResponse) ProtoReflect ¶
func (x *SearchEventsResponse) ProtoReflect() protoreflect.Message
func (*SearchEventsResponse) Reset ¶
func (x *SearchEventsResponse) Reset()
func (*SearchEventsResponse) String ¶
func (x *SearchEventsResponse) String() string
type SearchUserEventsRequest ¶
type SearchUserEventsRequest struct { Types []string `protobuf:"bytes,1,rep,name=types,proto3" json:"types,omitempty"` Subjects []string `protobuf:"bytes,2,rep,name=subjects,proto3" json:"subjects,omitempty"` Sources []string `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"` Schemas []string `protobuf:"bytes,4,rep,name=schemas,proto3" json:"schemas,omitempty"` Begin *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=begin,proto3" json:"begin,omitempty"` End *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=end,proto3" json:"end,omitempty"` Limit int32 `protobuf:"varint,7,opt,name=limit,proto3" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*SearchUserEventsRequest) Descriptor
deprecated
func (*SearchUserEventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use SearchUserEventsRequest.ProtoReflect.Descriptor instead.
func (*SearchUserEventsRequest) GetBegin ¶
func (x *SearchUserEventsRequest) GetBegin() *timestamppb.Timestamp
func (*SearchUserEventsRequest) GetEnd ¶
func (x *SearchUserEventsRequest) GetEnd() *timestamppb.Timestamp
func (*SearchUserEventsRequest) GetLimit ¶
func (x *SearchUserEventsRequest) GetLimit() int32
func (*SearchUserEventsRequest) GetSchemas ¶
func (x *SearchUserEventsRequest) GetSchemas() []string
func (*SearchUserEventsRequest) GetSources ¶
func (x *SearchUserEventsRequest) GetSources() []string
func (*SearchUserEventsRequest) GetSubjects ¶
func (x *SearchUserEventsRequest) GetSubjects() []string
func (*SearchUserEventsRequest) GetTypes ¶
func (x *SearchUserEventsRequest) GetTypes() []string
func (*SearchUserEventsRequest) ProtoMessage ¶
func (*SearchUserEventsRequest) ProtoMessage()
func (*SearchUserEventsRequest) ProtoReflect ¶
func (x *SearchUserEventsRequest) ProtoReflect() protoreflect.Message
func (*SearchUserEventsRequest) Reset ¶
func (x *SearchUserEventsRequest) Reset()
func (*SearchUserEventsRequest) String ¶
func (x *SearchUserEventsRequest) String() string
type SearchUserTraitsRequest ¶
type SearchUserTraitsRequest struct { UserId *UserID `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` Names []string `protobuf:"bytes,32,rep,name=names,proto3" json:"names,omitempty"` Begin *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=begin,proto3" json:"begin,omitempty"` End *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end,proto3" json:"end,omitempty"` Limit int32 `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"` Latest bool `protobuf:"varint,6,opt,name=latest,proto3" json:"latest,omitempty"` // contains filtered or unexported fields }
func (*SearchUserTraitsRequest) Descriptor
deprecated
func (*SearchUserTraitsRequest) Descriptor() ([]byte, []int)
Deprecated: Use SearchUserTraitsRequest.ProtoReflect.Descriptor instead.
func (*SearchUserTraitsRequest) GetBegin ¶
func (x *SearchUserTraitsRequest) GetBegin() *timestamppb.Timestamp
func (*SearchUserTraitsRequest) GetEnd ¶
func (x *SearchUserTraitsRequest) GetEnd() *timestamppb.Timestamp
func (*SearchUserTraitsRequest) GetLatest ¶
func (x *SearchUserTraitsRequest) GetLatest() bool
func (*SearchUserTraitsRequest) GetLimit ¶
func (x *SearchUserTraitsRequest) GetLimit() int32
func (*SearchUserTraitsRequest) GetNames ¶
func (x *SearchUserTraitsRequest) GetNames() []string
func (*SearchUserTraitsRequest) GetUserId ¶
func (x *SearchUserTraitsRequest) GetUserId() *UserID
func (*SearchUserTraitsRequest) ProtoMessage ¶
func (*SearchUserTraitsRequest) ProtoMessage()
func (*SearchUserTraitsRequest) ProtoReflect ¶
func (x *SearchUserTraitsRequest) ProtoReflect() protoreflect.Message
func (*SearchUserTraitsRequest) Reset ¶
func (x *SearchUserTraitsRequest) Reset()
func (*SearchUserTraitsRequest) String ¶
func (x *SearchUserTraitsRequest) String() string
type SearchUserTraitsResponse ¶
type SearchUserTraitsResponse struct { Traits []*structpb.Struct `protobuf:"bytes,1,rep,name=traits,proto3" json:"traits,omitempty"` // contains filtered or unexported fields }
func (*SearchUserTraitsResponse) Descriptor
deprecated
func (*SearchUserTraitsResponse) Descriptor() ([]byte, []int)
Deprecated: Use SearchUserTraitsResponse.ProtoReflect.Descriptor instead.
func (*SearchUserTraitsResponse) GetTraits ¶
func (x *SearchUserTraitsResponse) GetTraits() []*structpb.Struct
func (*SearchUserTraitsResponse) ProtoMessage ¶
func (*SearchUserTraitsResponse) ProtoMessage()
func (*SearchUserTraitsResponse) ProtoReflect ¶
func (x *SearchUserTraitsResponse) ProtoReflect() protoreflect.Message
func (*SearchUserTraitsResponse) Reset ¶
func (x *SearchUserTraitsResponse) Reset()
func (*SearchUserTraitsResponse) String ¶
func (x *SearchUserTraitsResponse) String() string
type Session ¶
type Session struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` UserId *UserID `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Object *structpb.Struct `protobuf:"bytes,4,opt,name=object,proto3" json:"object,omitempty"` // contains filtered or unexported fields }
func (*Session) Descriptor
deprecated
func (*Session) GetTimestamp ¶
func (x *Session) GetTimestamp() *timestamppb.Timestamp
func (*Session) ProtoMessage ¶
func (*Session) ProtoMessage()
func (*Session) ProtoReflect ¶
func (x *Session) ProtoReflect() protoreflect.Message
type SessionEventRequest ¶
type SessionEventRequest struct { Event *Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"` // contains filtered or unexported fields }
func (*SessionEventRequest) Descriptor
deprecated
func (*SessionEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use SessionEventRequest.ProtoReflect.Descriptor instead.
func (*SessionEventRequest) GetEvent ¶
func (x *SessionEventRequest) GetEvent() *Event
func (*SessionEventRequest) ProtoMessage ¶
func (*SessionEventRequest) ProtoMessage()
func (*SessionEventRequest) ProtoReflect ¶
func (x *SessionEventRequest) ProtoReflect() protoreflect.Message
func (*SessionEventRequest) Reset ¶
func (x *SessionEventRequest) Reset()
func (*SessionEventRequest) String ¶
func (x *SessionEventRequest) String() string
type SessionEventResponse ¶
type SessionEventResponse struct { Event *Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"` // contains filtered or unexported fields }
func (*SessionEventResponse) Descriptor
deprecated
func (*SessionEventResponse) Descriptor() ([]byte, []int)
Deprecated: Use SessionEventResponse.ProtoReflect.Descriptor instead.
func (*SessionEventResponse) GetEvent ¶
func (x *SessionEventResponse) GetEvent() *Event
func (*SessionEventResponse) ProtoMessage ¶
func (*SessionEventResponse) ProtoMessage()
func (*SessionEventResponse) ProtoReflect ¶
func (x *SessionEventResponse) ProtoReflect() protoreflect.Message
func (*SessionEventResponse) Reset ¶
func (x *SessionEventResponse) Reset()
func (*SessionEventResponse) String ¶
func (x *SessionEventResponse) String() string
type SessionListResponse ¶
type SessionListResponse struct { Sessions []*Session `protobuf:"bytes,1,rep,name=Sessions,proto3" json:"Sessions,omitempty"` // contains filtered or unexported fields }
func (*SessionListResponse) Descriptor
deprecated
func (*SessionListResponse) Descriptor() ([]byte, []int)
Deprecated: Use SessionListResponse.ProtoReflect.Descriptor instead.
func (*SessionListResponse) GetSessions ¶
func (x *SessionListResponse) GetSessions() []*Session
func (*SessionListResponse) ProtoMessage ¶
func (*SessionListResponse) ProtoMessage()
func (*SessionListResponse) ProtoReflect ¶
func (x *SessionListResponse) ProtoReflect() protoreflect.Message
func (*SessionListResponse) Reset ¶
func (x *SessionListResponse) Reset()
func (*SessionListResponse) String ¶
func (x *SessionListResponse) String() string
type SessionRequest ¶
type SessionRequest struct { Session *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"` // contains filtered or unexported fields }
func (*SessionRequest) Descriptor
deprecated
func (*SessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use SessionRequest.ProtoReflect.Descriptor instead.
func (*SessionRequest) GetSession ¶
func (x *SessionRequest) GetSession() *Session
func (*SessionRequest) ProtoMessage ¶
func (*SessionRequest) ProtoMessage()
func (*SessionRequest) ProtoReflect ¶
func (x *SessionRequest) ProtoReflect() protoreflect.Message
func (*SessionRequest) Reset ¶
func (x *SessionRequest) Reset()
func (*SessionRequest) String ¶
func (x *SessionRequest) String() string
type SessionResponse ¶
type SessionResponse struct { Session *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"` // contains filtered or unexported fields }
func (*SessionResponse) Descriptor
deprecated
func (*SessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use SessionResponse.ProtoReflect.Descriptor instead.
func (*SessionResponse) GetSession ¶
func (x *SessionResponse) GetSession() *Session
func (*SessionResponse) ProtoMessage ¶
func (*SessionResponse) ProtoMessage()
func (*SessionResponse) ProtoReflect ¶
func (x *SessionResponse) ProtoReflect() protoreflect.Message
func (*SessionResponse) Reset ¶
func (x *SessionResponse) Reset()
func (*SessionResponse) String ¶
func (x *SessionResponse) String() string
type TraitFilter ¶
type TraitFilter struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Operator Operator `protobuf:"varint,2,opt,name=operator,proto3,enum=userapi.Operator" json:"operator,omitempty"` Value *structpb.Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*TraitFilter) Descriptor
deprecated
func (*TraitFilter) Descriptor() ([]byte, []int)
Deprecated: Use TraitFilter.ProtoReflect.Descriptor instead.
func (*TraitFilter) GetName ¶
func (x *TraitFilter) GetName() string
func (*TraitFilter) GetOperator ¶
func (x *TraitFilter) GetOperator() Operator
func (*TraitFilter) GetValue ¶
func (x *TraitFilter) GetValue() *structpb.Value
func (*TraitFilter) ProtoMessage ¶
func (*TraitFilter) ProtoMessage()
func (*TraitFilter) ProtoReflect ¶
func (x *TraitFilter) ProtoReflect() protoreflect.Message
func (*TraitFilter) Reset ¶
func (x *TraitFilter) Reset()
func (*TraitFilter) String ¶
func (x *TraitFilter) String() string
type TraitListResponse ¶
type TraitListResponse struct { Traits *structpb.Struct `protobuf:"bytes,1,opt,name=traits,proto3" json:"traits,omitempty"` NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
func (*TraitListResponse) Descriptor
deprecated
func (*TraitListResponse) Descriptor() ([]byte, []int)
Deprecated: Use TraitListResponse.ProtoReflect.Descriptor instead.
func (*TraitListResponse) GetNextPageToken ¶
func (x *TraitListResponse) GetNextPageToken() string
func (*TraitListResponse) GetTraits ¶
func (x *TraitListResponse) GetTraits() *structpb.Struct
func (*TraitListResponse) ProtoMessage ¶
func (*TraitListResponse) ProtoMessage()
func (*TraitListResponse) ProtoReflect ¶
func (x *TraitListResponse) ProtoReflect() protoreflect.Message
func (*TraitListResponse) Reset ¶
func (x *TraitListResponse) Reset()
func (*TraitListResponse) String ¶
func (x *TraitListResponse) String() string
type TraitRequest ¶
type TraitRequest struct { UserId *UserID `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Value *structpb.Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*TraitRequest) Descriptor
deprecated
func (*TraitRequest) Descriptor() ([]byte, []int)
Deprecated: Use TraitRequest.ProtoReflect.Descriptor instead.
func (*TraitRequest) GetKey ¶
func (x *TraitRequest) GetKey() string
func (*TraitRequest) GetUserId ¶
func (x *TraitRequest) GetUserId() *UserID
func (*TraitRequest) GetValue ¶
func (x *TraitRequest) GetValue() *structpb.Value
func (*TraitRequest) ProtoMessage ¶
func (*TraitRequest) ProtoMessage()
func (*TraitRequest) ProtoReflect ¶
func (x *TraitRequest) ProtoReflect() protoreflect.Message
func (*TraitRequest) Reset ¶
func (x *TraitRequest) Reset()
func (*TraitRequest) String ¶
func (x *TraitRequest) String() string
type TraitResponse ¶
type TraitResponse struct {
// contains filtered or unexported fields
}
func (*TraitResponse) Descriptor
deprecated
func (*TraitResponse) Descriptor() ([]byte, []int)
Deprecated: Use TraitResponse.ProtoReflect.Descriptor instead.
func (*TraitResponse) ProtoMessage ¶
func (*TraitResponse) ProtoMessage()
func (*TraitResponse) ProtoReflect ¶
func (x *TraitResponse) ProtoReflect() protoreflect.Message
func (*TraitResponse) Reset ¶
func (x *TraitResponse) Reset()
func (*TraitResponse) String ¶
func (x *TraitResponse) String() string
type UnimplementedIntegrationsServer ¶
type UnimplementedIntegrationsServer struct { }
UnimplementedIntegrationsServer must be embedded to have forward compatible implementations.
func (UnimplementedIntegrationsServer) AddIntegration ¶
func (UnimplementedIntegrationsServer) AddIntegration(context.Context, *IntegrationAddRequest) (*IntegrationAddResponse, error)
func (UnimplementedIntegrationsServer) GetIntegration ¶
func (UnimplementedIntegrationsServer) GetIntegration(context.Context, *IntegrationGetRequest) (*IntegrationGetResponse, error)
func (UnimplementedIntegrationsServer) GetJobHistory ¶
func (UnimplementedIntegrationsServer) GetJobHistory(context.Context, *JobGetHistoryRequest) (*JobGetHistoryResponse, error)
func (UnimplementedIntegrationsServer) JobUpdate ¶
func (UnimplementedIntegrationsServer) JobUpdate(context.Context, *JobUpdateRequest) (*JobUpdateResponse, error)
func (UnimplementedIntegrationsServer) ListIntegrations ¶
func (UnimplementedIntegrationsServer) ListIntegrations(context.Context, *IntegrationListRequest) (*IntegrationListResponse, error)
func (UnimplementedIntegrationsServer) RemoveIntegration ¶
func (UnimplementedIntegrationsServer) RemoveIntegration(context.Context, *IntegrationRemoveRequest) (*IntegrationRemoveResponse, error)
func (UnimplementedIntegrationsServer) UpdateIntegration ¶
func (UnimplementedIntegrationsServer) UpdateIntegration(context.Context, *IntegrationUpdateRequest) (*IntegrationUpdateResponse, error)
type UnimplementedUsersServer ¶
type UnimplementedUsersServer struct { }
UnimplementedUsersServer must be embedded to have forward compatible implementations.
func (UnimplementedUsersServer) AddAttribute ¶
func (UnimplementedUsersServer) AddAttribute(context.Context, *AttributeRequest) (*AttributeResponse, error)
func (UnimplementedUsersServer) AddSession ¶
func (UnimplementedUsersServer) AddSession(context.Context, *SessionRequest) (*SessionResponse, error)
func (UnimplementedUsersServer) AddTrait ¶
func (UnimplementedUsersServer) AddTrait(context.Context, *TraitRequest) (*TraitResponse, error)
func (UnimplementedUsersServer) Create ¶
func (UnimplementedUsersServer) Create(context.Context, *NewUser) (*UserResponse, error)
func (UnimplementedUsersServer) Delete ¶
func (UnimplementedUsersServer) Delete(context.Context, *UserRequest) (*UserResponse, error)
func (UnimplementedUsersServer) DeleteAttribute ¶
func (UnimplementedUsersServer) DeleteAttribute(context.Context, *AttributeRequest) (*AttributeResponse, error)
func (UnimplementedUsersServer) DeleteTrait ¶
func (UnimplementedUsersServer) DeleteTrait(context.Context, *TraitRequest) (*TraitResponse, error)
func (UnimplementedUsersServer) Find ¶
func (UnimplementedUsersServer) Find(context.Context, *UserQuery) (*UserListResponse, error)
func (UnimplementedUsersServer) Get ¶
func (UnimplementedUsersServer) Get(context.Context, *UserRequest) (*UserResponse, error)
func (UnimplementedUsersServer) GetAggregateForUsers ¶
func (UnimplementedUsersServer) GetAggregateForUsers(context.Context, *GetAggregateForUsersRequest) (*AggregateResponse, error)
func (UnimplementedUsersServer) GetSessionEvents ¶
func (UnimplementedUsersServer) GetSessionEvents(context.Context, *GetSessionEventsRequest) (*EventListResponse, error)
func (UnimplementedUsersServer) GetSessions ¶
func (UnimplementedUsersServer) GetSessions(context.Context, *GetSessionsRequest) (*SessionListResponse, error)
func (UnimplementedUsersServer) GetUsersByAggregatedTraits ¶
func (UnimplementedUsersServer) GetUsersByAggregatedTraits(context.Context, *GetUsersByAggregatedTraitsRequest) (*UserListResponse, error)
func (UnimplementedUsersServer) GetUsersByEvents ¶
func (UnimplementedUsersServer) GetUsersByEvents(context.Context, *SearchUserEventsRequest) (*UserListResponse, error)
func (UnimplementedUsersServer) GetUsersByTraits ¶
func (UnimplementedUsersServer) GetUsersByTraits(context.Context, *SearchUserTraitsRequest) (*UserListResponse, error)
func (UnimplementedUsersServer) IdentifySession ¶
func (UnimplementedUsersServer) IdentifySession(context.Context, *IdentifySessionRequest) (*IdentifySessionResponse, error)
func (UnimplementedUsersServer) LogEvent ¶
func (UnimplementedUsersServer) LogEvent(context.Context, *EventRequest) (*EventResponse, error)
func (UnimplementedUsersServer) LogSessionEvent ¶
func (UnimplementedUsersServer) LogSessionEvent(context.Context, *SessionEventRequest) (*SessionEventResponse, error)
func (UnimplementedUsersServer) NaturalBreaks ¶
func (UnimplementedUsersServer) NaturalBreaks(context.Context, *NaturalBreaksRequest) (*NaturalBreaksResponse, error)
func (UnimplementedUsersServer) NaturalBreaksQueried ¶
func (UnimplementedUsersServer) NaturalBreaksQueried(context.Context, *NaturalBreaksQueryRequest) (*NaturalBreaksResponse, error)
func (UnimplementedUsersServer) QueryAttributes ¶
func (UnimplementedUsersServer) QueryAttributes(context.Context, *QueryRequest) (*AttributeListResponse, error)
func (UnimplementedUsersServer) QueryEvents ¶
func (UnimplementedUsersServer) QueryEvents(context.Context, *QueryRequest) (*SearchEventsResponse, error)
func (UnimplementedUsersServer) QueryTraits ¶
func (UnimplementedUsersServer) QueryTraits(context.Context, *QueryRequest) (*TraitListResponse, error)
func (UnimplementedUsersServer) QueryUsers ¶
func (UnimplementedUsersServer) QueryUsers(context.Context, *QueryRequest) (*UserListResponse, error)
func (UnimplementedUsersServer) SearchEvents ¶
func (UnimplementedUsersServer) SearchEvents(context.Context, *SearchEventsRequest) (*SearchEventsResponse, error)
func (UnimplementedUsersServer) SearchUserTraits ¶
func (UnimplementedUsersServer) SearchUserTraits(context.Context, *SearchUserTraitsRequest) (*SearchUserTraitsResponse, error)
func (UnimplementedUsersServer) Update ¶
func (UnimplementedUsersServer) Update(context.Context, *UserRequest) (*UserResponse, error)
type UnsafeIntegrationsServer ¶
type UnsafeIntegrationsServer interface {
// contains filtered or unexported methods
}
UnsafeIntegrationsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IntegrationsServer will result in compilation errors.
type UnsafeUsersServer ¶
type UnsafeUsersServer interface {
// contains filtered or unexported methods
}
UnsafeUsersServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UsersServer will result in compilation errors.
type UserID ¶
type UserID struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"` ExternalId string `protobuf:"bytes,3,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"` // contains filtered or unexported fields }
func (*UserID) Descriptor
deprecated
func (*UserID) GetExternalId ¶
func (*UserID) ProtoMessage ¶
func (*UserID) ProtoMessage()
func (*UserID) ProtoReflect ¶
func (x *UserID) ProtoReflect() protoreflect.Message
type UserListResponse ¶
type UserListResponse struct { Users []*UserResponse `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"` NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
func (*UserListResponse) Descriptor
deprecated
func (*UserListResponse) Descriptor() ([]byte, []int)
Deprecated: Use UserListResponse.ProtoReflect.Descriptor instead.
func (*UserListResponse) GetNextPageToken ¶
func (x *UserListResponse) GetNextPageToken() string
func (*UserListResponse) GetUsers ¶
func (x *UserListResponse) GetUsers() []*UserResponse
func (*UserListResponse) ProtoMessage ¶
func (*UserListResponse) ProtoMessage()
func (*UserListResponse) ProtoReflect ¶
func (x *UserListResponse) ProtoReflect() protoreflect.Message
func (*UserListResponse) Reset ¶
func (x *UserListResponse) Reset()
func (*UserListResponse) String ¶
func (x *UserListResponse) String() string
type UserQuery ¶
type UserQuery struct { PageSize int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` OrderBy string `protobuf:"bytes,3,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"` UserId *UserID `protobuf:"bytes,4,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` Username string `protobuf:"bytes,5,opt,name=username,proto3" json:"username,omitempty"` AttributeFilters []*AttributeFilter `protobuf:"bytes,6,rep,name=attributeFilters,proto3" json:"attributeFilters,omitempty"` TraitFilters []*TraitFilter `protobuf:"bytes,7,rep,name=traitFilters,proto3" json:"traitFilters,omitempty"` // contains filtered or unexported fields }
func (*UserQuery) Descriptor
deprecated
func (*UserQuery) GetAttributeFilters ¶
func (x *UserQuery) GetAttributeFilters() []*AttributeFilter
func (*UserQuery) GetOrderBy ¶
func (*UserQuery) GetPageSize ¶
func (*UserQuery) GetPageToken ¶
func (*UserQuery) GetTraitFilters ¶
func (x *UserQuery) GetTraitFilters() []*TraitFilter
func (*UserQuery) GetUsername ¶
func (*UserQuery) ProtoMessage ¶
func (*UserQuery) ProtoMessage()
func (*UserQuery) ProtoReflect ¶
func (x *UserQuery) ProtoReflect() protoreflect.Message
type UserRequest ¶
type UserRequest struct { Id *UserID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"` Attributes *structpb.Struct `protobuf:"bytes,3,opt,name=attributes,proto3" json:"attributes,omitempty"` Traits *structpb.Struct `protobuf:"bytes,4,opt,name=traits,proto3" json:"traits,omitempty"` // contains filtered or unexported fields }
func (*UserRequest) Descriptor
deprecated
func (*UserRequest) Descriptor() ([]byte, []int)
Deprecated: Use UserRequest.ProtoReflect.Descriptor instead.
func (*UserRequest) GetAttributes ¶
func (x *UserRequest) GetAttributes() *structpb.Struct
func (*UserRequest) GetId ¶
func (x *UserRequest) GetId() *UserID
func (*UserRequest) GetTraits ¶
func (x *UserRequest) GetTraits() *structpb.Struct
func (*UserRequest) GetUsername ¶
func (x *UserRequest) GetUsername() string
func (*UserRequest) ProtoMessage ¶
func (*UserRequest) ProtoMessage()
func (*UserRequest) ProtoReflect ¶
func (x *UserRequest) ProtoReflect() protoreflect.Message
func (*UserRequest) Reset ¶
func (x *UserRequest) Reset()
func (*UserRequest) String ¶
func (x *UserRequest) String() string
type UserResponse ¶
type UserResponse struct { Id *UserID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"` Attributes *structpb.Struct `protobuf:"bytes,3,opt,name=attributes,proto3" json:"attributes,omitempty"` Traits *structpb.Struct `protobuf:"bytes,4,opt,name=traits,proto3" json:"traits,omitempty"` // contains filtered or unexported fields }
func (*UserResponse) Descriptor
deprecated
func (*UserResponse) Descriptor() ([]byte, []int)
Deprecated: Use UserResponse.ProtoReflect.Descriptor instead.
func (*UserResponse) GetAttributes ¶
func (x *UserResponse) GetAttributes() *structpb.Struct
func (*UserResponse) GetId ¶
func (x *UserResponse) GetId() *UserID
func (*UserResponse) GetTraits ¶
func (x *UserResponse) GetTraits() *structpb.Struct
func (*UserResponse) GetUsername ¶
func (x *UserResponse) GetUsername() string
func (*UserResponse) ProtoMessage ¶
func (*UserResponse) ProtoMessage()
func (*UserResponse) ProtoReflect ¶
func (x *UserResponse) ProtoReflect() protoreflect.Message
func (*UserResponse) Reset ¶
func (x *UserResponse) Reset()
func (*UserResponse) String ¶
func (x *UserResponse) String() string
type UsersClient ¶
type UsersClient interface { Create(ctx context.Context, in *NewUser, opts ...grpc.CallOption) (*UserResponse, error) Get(ctx context.Context, in *UserRequest, opts ...grpc.CallOption) (*UserResponse, error) Update(ctx context.Context, in *UserRequest, opts ...grpc.CallOption) (*UserResponse, error) Find(ctx context.Context, in *UserQuery, opts ...grpc.CallOption) (*UserListResponse, error) Delete(ctx context.Context, in *UserRequest, opts ...grpc.CallOption) (*UserResponse, error) LogEvent(ctx context.Context, in *EventRequest, opts ...grpc.CallOption) (*EventResponse, error) AddAttribute(ctx context.Context, in *AttributeRequest, opts ...grpc.CallOption) (*AttributeResponse, error) AddTrait(ctx context.Context, in *TraitRequest, opts ...grpc.CallOption) (*TraitResponse, error) DeleteAttribute(ctx context.Context, in *AttributeRequest, opts ...grpc.CallOption) (*AttributeResponse, error) DeleteTrait(ctx context.Context, in *TraitRequest, opts ...grpc.CallOption) (*TraitResponse, error) SearchUserTraits(ctx context.Context, in *SearchUserTraitsRequest, opts ...grpc.CallOption) (*SearchUserTraitsResponse, error) GetUsersByTraits(ctx context.Context, in *SearchUserTraitsRequest, opts ...grpc.CallOption) (*UserListResponse, error) GetUsersByAggregatedTraits(ctx context.Context, in *GetUsersByAggregatedTraitsRequest, opts ...grpc.CallOption) (*UserListResponse, error) GetAggregateForUsers(ctx context.Context, in *GetAggregateForUsersRequest, opts ...grpc.CallOption) (*AggregateResponse, error) GetUsersByEvents(ctx context.Context, in *SearchUserEventsRequest, opts ...grpc.CallOption) (*UserListResponse, error) SearchEvents(ctx context.Context, in *SearchEventsRequest, opts ...grpc.CallOption) (*SearchEventsResponse, error) NaturalBreaks(ctx context.Context, in *NaturalBreaksRequest, opts ...grpc.CallOption) (*NaturalBreaksResponse, error) NaturalBreaksQueried(ctx context.Context, in *NaturalBreaksQueryRequest, opts ...grpc.CallOption) (*NaturalBreaksResponse, error) QueryUsers(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*UserListResponse, error) QueryAttributes(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*AttributeListResponse, error) QueryTraits(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*TraitListResponse, error) QueryEvents(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*SearchEventsResponse, error) AddSession(ctx context.Context, in *SessionRequest, opts ...grpc.CallOption) (*SessionResponse, error) IdentifySession(ctx context.Context, in *IdentifySessionRequest, opts ...grpc.CallOption) (*IdentifySessionResponse, error) GetSessions(ctx context.Context, in *GetSessionsRequest, opts ...grpc.CallOption) (*SessionListResponse, error) LogSessionEvent(ctx context.Context, in *SessionEventRequest, opts ...grpc.CallOption) (*SessionEventResponse, error) GetSessionEvents(ctx context.Context, in *GetSessionEventsRequest, opts ...grpc.CallOption) (*EventListResponse, error) }
UsersClient is the client API for Users 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 NewUsersClient ¶
func NewUsersClient(cc grpc.ClientConnInterface) UsersClient
type UsersServer ¶
type UsersServer interface { Create(context.Context, *NewUser) (*UserResponse, error) Get(context.Context, *UserRequest) (*UserResponse, error) Update(context.Context, *UserRequest) (*UserResponse, error) Find(context.Context, *UserQuery) (*UserListResponse, error) Delete(context.Context, *UserRequest) (*UserResponse, error) LogEvent(context.Context, *EventRequest) (*EventResponse, error) AddAttribute(context.Context, *AttributeRequest) (*AttributeResponse, error) AddTrait(context.Context, *TraitRequest) (*TraitResponse, error) DeleteAttribute(context.Context, *AttributeRequest) (*AttributeResponse, error) DeleteTrait(context.Context, *TraitRequest) (*TraitResponse, error) SearchUserTraits(context.Context, *SearchUserTraitsRequest) (*SearchUserTraitsResponse, error) GetUsersByTraits(context.Context, *SearchUserTraitsRequest) (*UserListResponse, error) GetUsersByAggregatedTraits(context.Context, *GetUsersByAggregatedTraitsRequest) (*UserListResponse, error) GetAggregateForUsers(context.Context, *GetAggregateForUsersRequest) (*AggregateResponse, error) GetUsersByEvents(context.Context, *SearchUserEventsRequest) (*UserListResponse, error) SearchEvents(context.Context, *SearchEventsRequest) (*SearchEventsResponse, error) NaturalBreaks(context.Context, *NaturalBreaksRequest) (*NaturalBreaksResponse, error) NaturalBreaksQueried(context.Context, *NaturalBreaksQueryRequest) (*NaturalBreaksResponse, error) QueryUsers(context.Context, *QueryRequest) (*UserListResponse, error) QueryAttributes(context.Context, *QueryRequest) (*AttributeListResponse, error) QueryTraits(context.Context, *QueryRequest) (*TraitListResponse, error) QueryEvents(context.Context, *QueryRequest) (*SearchEventsResponse, error) AddSession(context.Context, *SessionRequest) (*SessionResponse, error) IdentifySession(context.Context, *IdentifySessionRequest) (*IdentifySessionResponse, error) GetSessions(context.Context, *GetSessionsRequest) (*SessionListResponse, error) LogSessionEvent(context.Context, *SessionEventRequest) (*SessionEventResponse, error) GetSessionEvents(context.Context, *GetSessionEventsRequest) (*EventListResponse, error) // contains filtered or unexported methods }
UsersServer is the server API for Users service. All implementations must embed UnimplementedUsersServer for forward compatibility