v1

package
v1.16.1 Latest Latest
Warning

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

 Go to latest Published: Feb 3, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SubscriptionEventService_StreamHandsetChangeEvents_FullMethodName   = "/wgtwo.subscription.v1.SubscriptionEventService/StreamHandsetChangeEvents"
	SubscriptionEventService_AckHandsetChangeEvent_FullMethodName       = "/wgtwo.subscription.v1.SubscriptionEventService/AckHandsetChangeEvent"
	SubscriptionEventService_StreamFirstAttachmentEvents_FullMethodName = "/wgtwo.subscription.v1.SubscriptionEventService/StreamFirstAttachmentEvents"
	SubscriptionEventService_AckFirstAttachmentEvent_FullMethodName     = "/wgtwo.subscription.v1.SubscriptionEventService/AckFirstAttachmentEvent"
	SubscriptionEventService_StreamCountryChangeEvents_FullMethodName   = "/wgtwo.subscription.v1.SubscriptionEventService/StreamCountryChangeEvents"
	SubscriptionEventService_AckCountryChangeEvent_FullMethodName       = "/wgtwo.subscription.v1.SubscriptionEventService/AckCountryChangeEvent"
	SubscriptionEventService_StreamPeriodicCountryEvents_FullMethodName = "/wgtwo.subscription.v1.SubscriptionEventService/StreamPeriodicCountryEvents"
	SubscriptionEventService_AckPeriodicCountryEvent_FullMethodName     = "/wgtwo.subscription.v1.SubscriptionEventService/AckPeriodicCountryEvent"
)

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 {

	// Used to identify the event to acknowledge.
	AckInfo *v1.AckInfo `protobuf:"bytes,1,opt,name=ack_info,json=ackInfo,proto3" json:"ack_info,omitempty"`
	// contains filtered or unexported fields
}

Request message for acknowledging a country change event.

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 {

	// The status response (success/failure) of the acknowledgement.
	AckStatus *v1.AckStatus `protobuf:"bytes,1,opt,name=ack_status,json=ackStatus,proto3" json:"ack_status,omitempty"`
	// contains filtered or unexported fields
}

Response message for acknowledging a country change event.

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 {

	// Used to identify the event to acknowledge.
	AckInfo *v1.AckInfo `protobuf:"bytes,1,opt,name=ack_info,json=ackInfo,proto3" json:"ack_info,omitempty"`
	// contains filtered or unexported fields
}

Request message for acknowledging a first attachment event.

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 {

	// The status response (success/failure) of the acknowledgement.
	AckStatus *v1.AckStatus `protobuf:"bytes,1,opt,name=ack_status,json=ackStatus,proto3" json:"ack_status,omitempty"`
	// contains filtered or unexported fields
}

Response message for acknowledging a first attachment event.

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 {

	// Used to identify the event to acknowledge.
	AckInfo *v1.AckInfo `protobuf:"bytes,1,opt,name=ack_info,json=ackInfo,proto3" json:"ack_info,omitempty"`
	// contains filtered or unexported fields
}

Request message for acknowledging a handset change event.

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 {

	// The status response (success/failure) of the acknowledgement.
	AckStatus *v1.AckStatus `protobuf:"bytes,1,opt,name=ack_status,json=ackStatus,proto3" json:"ack_status,omitempty"`
	// contains filtered or unexported fields
}

Response message for acknowledging a handset change event.

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 {

	// Used to identify the event to acknowledge.
	AckInfo *v1.AckInfo `protobuf:"bytes,1,opt,name=ack_info,json=ackInfo,proto3" json:"ack_info,omitempty"`
	// contains filtered or unexported fields
}

Request message for acknowledging a periodic country event.

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 {

	// The status response (success/failure) of the acknowledgement.
	AckStatus *v1.AckStatus `protobuf:"bytes,1,opt,name=ack_status,json=ackStatus,proto3" json:"ack_status,omitempty"`
	// contains filtered or unexported fields
}

Response message for acknowledging a periodic country event.

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
}

The country change event message

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
}

The first attachment event message

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 {

	// The International Mobile station Equipment Identity and Software Version number.
	ImeiSv *v11.ImeiSv `protobuf:"bytes,1,opt,name=imei_sv,json=imeiSv,proto3" json:"imei_sv,omitempty"`
	// contains filtered or unexported fields
}

Handset message

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
}

The handset change event message

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
}

The periodic country event message

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 {

	// Configuration for the stream.
	StreamConfiguration *v1.StreamConfiguration `protobuf:"bytes,1,opt,name=stream_configuration,json=streamConfiguration,proto3" json:"stream_configuration,omitempty"`
	// contains filtered or unexported fields
}

Request message for streaming of country change events.

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 for the stream.
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// The country change event.
	CountryChangeEvent *CountryChangeEvent `protobuf:"bytes,2,opt,name=country_change_event,json=countryChangeEvent,proto3" json:"country_change_event,omitempty"`
	// contains filtered or unexported fields
}

Response message for streaming of country change events.

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 {

	// Configuration for the stream.
	StreamConfiguration *v1.StreamConfiguration `protobuf:"bytes,1,opt,name=stream_configuration,json=streamConfiguration,proto3" json:"stream_configuration,omitempty"`
	// contains filtered or unexported fields
}

Request message for streaming of first attachment events.

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 for the stream.
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// The first attachment event.
	FirstAttachmentEvent *FirstAttachmentEvent `protobuf:"bytes,2,opt,name=first_attachment_event,json=firstAttachmentEvent,proto3" json:"first_attachment_event,omitempty"`
	// contains filtered or unexported fields
}

Response message for streaming of first attachment events.

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 {

	// Configuration for the stream.
	StreamConfiguration *v1.StreamConfiguration `protobuf:"bytes,1,opt,name=stream_configuration,json=streamConfiguration,proto3" json:"stream_configuration,omitempty"`
	// contains filtered or unexported fields
}

Request message for streaming of handset change events.

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 for the stream.
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// The handset change event.
	HandsetChangeEvent *HandsetChangeEvent `protobuf:"bytes,2,opt,name=handset_change_event,json=handsetChangeEvent,proto3" json:"handset_change_event,omitempty"`
	// contains filtered or unexported fields
}

Response message for streaming of handset change events.

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 {

	// Configuration for the stream.
	StreamConfiguration *v1.StreamConfiguration `protobuf:"bytes,1,opt,name=stream_configuration,json=streamConfiguration,proto3" json:"stream_configuration,omitempty"`
	// contains filtered or unexported fields
}

Request message for streaming of periodic country events.

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 for the stream.
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// The periodic country event.
	PeriodicCountryEvent *PeriodicCountryEvent `protobuf:"bytes,2,opt,name=periodic_country_event,json=periodicCountryEvent,proto3" json:"periodic_country_event,omitempty"`
	// contains filtered or unexported fields
}

Response message for streaming of periodic country events.

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 {
	// Handset Change events are triggered whenever a SIM card is moved from one handset to another.
	StreamHandsetChangeEvents(ctx context.Context, in *StreamHandsetChangeEventsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[StreamHandsetChangeEventsResponse], error)
	// Manually ack a handset change event.
	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) (grpc.ServerStreamingClient[StreamFirstAttachmentEventsResponse], 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.
	// <p/>
	// 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.
	// <p/>
	// 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) (grpc.ServerStreamingClient[StreamCountryChangeEventsResponse], 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.
	// <p/>
	// 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.
	// <p/>
	// This event is triggered: <br>
	// <br>
	//   - 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. <br>
	//   - When the subscriber enters a new country (not visited before). This is triggered
	//     at the same time as the corresponding 'CountryChange' event. <br>
	//   - 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. <br>
	//
	// <p/>
	// 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) (grpc.ServerStreamingClient[StreamPeriodicCountryEventsResponse], 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.

Service to handle events related to a subscription, and where the subscriber is located. Each event has two operating methods: Stream\*Event and Ack\*Event. See events.proto for details on subscribing.

| Event | Description | | ---------------- | ------------------------------------------------------- | | First Attachment | When the subscriber first attaches to the network. | | Periodic Country | While the subscriber is in a country. | | Country Change | When the subscriber changes current country location. | | Handset Change | When the SIM card is moved from one handset to another. |

func NewSubscriptionEventServiceClient 

func NewSubscriptionEventServiceClient(cc grpc.ClientConnInterface) SubscriptionEventServiceClient

type SubscriptionEventServiceServer 

type SubscriptionEventServiceServer interface {
	// Handset Change events are triggered whenever a SIM card is moved from one handset to another.
	StreamHandsetChangeEvents(*StreamHandsetChangeEventsRequest, grpc.ServerStreamingServer[StreamHandsetChangeEventsResponse]) error
	// Manually ack a handset change event.
	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, grpc.ServerStreamingServer[StreamFirstAttachmentEventsResponse]) 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.
	// <p/>
	// 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.
	// <p/>
	// For subscribers with multiple SIM cards you will see an event for each SIM
	// (IMSI), as they can move between countries individually.
	StreamCountryChangeEvents(*StreamCountryChangeEventsRequest, grpc.ServerStreamingServer[StreamCountryChangeEventsResponse]) 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.
	// <p/>
	// 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.
	// <p/>
	// This event is triggered: <br>
	// <br>
	//   - 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. <br>
	//   - When the subscriber enters a new country (not visited before). This is triggered
	//     at the same time as the corresponding 'CountryChange' event. <br>
	//   - 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. <br>
	//
	// <p/>
	// For subscribers with multiple SIM cards you will see an event for each SIM
	// (IMSI), as they can move between countries individually.
	StreamPeriodicCountryEvents(*StreamPeriodicCountryEventsRequest, grpc.ServerStreamingServer[StreamPeriodicCountryEventsResponse]) 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.

Service to handle events related to a subscription, and where the subscriber is located. Each event has two operating methods: Stream\*Event and Ack\*Event. See events.proto for details on subscribing.

| Event | Description | | ---------------- | ------------------------------------------------------- | | First Attachment | When the subscriber first attaches to the network. | | Periodic Country | While the subscriber is in a country. | | Country Change | When the subscriber changes current country location. | | Handset Change | When the SIM card is moved from one handset to another. |

type SubscriptionEventService_StreamCountryChangeEventsClient 

type SubscriptionEventService_StreamCountryChangeEventsClient = grpc.ServerStreamingClient[StreamCountryChangeEventsResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SubscriptionEventService_StreamCountryChangeEventsServer 

type SubscriptionEventService_StreamCountryChangeEventsServer = grpc.ServerStreamingServer[StreamCountryChangeEventsResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SubscriptionEventService_StreamFirstAttachmentEventsClient 

type SubscriptionEventService_StreamFirstAttachmentEventsClient = grpc.ServerStreamingClient[StreamFirstAttachmentEventsResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SubscriptionEventService_StreamFirstAttachmentEventsServer 

type SubscriptionEventService_StreamFirstAttachmentEventsServer = grpc.ServerStreamingServer[StreamFirstAttachmentEventsResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SubscriptionEventService_StreamHandsetChangeEventsClient 

type SubscriptionEventService_StreamHandsetChangeEventsClient = grpc.ServerStreamingClient[StreamHandsetChangeEventsResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SubscriptionEventService_StreamHandsetChangeEventsServer 

type SubscriptionEventService_StreamHandsetChangeEventsServer = grpc.ServerStreamingServer[StreamHandsetChangeEventsResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SubscriptionEventService_StreamPeriodicCountryEventsClient 

type SubscriptionEventService_StreamPeriodicCountryEventsClient = grpc.ServerStreamingClient[StreamPeriodicCountryEventsResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SubscriptionEventService_StreamPeriodicCountryEventsServer 

type SubscriptionEventService_StreamPeriodicCountryEventsServer = grpc.ServerStreamingServer[StreamPeriodicCountryEventsResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UnimplementedSubscriptionEventServiceServer 

type UnimplementedSubscriptionEventServiceServer struct{}

UnimplementedSubscriptionEventServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

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, grpc.ServerStreamingServer[StreamCountryChangeEventsResponse]) error

func (UnimplementedSubscriptionEventServiceServer) StreamFirstAttachmentEvents 

func (UnimplementedSubscriptionEventServiceServer) StreamFirstAttachmentEvents(*StreamFirstAttachmentEventsRequest, grpc.ServerStreamingServer[StreamFirstAttachmentEventsResponse]) error

func (UnimplementedSubscriptionEventServiceServer) StreamHandsetChangeEvents 

func (UnimplementedSubscriptionEventServiceServer) StreamHandsetChangeEvents(*StreamHandsetChangeEventsRequest, grpc.ServerStreamingServer[StreamHandsetChangeEventsResponse]) error

func (UnimplementedSubscriptionEventServiceServer) StreamPeriodicCountryEvents 

func (UnimplementedSubscriptionEventServiceServer) StreamPeriodicCountryEvents(*StreamPeriodicCountryEventsRequest, grpc.ServerStreamingServer[StreamPeriodicCountryEventsResponse]) 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.