v1

package
v0.1.3 Latest Latest
Warning

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

 Go to latest Published: Jun 15, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_wgtwo_subscription_v1_subscription_events_proto protoreflect.FileDescriptor
View Source 
var SubscriptionEventService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "wgtwo.subscription.v1.SubscriptionEventService",
	HandlerType: (*SubscriptionEventServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AckHandsetChangeEvent",
			Handler:    _SubscriptionEventService_AckHandsetChangeEvent_Handler,
		},
		{
			MethodName: "AckFirstAttachmentEvent",
			Handler:    _SubscriptionEventService_AckFirstAttachmentEvent_Handler,
		},
		{
			MethodName: "AckCountryChangeEvent",
			Handler:    _SubscriptionEventService_AckCountryChangeEvent_Handler,
		},
		{
			MethodName: "AckPeriodicCountryEvent",
			Handler:    _SubscriptionEventService_AckPeriodicCountryEvent_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamHandsetChangeEvents",
			Handler:       _SubscriptionEventService_StreamHandsetChangeEvents_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamFirstAttachmentEvents",
			Handler:       _SubscriptionEventService_StreamFirstAttachmentEvents_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamCountryChangeEvents",
			Handler:       _SubscriptionEventService_StreamCountryChangeEvents_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamPeriodicCountryEvents",
			Handler:       _SubscriptionEventService_StreamPeriodicCountryEvents_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "wgtwo/subscription/v1/subscription_events.proto",
}

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

Functions

func RegisterSubscriptionEventServiceServer 

func RegisterSubscriptionEventServiceServer(s grpc.ServiceRegistrar, srv SubscriptionEventServiceServer)

Types

type AckCountryChangeEventRequest 

type AckCountryChangeEventRequest struct {
	AckInfo *v1.AckInfo `protobuf:"bytes,1,opt,name=ack_info,json=ackInfo,proto3" json:"ack_info,omitempty"`
	// contains filtered or unexported fields
}

func (*AckCountryChangeEventRequest) Descriptor deprecated 

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

Deprecated: Use AckCountryChangeEventRequest.ProtoReflect.Descriptor instead.

func (*AckCountryChangeEventRequest) GetAckInfo 

func (x *AckCountryChangeEventRequest) GetAckInfo() *v1.AckInfo

func (*AckCountryChangeEventRequest) ProtoMessage 

func (*AckCountryChangeEventRequest) ProtoMessage()

func (*AckCountryChangeEventRequest) ProtoReflect 

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

func (*AckCountryChangeEventRequest) Reset 

func (x *AckCountryChangeEventRequest) Reset()

func (*AckCountryChangeEventRequest) String 

func (x *AckCountryChangeEventRequest) String() string

type AckCountryChangeEventResponse 

type AckCountryChangeEventResponse struct {
	AckStatus *v1.AckStatus `protobuf:"bytes,1,opt,name=ack_status,json=ackStatus,proto3" json:"ack_status,omitempty"`
	// contains filtered or unexported fields
}

func (*AckCountryChangeEventResponse) Descriptor deprecated 

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

Deprecated: Use AckCountryChangeEventResponse.ProtoReflect.Descriptor instead.

func (*AckCountryChangeEventResponse) GetAckStatus 

func (x *AckCountryChangeEventResponse) GetAckStatus() *v1.AckStatus

func (*AckCountryChangeEventResponse) ProtoMessage 

func (*AckCountryChangeEventResponse) ProtoMessage()

func (*AckCountryChangeEventResponse) ProtoReflect 

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

func (*AckCountryChangeEventResponse) Reset 

func (x *AckCountryChangeEventResponse) Reset()

func (*AckCountryChangeEventResponse) String 

func (x *AckCountryChangeEventResponse) String() string

type AckFirstAttachmentEventRequest 

type AckFirstAttachmentEventRequest struct {
	AckInfo *v1.AckInfo `protobuf:"bytes,1,opt,name=ack_info,json=ackInfo,proto3" json:"ack_info,omitempty"`
	// contains filtered or unexported fields
}

func (*AckFirstAttachmentEventRequest) Descriptor deprecated 

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

Deprecated: Use AckFirstAttachmentEventRequest.ProtoReflect.Descriptor instead.

func (*AckFirstAttachmentEventRequest) GetAckInfo 

func (x *AckFirstAttachmentEventRequest) GetAckInfo() *v1.AckInfo

func (*AckFirstAttachmentEventRequest) ProtoMessage 

func (*AckFirstAttachmentEventRequest) ProtoMessage()

func (*AckFirstAttachmentEventRequest) ProtoReflect 

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

func (*AckFirstAttachmentEventRequest) Reset 

func (x *AckFirstAttachmentEventRequest) Reset()

func (*AckFirstAttachmentEventRequest) String 

func (x *AckFirstAttachmentEventRequest) String() string

type AckFirstAttachmentEventResponse 

type AckFirstAttachmentEventResponse struct {
	AckStatus *v1.AckStatus `protobuf:"bytes,1,opt,name=ack_status,json=ackStatus,proto3" json:"ack_status,omitempty"`
	// contains filtered or unexported fields
}

func (*AckFirstAttachmentEventResponse) Descriptor deprecated 

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

Deprecated: Use AckFirstAttachmentEventResponse.ProtoReflect.Descriptor instead.

func (*AckFirstAttachmentEventResponse) GetAckStatus 

func (x *AckFirstAttachmentEventResponse) GetAckStatus() *v1.AckStatus

func (*AckFirstAttachmentEventResponse) ProtoMessage 

func (*AckFirstAttachmentEventResponse) ProtoMessage()

func (*AckFirstAttachmentEventResponse) ProtoReflect 

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

func (*AckFirstAttachmentEventResponse) Reset 

func (x *AckFirstAttachmentEventResponse) Reset()

func (*AckFirstAttachmentEventResponse) String 

func (x *AckFirstAttachmentEventResponse) String() string

type AckHandsetChangeEventRequest 

type AckHandsetChangeEventRequest struct {
	AckInfo *v1.AckInfo `protobuf:"bytes,1,opt,name=ack_info,json=ackInfo,proto3" json:"ack_info,omitempty"`
	// contains filtered or unexported fields
}

func (*AckHandsetChangeEventRequest) Descriptor deprecated 

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

Deprecated: Use AckHandsetChangeEventRequest.ProtoReflect.Descriptor instead.

func (*AckHandsetChangeEventRequest) GetAckInfo 

func (x *AckHandsetChangeEventRequest) GetAckInfo() *v1.AckInfo

func (*AckHandsetChangeEventRequest) ProtoMessage 

func (*AckHandsetChangeEventRequest) ProtoMessage()

func (*AckHandsetChangeEventRequest) ProtoReflect 

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

func (*AckHandsetChangeEventRequest) Reset 

func (x *AckHandsetChangeEventRequest) Reset()

func (*AckHandsetChangeEventRequest) String 

func (x *AckHandsetChangeEventRequest) String() string

type AckHandsetChangeEventResponse 

type AckHandsetChangeEventResponse struct {
	AckStatus *v1.AckStatus `protobuf:"bytes,1,opt,name=ack_status,json=ackStatus,proto3" json:"ack_status,omitempty"`
	// contains filtered or unexported fields
}

func (*AckHandsetChangeEventResponse) Descriptor deprecated 

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

Deprecated: Use AckHandsetChangeEventResponse.ProtoReflect.Descriptor instead.

func (*AckHandsetChangeEventResponse) GetAckStatus 

func (x *AckHandsetChangeEventResponse) GetAckStatus() *v1.AckStatus

func (*AckHandsetChangeEventResponse) ProtoMessage 

func (*AckHandsetChangeEventResponse) ProtoMessage()

func (*AckHandsetChangeEventResponse) ProtoReflect 

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

func (*AckHandsetChangeEventResponse) Reset 

func (x *AckHandsetChangeEventResponse) Reset()

func (*AckHandsetChangeEventResponse) String 

func (x *AckHandsetChangeEventResponse) String() string

type AckPeriodicCountryEventRequest 

type AckPeriodicCountryEventRequest struct {
	AckInfo *v1.AckInfo `protobuf:"bytes,1,opt,name=ack_info,json=ackInfo,proto3" json:"ack_info,omitempty"`
	// contains filtered or unexported fields
}

func (*AckPeriodicCountryEventRequest) Descriptor deprecated 

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

Deprecated: Use AckPeriodicCountryEventRequest.ProtoReflect.Descriptor instead.

func (*AckPeriodicCountryEventRequest) GetAckInfo 

func (x *AckPeriodicCountryEventRequest) GetAckInfo() *v1.AckInfo

func (*AckPeriodicCountryEventRequest) ProtoMessage 

func (*AckPeriodicCountryEventRequest) ProtoMessage()

func (*AckPeriodicCountryEventRequest) ProtoReflect 

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

func (*AckPeriodicCountryEventRequest) Reset 

func (x *AckPeriodicCountryEventRequest) Reset()

func (*AckPeriodicCountryEventRequest) String 

func (x *AckPeriodicCountryEventRequest) String() string

type AckPeriodicCountryEventResponse 

type AckPeriodicCountryEventResponse struct {
	AckStatus *v1.AckStatus `protobuf:"bytes,1,opt,name=ack_status,json=ackStatus,proto3" json:"ack_status,omitempty"`
	// contains filtered or unexported fields
}

func (*AckPeriodicCountryEventResponse) Descriptor deprecated 

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

Deprecated: Use AckPeriodicCountryEventResponse.ProtoReflect.Descriptor instead.

func (*AckPeriodicCountryEventResponse) GetAckStatus 

func (x *AckPeriodicCountryEventResponse) GetAckStatus() *v1.AckStatus

func (*AckPeriodicCountryEventResponse) ProtoMessage 

func (*AckPeriodicCountryEventResponse) ProtoMessage()

func (*AckPeriodicCountryEventResponse) ProtoReflect 

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

func (*AckPeriodicCountryEventResponse) Reset 

func (x *AckPeriodicCountryEventResponse) Reset()

func (*AckPeriodicCountryEventResponse) String 

func (x *AckPeriodicCountryEventResponse) String() string

type CountryChangeEvent 

type CountryChangeEvent struct {

	// The international number of the subscriber.
	Number *v11.E164 `protobuf:"bytes,3,opt,name=number,proto3" json:"number,omitempty"`
	// The country the subscriber moved from.
	Previous *v11.Country `protobuf:"bytes,1,opt,name=previous,proto3" json:"previous,omitempty"`
	// The country the subscriber moved to.
	Current *v11.Country `protobuf:"bytes,2,opt,name=current,proto3" json:"current,omitempty"`
	// contains filtered or unexported fields
}

func (*CountryChangeEvent) Descriptor deprecated 

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

Deprecated: Use CountryChangeEvent.ProtoReflect.Descriptor instead.

func (*CountryChangeEvent) GetCurrent 

func (x *CountryChangeEvent) GetCurrent() *v11.Country

func (*CountryChangeEvent) GetNumber 

func (x *CountryChangeEvent) GetNumber() *v11.E164

func (*CountryChangeEvent) GetPrevious 

func (x *CountryChangeEvent) GetPrevious() *v11.Country

func (*CountryChangeEvent) ProtoMessage 

func (*CountryChangeEvent) ProtoMessage()

func (*CountryChangeEvent) ProtoReflect 

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

func (*CountryChangeEvent) Reset 

func (x *CountryChangeEvent) Reset()

func (*CountryChangeEvent) String 

func (x *CountryChangeEvent) String() string

type FirstAttachmentEvent 

type FirstAttachmentEvent struct {

	// The international number of the subscriber.
	Number *v11.E164 `protobuf:"bytes,1,opt,name=number,proto3" json:"number,omitempty"`
	// The IMSI for the SIM card that has been observed. This is PII sensitive information, and
	// needs to be handled with care.
	Imsi *v11.Imsi `protobuf:"bytes,2,opt,name=imsi,proto3" json:"imsi,omitempty"`
	// contains filtered or unexported fields
}

func (*FirstAttachmentEvent) Descriptor deprecated 

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

Deprecated: Use FirstAttachmentEvent.ProtoReflect.Descriptor instead.

func (*FirstAttachmentEvent) GetImsi 

func (x *FirstAttachmentEvent) GetImsi() *v11.Imsi

func (*FirstAttachmentEvent) GetNumber 

func (x *FirstAttachmentEvent) GetNumber() *v11.E164

func (*FirstAttachmentEvent) ProtoMessage 

func (*FirstAttachmentEvent) ProtoMessage()

func (*FirstAttachmentEvent) ProtoReflect 

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

func (*FirstAttachmentEvent) Reset 

func (x *FirstAttachmentEvent) Reset()

func (*FirstAttachmentEvent) String 

func (x *FirstAttachmentEvent) String() string

type Handset 

type Handset struct {
	ImeiSv *v11.ImeiSv `protobuf:"bytes,1,opt,name=imei_sv,json=imeiSv,proto3" json:"imei_sv,omitempty"`
	// contains filtered or unexported fields
}

func (*Handset) Descriptor deprecated 

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

Deprecated: Use Handset.ProtoReflect.Descriptor instead.

func (*Handset) GetImeiSv 

func (x *Handset) GetImeiSv() *v11.ImeiSv

func (*Handset) ProtoMessage 

func (*Handset) ProtoMessage()

func (*Handset) ProtoReflect 

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

func (*Handset) Reset 

func (x *Handset) Reset()

func (*Handset) String 

func (x *Handset) String() string

type HandsetChangeEvent 

type HandsetChangeEvent struct {

	// The international number of the subscriber.
	Number *v11.E164 `protobuf:"bytes,4,opt,name=number,proto3" json:"number,omitempty"`
	// The IMSI for the SIM card that has been observed. This is PII sensitive information, and
	// needs to be handled with care.
	Imsi *v11.Imsi `protobuf:"bytes,3,opt,name=imsi,proto3" json:"imsi,omitempty"`
	// The previously stored handset info, may be empty.
	Previous *Handset `protobuf:"bytes,1,opt,name=previous,proto3" json:"previous,omitempty"`
	// The updated handset info
	Current *Handset `protobuf:"bytes,2,opt,name=current,proto3" json:"current,omitempty"`
	// contains filtered or unexported fields
}

func (*HandsetChangeEvent) Descriptor deprecated 

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

Deprecated: Use HandsetChangeEvent.ProtoReflect.Descriptor instead.

func (*HandsetChangeEvent) GetCurrent 

func (x *HandsetChangeEvent) GetCurrent() *Handset

func (*HandsetChangeEvent) GetImsi 

func (x *HandsetChangeEvent) GetImsi() *v11.Imsi

func (*HandsetChangeEvent) GetNumber 

func (x *HandsetChangeEvent) GetNumber() *v11.E164

func (*HandsetChangeEvent) GetPrevious 

func (x *HandsetChangeEvent) GetPrevious() *Handset

func (*HandsetChangeEvent) ProtoMessage 

func (*HandsetChangeEvent) ProtoMessage()

func (*HandsetChangeEvent) ProtoReflect 

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

func (*HandsetChangeEvent) Reset 

func (x *HandsetChangeEvent) Reset()

func (*HandsetChangeEvent) String 

func (x *HandsetChangeEvent) String() string

type PeriodicCountryEvent 

type PeriodicCountryEvent struct {

	// The international number of the subscriber.
	Number *v11.E164 `protobuf:"bytes,1,opt,name=number,proto3" json:"number,omitempty"`
	// The IMSI for the SIM card that has been observed. This is PII sensitive information, and
	// needs to be handled with care.
	Imsi *v11.Imsi `protobuf:"bytes,2,opt,name=imsi,proto3" json:"imsi,omitempty"`
	// The country for which the SIM card is observed.
	Country *v11.Country `protobuf:"bytes,3,opt,name=country,proto3" json:"country,omitempty"`
	// contains filtered or unexported fields
}

func (*PeriodicCountryEvent) Descriptor deprecated 

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

Deprecated: Use PeriodicCountryEvent.ProtoReflect.Descriptor instead.

func (*PeriodicCountryEvent) GetCountry 

func (x *PeriodicCountryEvent) GetCountry() *v11.Country

func (*PeriodicCountryEvent) GetImsi 

func (x *PeriodicCountryEvent) GetImsi() *v11.Imsi

func (*PeriodicCountryEvent) GetNumber 

func (x *PeriodicCountryEvent) GetNumber() *v11.E164

func (*PeriodicCountryEvent) ProtoMessage 

func (*PeriodicCountryEvent) ProtoMessage()

func (*PeriodicCountryEvent) ProtoReflect 

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

func (*PeriodicCountryEvent) Reset 

func (x *PeriodicCountryEvent) Reset()

func (*PeriodicCountryEvent) String 

func (x *PeriodicCountryEvent) String() string

type StreamCountryChangeEventsRequest 

type StreamCountryChangeEventsRequest struct {
	StreamConfiguration *v1.StreamConfiguration `protobuf:"bytes,1,opt,name=stream_configuration,json=streamConfiguration,proto3" json:"stream_configuration,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCountryChangeEventsRequest) Descriptor deprecated 

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

Deprecated: Use StreamCountryChangeEventsRequest.ProtoReflect.Descriptor instead.

func (*StreamCountryChangeEventsRequest) GetStreamConfiguration 

func (x *StreamCountryChangeEventsRequest) GetStreamConfiguration() *v1.StreamConfiguration

func (*StreamCountryChangeEventsRequest) ProtoMessage 

func (*StreamCountryChangeEventsRequest) ProtoMessage()

func (*StreamCountryChangeEventsRequest) ProtoReflect 

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

func (*StreamCountryChangeEventsRequest) Reset 

func (x *StreamCountryChangeEventsRequest) Reset()

func (*StreamCountryChangeEventsRequest) String 

func (x *StreamCountryChangeEventsRequest) String() string

type StreamCountryChangeEventsResponse 

type StreamCountryChangeEventsResponse struct {
	Metadata           *v1.Metadata        `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	CountryChangeEvent *CountryChangeEvent `protobuf:"bytes,2,opt,name=country_change_event,json=countryChangeEvent,proto3" json:"country_change_event,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCountryChangeEventsResponse) Descriptor deprecated 

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

Deprecated: Use StreamCountryChangeEventsResponse.ProtoReflect.Descriptor instead.

func (*StreamCountryChangeEventsResponse) GetCountryChangeEvent 

func (x *StreamCountryChangeEventsResponse) GetCountryChangeEvent() *CountryChangeEvent

func (*StreamCountryChangeEventsResponse) GetMetadata 

func (x *StreamCountryChangeEventsResponse) GetMetadata() *v1.Metadata

func (*StreamCountryChangeEventsResponse) ProtoMessage 

func (*StreamCountryChangeEventsResponse) ProtoMessage()

func (*StreamCountryChangeEventsResponse) ProtoReflect 

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

func (*StreamCountryChangeEventsResponse) Reset 

func (x *StreamCountryChangeEventsResponse) Reset()

func (*StreamCountryChangeEventsResponse) String 

func (x *StreamCountryChangeEventsResponse) String() string

type StreamFirstAttachmentEventsRequest 

type StreamFirstAttachmentEventsRequest struct {
	StreamConfiguration *v1.StreamConfiguration `protobuf:"bytes,1,opt,name=stream_configuration,json=streamConfiguration,proto3" json:"stream_configuration,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFirstAttachmentEventsRequest) Descriptor deprecated 

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

Deprecated: Use StreamFirstAttachmentEventsRequest.ProtoReflect.Descriptor instead.

func (*StreamFirstAttachmentEventsRequest) GetStreamConfiguration 

func (x *StreamFirstAttachmentEventsRequest) GetStreamConfiguration() *v1.StreamConfiguration

func (*StreamFirstAttachmentEventsRequest) ProtoMessage 

func (*StreamFirstAttachmentEventsRequest) ProtoMessage()

func (*StreamFirstAttachmentEventsRequest) ProtoReflect 

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

func (*StreamFirstAttachmentEventsRequest) Reset 

func (x *StreamFirstAttachmentEventsRequest) Reset()

func (*StreamFirstAttachmentEventsRequest) String 

func (x *StreamFirstAttachmentEventsRequest) String() string

type StreamFirstAttachmentEventsResponse 

type StreamFirstAttachmentEventsResponse struct {
	Metadata             *v1.Metadata          `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	FirstAttachmentEvent *FirstAttachmentEvent `protobuf:"bytes,2,opt,name=first_attachment_event,json=firstAttachmentEvent,proto3" json:"first_attachment_event,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFirstAttachmentEventsResponse) Descriptor deprecated 

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

Deprecated: Use StreamFirstAttachmentEventsResponse.ProtoReflect.Descriptor instead.

func (*StreamFirstAttachmentEventsResponse) GetFirstAttachmentEvent 

func (x *StreamFirstAttachmentEventsResponse) GetFirstAttachmentEvent() *FirstAttachmentEvent

func (*StreamFirstAttachmentEventsResponse) GetMetadata 

func (x *StreamFirstAttachmentEventsResponse) GetMetadata() *v1.Metadata

func (*StreamFirstAttachmentEventsResponse) ProtoMessage 

func (*StreamFirstAttachmentEventsResponse) ProtoMessage()

func (*StreamFirstAttachmentEventsResponse) ProtoReflect 

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

func (*StreamFirstAttachmentEventsResponse) Reset 

func (x *StreamFirstAttachmentEventsResponse) Reset()

func (*StreamFirstAttachmentEventsResponse) String 

func (x *StreamFirstAttachmentEventsResponse) String() string

type StreamHandsetChangeEventsRequest 

type StreamHandsetChangeEventsRequest struct {
	StreamConfiguration *v1.StreamConfiguration `protobuf:"bytes,1,opt,name=stream_configuration,json=streamConfiguration,proto3" json:"stream_configuration,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamHandsetChangeEventsRequest) Descriptor deprecated 

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

Deprecated: Use StreamHandsetChangeEventsRequest.ProtoReflect.Descriptor instead.

func (*StreamHandsetChangeEventsRequest) GetStreamConfiguration 

func (x *StreamHandsetChangeEventsRequest) GetStreamConfiguration() *v1.StreamConfiguration

func (*StreamHandsetChangeEventsRequest) ProtoMessage 

func (*StreamHandsetChangeEventsRequest) ProtoMessage()

func (*StreamHandsetChangeEventsRequest) ProtoReflect 

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

func (*StreamHandsetChangeEventsRequest) Reset 

func (x *StreamHandsetChangeEventsRequest) Reset()

func (*StreamHandsetChangeEventsRequest) String 

func (x *StreamHandsetChangeEventsRequest) String() string

type StreamHandsetChangeEventsResponse 

type StreamHandsetChangeEventsResponse struct {
	Metadata           *v1.Metadata        `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	HandsetChangeEvent *HandsetChangeEvent `protobuf:"bytes,2,opt,name=handset_change_event,json=handsetChangeEvent,proto3" json:"handset_change_event,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamHandsetChangeEventsResponse) Descriptor deprecated 

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

Deprecated: Use StreamHandsetChangeEventsResponse.ProtoReflect.Descriptor instead.

func (*StreamHandsetChangeEventsResponse) GetHandsetChangeEvent 

func (x *StreamHandsetChangeEventsResponse) GetHandsetChangeEvent() *HandsetChangeEvent

func (*StreamHandsetChangeEventsResponse) GetMetadata 

func (x *StreamHandsetChangeEventsResponse) GetMetadata() *v1.Metadata

func (*StreamHandsetChangeEventsResponse) ProtoMessage 

func (*StreamHandsetChangeEventsResponse) ProtoMessage()

func (*StreamHandsetChangeEventsResponse) ProtoReflect 

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

func (*StreamHandsetChangeEventsResponse) Reset 

func (x *StreamHandsetChangeEventsResponse) Reset()

func (*StreamHandsetChangeEventsResponse) String 

func (x *StreamHandsetChangeEventsResponse) String() string

type StreamPeriodicCountryEventsRequest 

type StreamPeriodicCountryEventsRequest struct {
	StreamConfiguration *v1.StreamConfiguration `protobuf:"bytes,1,opt,name=stream_configuration,json=streamConfiguration,proto3" json:"stream_configuration,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamPeriodicCountryEventsRequest) Descriptor deprecated 

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

Deprecated: Use StreamPeriodicCountryEventsRequest.ProtoReflect.Descriptor instead.

func (*StreamPeriodicCountryEventsRequest) GetStreamConfiguration 

func (x *StreamPeriodicCountryEventsRequest) GetStreamConfiguration() *v1.StreamConfiguration

func (*StreamPeriodicCountryEventsRequest) ProtoMessage 

func (*StreamPeriodicCountryEventsRequest) ProtoMessage()

func (*StreamPeriodicCountryEventsRequest) ProtoReflect 

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

func (*StreamPeriodicCountryEventsRequest) Reset 

func (x *StreamPeriodicCountryEventsRequest) Reset()

func (*StreamPeriodicCountryEventsRequest) String 

func (x *StreamPeriodicCountryEventsRequest) String() string

type StreamPeriodicCountryEventsResponse 

type StreamPeriodicCountryEventsResponse struct {
	Metadata             *v1.Metadata          `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	PeriodicCountryEvent *PeriodicCountryEvent `protobuf:"bytes,2,opt,name=periodic_country_event,json=periodicCountryEvent,proto3" json:"periodic_country_event,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamPeriodicCountryEventsResponse) Descriptor deprecated 

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

Deprecated: Use StreamPeriodicCountryEventsResponse.ProtoReflect.Descriptor instead.

func (*StreamPeriodicCountryEventsResponse) GetMetadata 

func (x *StreamPeriodicCountryEventsResponse) GetMetadata() *v1.Metadata

func (*StreamPeriodicCountryEventsResponse) GetPeriodicCountryEvent 

func (x *StreamPeriodicCountryEventsResponse) GetPeriodicCountryEvent() *PeriodicCountryEvent

func (*StreamPeriodicCountryEventsResponse) ProtoMessage 

func (*StreamPeriodicCountryEventsResponse) ProtoMessage()

func (*StreamPeriodicCountryEventsResponse) ProtoReflect 

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

func (*StreamPeriodicCountryEventsResponse) Reset 

func (x *StreamPeriodicCountryEventsResponse) Reset()

func (*StreamPeriodicCountryEventsResponse) String 

func (x *StreamPeriodicCountryEventsResponse) String() string

type SubscriptionEventServiceClient 

type SubscriptionEventServiceClient interface {
	StreamHandsetChangeEvents(ctx context.Context, in *StreamHandsetChangeEventsRequest, opts ...grpc.CallOption) (SubscriptionEventService_StreamHandsetChangeEventsClient, error)
	AckHandsetChangeEvent(ctx context.Context, in *AckHandsetChangeEventRequest, opts ...grpc.CallOption) (*AckHandsetChangeEventResponse, error)
	// First Attachment events are triggered whenever a SIM is first attached to the
	// network. It contains the IMSI to distinguish which SIM of the subscriber has
	// been attached.
	StreamFirstAttachmentEvents(ctx context.Context, in *StreamFirstAttachmentEventsRequest, opts ...grpc.CallOption) (SubscriptionEventService_StreamFirstAttachmentEventsClient, error)
	// Manually ack a first attachment event.
	AckFirstAttachmentEvent(ctx context.Context, in *AckFirstAttachmentEventRequest, opts ...grpc.CallOption) (*AckFirstAttachmentEventResponse, error)
	// Country change events are triggered whenever a SIM changes current country
	// location. It has both the current (new) country and the previous (old) country.
	//
	// This event is triggered when the previously seen country and the currently seen country
	// are different. Note that subscribers being close to borders, or during travels may generate
	// a lot of CountryChange events. See 'PeriodicCountry' events for an alternative.
	//
	// For subscribers with multiple SIM cards you will see an event for each SIM
	// (IMSI), as they can move between countries individually.
	StreamCountryChangeEvents(ctx context.Context, in *StreamCountryChangeEventsRequest, opts ...grpc.CallOption) (SubscriptionEventService_StreamCountryChangeEventsClient, error)
	// Manually ack a country change event.
	AckCountryChangeEvent(ctx context.Context, in *AckCountryChangeEventRequest, opts ...grpc.CallOption) (*AckCountryChangeEventResponse, error)
	// Periodic country events are triggered on a regular basis for each user for each
	// country where they are seen. It is triggered by knowingly seeing the subscriber
	// & handset in a specific country, and for each tenant will be triggered on a
	// regular interval. E.g. if 'Operator X' is configured for a 2 week interval,
	// there will be an event every 14 days (or 336 hours or 1209600 seconds) as long
	// as the subscriber is still seen in that country.
	//
	// As this event is not always triggered based on the subscriber moving between
	// countries, it does not contain the previously seen country. For getting the real-time
	// movement of the subscriber between countries, use 'CountryChange' event.
	//
	// This event is triggered:
	//
	// - When the subscriber first turns on the device and it connects to a network, it
	//   will be triggered for the country of the connected network at the same time as the
	//   corresponding 'FirstAttachment' event.
	// - When the subscriber enters a new country (not visited before). This is triggered
	//   at the same time as the corresponding 'CountryChange' event.
	// - When the subscriber is seen in a country, and the 'PeriodicCountry' event for that
	//   subscriber and country has not been triggered for the configured time delay.
	//
	// For subscribers with multiple SIM cards you will see an event for each SIM
	// (IMSI), as they can move between countries individually.
	StreamPeriodicCountryEvents(ctx context.Context, in *StreamPeriodicCountryEventsRequest, opts ...grpc.CallOption) (SubscriptionEventService_StreamPeriodicCountryEventsClient, error)
	// Manually ack a periodic country event.
	AckPeriodicCountryEvent(ctx context.Context, in *AckPeriodicCountryEventRequest, opts ...grpc.CallOption) (*AckPeriodicCountryEventResponse, error)
}

SubscriptionEventServiceClient is the client API for SubscriptionEventService 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 NewSubscriptionEventServiceClient 

func NewSubscriptionEventServiceClient(cc grpc.ClientConnInterface) SubscriptionEventServiceClient

type SubscriptionEventServiceServer 

type SubscriptionEventServiceServer interface {
	StreamHandsetChangeEvents(*StreamHandsetChangeEventsRequest, SubscriptionEventService_StreamHandsetChangeEventsServer) error
	AckHandsetChangeEvent(context.Context, *AckHandsetChangeEventRequest) (*AckHandsetChangeEventResponse, error)
	// First Attachment events are triggered whenever a SIM is first attached to the
	// network. It contains the IMSI to distinguish which SIM of the subscriber has
	// been attached.
	StreamFirstAttachmentEvents(*StreamFirstAttachmentEventsRequest, SubscriptionEventService_StreamFirstAttachmentEventsServer) error
	// Manually ack a first attachment event.
	AckFirstAttachmentEvent(context.Context, *AckFirstAttachmentEventRequest) (*AckFirstAttachmentEventResponse, error)
	// Country change events are triggered whenever a SIM changes current country
	// location. It has both the current (new) country and the previous (old) country.
	//
	// This event is triggered when the previously seen country and the currently seen country
	// are different. Note that subscribers being close to borders, or during travels may generate
	// a lot of CountryChange events. See 'PeriodicCountry' events for an alternative.
	//
	// For subscribers with multiple SIM cards you will see an event for each SIM
	// (IMSI), as they can move between countries individually.
	StreamCountryChangeEvents(*StreamCountryChangeEventsRequest, SubscriptionEventService_StreamCountryChangeEventsServer) error
	// Manually ack a country change event.
	AckCountryChangeEvent(context.Context, *AckCountryChangeEventRequest) (*AckCountryChangeEventResponse, error)
	// Periodic country events are triggered on a regular basis for each user for each
	// country where they are seen. It is triggered by knowingly seeing the subscriber
	// & handset in a specific country, and for each tenant will be triggered on a
	// regular interval. E.g. if 'Operator X' is configured for a 2 week interval,
	// there will be an event every 14 days (or 336 hours or 1209600 seconds) as long
	// as the subscriber is still seen in that country.
	//
	// As this event is not always triggered based on the subscriber moving between
	// countries, it does not contain the previously seen country. For getting the real-time
	// movement of the subscriber between countries, use 'CountryChange' event.
	//
	// This event is triggered:
	//
	// - When the subscriber first turns on the device and it connects to a network, it
	//   will be triggered for the country of the connected network at the same time as the
	//   corresponding 'FirstAttachment' event.
	// - When the subscriber enters a new country (not visited before). This is triggered
	//   at the same time as the corresponding 'CountryChange' event.
	// - When the subscriber is seen in a country, and the 'PeriodicCountry' event for that
	//   subscriber and country has not been triggered for the configured time delay.
	//
	// For subscribers with multiple SIM cards you will see an event for each SIM
	// (IMSI), as they can move between countries individually.
	StreamPeriodicCountryEvents(*StreamPeriodicCountryEventsRequest, SubscriptionEventService_StreamPeriodicCountryEventsServer) error
	// Manually ack a periodic country event.
	AckPeriodicCountryEvent(context.Context, *AckPeriodicCountryEventRequest) (*AckPeriodicCountryEventResponse, error)
}

SubscriptionEventServiceServer is the server API for SubscriptionEventService service. All implementations should embed UnimplementedSubscriptionEventServiceServer for forward compatibility

type SubscriptionEventService_StreamCountryChangeEventsClient 

type SubscriptionEventService_StreamCountryChangeEventsClient interface {
	Recv() (*StreamCountryChangeEventsResponse, error)
	grpc.ClientStream
}

type SubscriptionEventService_StreamCountryChangeEventsServer 

type SubscriptionEventService_StreamCountryChangeEventsServer interface {
	Send(*StreamCountryChangeEventsResponse) error
	grpc.ServerStream
}

type SubscriptionEventService_StreamFirstAttachmentEventsClient 

type SubscriptionEventService_StreamFirstAttachmentEventsClient interface {
	Recv() (*StreamFirstAttachmentEventsResponse, error)
	grpc.ClientStream
}

type SubscriptionEventService_StreamFirstAttachmentEventsServer 

type SubscriptionEventService_StreamFirstAttachmentEventsServer interface {
	Send(*StreamFirstAttachmentEventsResponse) error
	grpc.ServerStream
}

type SubscriptionEventService_StreamHandsetChangeEventsClient 

type SubscriptionEventService_StreamHandsetChangeEventsClient interface {
	Recv() (*StreamHandsetChangeEventsResponse, error)
	grpc.ClientStream
}

type SubscriptionEventService_StreamHandsetChangeEventsServer 

type SubscriptionEventService_StreamHandsetChangeEventsServer interface {
	Send(*StreamHandsetChangeEventsResponse) error
	grpc.ServerStream
}

type SubscriptionEventService_StreamPeriodicCountryEventsClient 

type SubscriptionEventService_StreamPeriodicCountryEventsClient interface {
	Recv() (*StreamPeriodicCountryEventsResponse, error)
	grpc.ClientStream
}

type SubscriptionEventService_StreamPeriodicCountryEventsServer 

type SubscriptionEventService_StreamPeriodicCountryEventsServer interface {
	Send(*StreamPeriodicCountryEventsResponse) error
	grpc.ServerStream
}

type UnimplementedSubscriptionEventServiceServer 

type UnimplementedSubscriptionEventServiceServer struct {
}

UnimplementedSubscriptionEventServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedSubscriptionEventServiceServer) AckCountryChangeEvent 

func (UnimplementedSubscriptionEventServiceServer) AckCountryChangeEvent(context.Context, *AckCountryChangeEventRequest) (*AckCountryChangeEventResponse, error)

func (UnimplementedSubscriptionEventServiceServer) AckFirstAttachmentEvent 

func (UnimplementedSubscriptionEventServiceServer) AckFirstAttachmentEvent(context.Context, *AckFirstAttachmentEventRequest) (*AckFirstAttachmentEventResponse, error)

func (UnimplementedSubscriptionEventServiceServer) AckHandsetChangeEvent 

func (UnimplementedSubscriptionEventServiceServer) AckHandsetChangeEvent(context.Context, *AckHandsetChangeEventRequest) (*AckHandsetChangeEventResponse, error)

func (UnimplementedSubscriptionEventServiceServer) AckPeriodicCountryEvent 

func (UnimplementedSubscriptionEventServiceServer) AckPeriodicCountryEvent(context.Context, *AckPeriodicCountryEventRequest) (*AckPeriodicCountryEventResponse, error)

func (UnimplementedSubscriptionEventServiceServer) StreamCountryChangeEvents 

func (UnimplementedSubscriptionEventServiceServer) StreamCountryChangeEvents(*StreamCountryChangeEventsRequest, SubscriptionEventService_StreamCountryChangeEventsServer) error

func (UnimplementedSubscriptionEventServiceServer) StreamFirstAttachmentEvents 

func (UnimplementedSubscriptionEventServiceServer) StreamFirstAttachmentEvents(*StreamFirstAttachmentEventsRequest, SubscriptionEventService_StreamFirstAttachmentEventsServer) error

func (UnimplementedSubscriptionEventServiceServer) StreamHandsetChangeEvents 

func (UnimplementedSubscriptionEventServiceServer) StreamHandsetChangeEvents(*StreamHandsetChangeEventsRequest, SubscriptionEventService_StreamHandsetChangeEventsServer) error

func (UnimplementedSubscriptionEventServiceServer) StreamPeriodicCountryEvents 

func (UnimplementedSubscriptionEventServiceServer) StreamPeriodicCountryEvents(*StreamPeriodicCountryEventsRequest, SubscriptionEventService_StreamPeriodicCountryEventsServer) error

type UnsafeSubscriptionEventServiceServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.