Documentation
¶
Index ¶
- Variables
- func RegisterModuleServer(s *grpc.Server, srv ModuleServer)
- type C2SStreamEventInfo
- func (*C2SStreamEventInfo) Descriptor() ([]byte, []int)deprecated
- func (x *C2SStreamEventInfo) GetId() string
- func (x *C2SStreamEventInfo) GetJid() string
- func (x *C2SStreamEventInfo) GetStanza() *stravaganza.PBElement
- func (x *C2SStreamEventInfo) GetTargets() []string
- func (*C2SStreamEventInfo) ProtoMessage()
- func (x *C2SStreamEventInfo) ProtoReflect() protoreflect.Message
- func (x *C2SStreamEventInfo) Reset()
- func (x *C2SStreamEventInfo) String() string
- type ExternalComponentEventInfo
- func (*ExternalComponentEventInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ExternalComponentEventInfo) GetHost() string
- func (x *ExternalComponentEventInfo) GetId() string
- func (x *ExternalComponentEventInfo) GetStanza() *stravaganza.PBElement
- func (*ExternalComponentEventInfo) ProtoMessage()
- func (x *ExternalComponentEventInfo) ProtoReflect() protoreflect.Message
- func (x *ExternalComponentEventInfo) Reset()
- func (x *ExternalComponentEventInfo) String() string
- type GetAccountFeaturesRequest
- type GetAccountFeaturesResponse
- func (*GetAccountFeaturesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetAccountFeaturesResponse) GetFeatures() []string
- func (*GetAccountFeaturesResponse) ProtoMessage()
- func (x *GetAccountFeaturesResponse) ProtoReflect() protoreflect.Message
- func (x *GetAccountFeaturesResponse) Reset()
- func (x *GetAccountFeaturesResponse) String() string
- type GetServerFeaturesRequest
- type GetServerFeaturesResponse
- func (*GetServerFeaturesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetServerFeaturesResponse) GetFeatures() []string
- func (*GetServerFeaturesResponse) ProtoMessage()
- func (x *GetServerFeaturesResponse) ProtoReflect() protoreflect.Message
- func (x *GetServerFeaturesResponse) Reset()
- func (x *GetServerFeaturesResponse) String() string
- type GetStanzasRequest
- type GetStreamFeatureRequest
- func (*GetStreamFeatureRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetStreamFeatureRequest) GetDomain() string
- func (*GetStreamFeatureRequest) ProtoMessage()
- func (x *GetStreamFeatureRequest) ProtoReflect() protoreflect.Message
- func (x *GetStreamFeatureRequest) Reset()
- func (x *GetStreamFeatureRequest) String() string
- type GetStreamFeatureResponse
- func (*GetStreamFeatureResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetStreamFeatureResponse) GetFeature() *stravaganza.PBElement
- func (*GetStreamFeatureResponse) ProtoMessage()
- func (x *GetStreamFeatureResponse) ProtoReflect() protoreflect.Message
- func (x *GetStreamFeatureResponse) Reset()
- func (x *GetStreamFeatureResponse) String() string
- type InterceptStanzaRequest
- func (*InterceptStanzaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InterceptStanzaRequest) GetId() int64
- func (x *InterceptStanzaRequest) GetStanza() *stravaganza.PBElement
- func (*InterceptStanzaRequest) ProtoMessage()
- func (x *InterceptStanzaRequest) ProtoReflect() protoreflect.Message
- func (x *InterceptStanzaRequest) Reset()
- func (x *InterceptStanzaRequest) String() string
- type InterceptStanzaResponse
- func (*InterceptStanzaResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InterceptStanzaResponse) GetStanza() *stravaganza.PBElement
- func (*InterceptStanzaResponse) ProtoMessage()
- func (x *InterceptStanzaResponse) ProtoReflect() protoreflect.Message
- func (x *InterceptStanzaResponse) Reset()
- func (x *InterceptStanzaResponse) String() string
- type ModuleClient
- type ModuleServer
- type Module_GetStanzasClient
- type Module_GetStanzasServer
- type OfflineEventInfo
- func (*OfflineEventInfo) Descriptor() ([]byte, []int)deprecated
- func (x *OfflineEventInfo) GetMessage() *stravaganza.PBElement
- func (x *OfflineEventInfo) GetUsername() string
- func (*OfflineEventInfo) ProtoMessage()
- func (x *OfflineEventInfo) ProtoReflect() protoreflect.Message
- func (x *OfflineEventInfo) Reset()
- func (x *OfflineEventInfo) String() string
- type PrivateEventInfo
- func (*PrivateEventInfo) Descriptor() ([]byte, []int)deprecated
- func (x *PrivateEventInfo) GetPrivate() *stravaganza.PBElement
- func (x *PrivateEventInfo) GetUsername() string
- func (*PrivateEventInfo) ProtoMessage()
- func (x *PrivateEventInfo) ProtoReflect() protoreflect.Message
- func (x *PrivateEventInfo) Reset()
- func (x *PrivateEventInfo) String() string
- type ProcessEventRequest
- func (*ProcessEventRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessEventRequest) GetC2SStreamEvInfo() *C2SStreamEventInfo
- func (x *ProcessEventRequest) GetEventName() string
- func (x *ProcessEventRequest) GetExtComponentEvInfo() *ExternalComponentEventInfo
- func (x *ProcessEventRequest) GetInstanceId() string
- func (x *ProcessEventRequest) GetOfflineEvInfo() *OfflineEventInfo
- func (m *ProcessEventRequest) GetPayload() isProcessEventRequest_Payload
- func (x *ProcessEventRequest) GetPrivateEvInfo() *PrivateEventInfo
- func (x *ProcessEventRequest) GetRosterEvInfo() *RosterEventInfo
- func (x *ProcessEventRequest) GetS2SStreamEvInfo() *S2SStreamEventInfo
- func (x *ProcessEventRequest) GetUserEvInfo() *UserEventInfo
- func (x *ProcessEventRequest) GetVcardEvInfo() *VCardEventInfo
- func (*ProcessEventRequest) ProtoMessage()
- func (x *ProcessEventRequest) ProtoReflect() protoreflect.Message
- func (x *ProcessEventRequest) Reset()
- func (x *ProcessEventRequest) String() string
- type ProcessEventRequest_C2SStreamEvInfo
- type ProcessEventRequest_ExtComponentEvInfo
- type ProcessEventRequest_OfflineEvInfo
- type ProcessEventRequest_PrivateEvInfo
- type ProcessEventRequest_RosterEvInfo
- type ProcessEventRequest_S2SStreamEvInfo
- type ProcessEventRequest_UserEvInfo
- type ProcessEventRequest_VcardEvInfo
- type ProcessEventResponse
- type ProcessIQRequest
- func (*ProcessIQRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessIQRequest) GetIq() *stravaganza.PBElement
- func (*ProcessIQRequest) ProtoMessage()
- func (x *ProcessIQRequest) ProtoReflect() protoreflect.Message
- func (x *ProcessIQRequest) Reset()
- func (x *ProcessIQRequest) String() string
- type ProcessIQResponse
- type RosterEventInfo
- func (*RosterEventInfo) Descriptor() ([]byte, []int)deprecated
- func (x *RosterEventInfo) GetJid() string
- func (x *RosterEventInfo) GetSubscription() string
- func (x *RosterEventInfo) GetUsername() string
- func (*RosterEventInfo) ProtoMessage()
- func (x *RosterEventInfo) ProtoReflect() protoreflect.Message
- func (x *RosterEventInfo) Reset()
- func (x *RosterEventInfo) String() string
- type S2SStreamEventInfo
- func (*S2SStreamEventInfo) Descriptor() ([]byte, []int)deprecated
- func (x *S2SStreamEventInfo) GetId() string
- func (x *S2SStreamEventInfo) GetSender() string
- func (x *S2SStreamEventInfo) GetStanza() *stravaganza.PBElement
- func (x *S2SStreamEventInfo) GetTarget() string
- func (*S2SStreamEventInfo) ProtoMessage()
- func (x *S2SStreamEventInfo) ProtoReflect() protoreflect.Message
- func (x *S2SStreamEventInfo) Reset()
- func (x *S2SStreamEventInfo) String() string
- type UnimplementedModuleServer
- func (*UnimplementedModuleServer) GetAccountFeatures(context.Context, *GetAccountFeaturesRequest) (*GetAccountFeaturesResponse, error)
- func (*UnimplementedModuleServer) GetServerFeatures(context.Context, *GetServerFeaturesRequest) (*GetServerFeaturesResponse, error)
- func (*UnimplementedModuleServer) GetStanzas(*GetStanzasRequest, Module_GetStanzasServer) error
- func (*UnimplementedModuleServer) GetStreamFeature(context.Context, *GetStreamFeatureRequest) (*GetStreamFeatureResponse, error)
- func (*UnimplementedModuleServer) InterceptStanza(context.Context, *InterceptStanzaRequest) (*InterceptStanzaResponse, error)
- func (*UnimplementedModuleServer) ProcessEvent(context.Context, *ProcessEventRequest) (*ProcessEventResponse, error)
- func (*UnimplementedModuleServer) ProcessIQ(context.Context, *ProcessIQRequest) (*ProcessIQResponse, error)
- type UserEventInfo
- type VCardEventInfo
- func (*VCardEventInfo) Descriptor() ([]byte, []int)deprecated
- func (x *VCardEventInfo) GetUsername() string
- func (x *VCardEventInfo) GetVcard() *stravaganza.PBElement
- func (*VCardEventInfo) ProtoMessage()
- func (x *VCardEventInfo) ProtoReflect() protoreflect.Message
- func (x *VCardEventInfo) Reset()
- func (x *VCardEventInfo) String() string
Constants ¶
This section is empty.
Variables ¶
var File_module_proto protoreflect.FileDescriptor
Functions ¶
func RegisterModuleServer ¶
func RegisterModuleServer(s *grpc.Server, srv ModuleServer)
Types ¶
type C2SStreamEventInfo ¶
type C2SStreamEventInfo struct { // id is the event stream identifier. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // jid represents the event associated JID. Jid string `protobuf:"bytes,2,opt,name=jid,proto3" json:"jid,omitempty"` // targets contains all JIDs to which the event stanza was routed. Targets []string `protobuf:"bytes,3,rep,name=targets,proto3" json:"targets,omitempty"` // stanza contains the XMPP stanza associated to the event. Stanza *stravaganza.PBElement `protobuf:"bytes,4,opt,name=stanza,proto3" json:"stanza,omitempty"` // contains filtered or unexported fields }
C2SStreamEventInfo contains all info associated to a C2S stream event.
func (*C2SStreamEventInfo) Descriptor
deprecated
func (*C2SStreamEventInfo) Descriptor() ([]byte, []int)
Deprecated: Use C2SStreamEventInfo.ProtoReflect.Descriptor instead.
func (*C2SStreamEventInfo) GetId ¶
func (x *C2SStreamEventInfo) GetId() string
func (*C2SStreamEventInfo) GetJid ¶
func (x *C2SStreamEventInfo) GetJid() string
func (*C2SStreamEventInfo) GetStanza ¶
func (x *C2SStreamEventInfo) GetStanza() *stravaganza.PBElement
func (*C2SStreamEventInfo) GetTargets ¶ added in v0.52.2
func (x *C2SStreamEventInfo) GetTargets() []string
func (*C2SStreamEventInfo) ProtoMessage ¶
func (*C2SStreamEventInfo) ProtoMessage()
func (*C2SStreamEventInfo) ProtoReflect ¶
func (x *C2SStreamEventInfo) ProtoReflect() protoreflect.Message
func (*C2SStreamEventInfo) Reset ¶
func (x *C2SStreamEventInfo) Reset()
func (*C2SStreamEventInfo) String ¶
func (x *C2SStreamEventInfo) String() string
type ExternalComponentEventInfo ¶
type ExternalComponentEventInfo struct { // id is the event stream identifier. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // host is the external component host domain. Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"` // stanza contains the XMPP stanza associated to the event. Stanza *stravaganza.PBElement `protobuf:"bytes,3,opt,name=stanza,proto3" json:"stanza,omitempty"` // contains filtered or unexported fields }
ExternalComponentEventInfo contains all info associated to an external component stream event.
func (*ExternalComponentEventInfo) Descriptor
deprecated
func (*ExternalComponentEventInfo) Descriptor() ([]byte, []int)
Deprecated: Use ExternalComponentEventInfo.ProtoReflect.Descriptor instead.
func (*ExternalComponentEventInfo) GetHost ¶
func (x *ExternalComponentEventInfo) GetHost() string
func (*ExternalComponentEventInfo) GetId ¶
func (x *ExternalComponentEventInfo) GetId() string
func (*ExternalComponentEventInfo) GetStanza ¶
func (x *ExternalComponentEventInfo) GetStanza() *stravaganza.PBElement
func (*ExternalComponentEventInfo) ProtoMessage ¶
func (*ExternalComponentEventInfo) ProtoMessage()
func (*ExternalComponentEventInfo) ProtoReflect ¶
func (x *ExternalComponentEventInfo) ProtoReflect() protoreflect.Message
func (*ExternalComponentEventInfo) Reset ¶
func (x *ExternalComponentEventInfo) Reset()
func (*ExternalComponentEventInfo) String ¶
func (x *ExternalComponentEventInfo) String() string
type GetAccountFeaturesRequest ¶
type GetAccountFeaturesRequest struct {
// contains filtered or unexported fields
}
GetAccountFeaturesRequest is the parameter message for GetAccountFeatures rpc.
func (*GetAccountFeaturesRequest) Descriptor
deprecated
func (*GetAccountFeaturesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetAccountFeaturesRequest.ProtoReflect.Descriptor instead.
func (*GetAccountFeaturesRequest) ProtoMessage ¶
func (*GetAccountFeaturesRequest) ProtoMessage()
func (*GetAccountFeaturesRequest) ProtoReflect ¶
func (x *GetAccountFeaturesRequest) ProtoReflect() protoreflect.Message
func (*GetAccountFeaturesRequest) Reset ¶
func (x *GetAccountFeaturesRequest) Reset()
func (*GetAccountFeaturesRequest) String ¶
func (x *GetAccountFeaturesRequest) String() string
type GetAccountFeaturesResponse ¶
type GetAccountFeaturesResponse struct { // features contains features that should be announced by account entity. Features []string `protobuf:"bytes,1,rep,name=features,proto3" json:"features,omitempty"` // contains filtered or unexported fields }
GetAccountFeaturesResponse is the response returned by GetAccountFeatures rpc.
func (*GetAccountFeaturesResponse) Descriptor
deprecated
func (*GetAccountFeaturesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetAccountFeaturesResponse.ProtoReflect.Descriptor instead.
func (*GetAccountFeaturesResponse) GetFeatures ¶
func (x *GetAccountFeaturesResponse) GetFeatures() []string
func (*GetAccountFeaturesResponse) ProtoMessage ¶
func (*GetAccountFeaturesResponse) ProtoMessage()
func (*GetAccountFeaturesResponse) ProtoReflect ¶
func (x *GetAccountFeaturesResponse) ProtoReflect() protoreflect.Message
func (*GetAccountFeaturesResponse) Reset ¶
func (x *GetAccountFeaturesResponse) Reset()
func (*GetAccountFeaturesResponse) String ¶
func (x *GetAccountFeaturesResponse) String() string
type GetServerFeaturesRequest ¶
type GetServerFeaturesRequest struct {
// contains filtered or unexported fields
}
GetServerFeaturesRequest is the parameter message for GetServerFeatures rpc.
func (*GetServerFeaturesRequest) Descriptor
deprecated
func (*GetServerFeaturesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetServerFeaturesRequest.ProtoReflect.Descriptor instead.
func (*GetServerFeaturesRequest) ProtoMessage ¶
func (*GetServerFeaturesRequest) ProtoMessage()
func (*GetServerFeaturesRequest) ProtoReflect ¶
func (x *GetServerFeaturesRequest) ProtoReflect() protoreflect.Message
func (*GetServerFeaturesRequest) Reset ¶
func (x *GetServerFeaturesRequest) Reset()
func (*GetServerFeaturesRequest) String ¶
func (x *GetServerFeaturesRequest) String() string
type GetServerFeaturesResponse ¶
type GetServerFeaturesResponse struct { // features contains features that should be announced by server entity. Features []string `protobuf:"bytes,1,rep,name=features,proto3" json:"features,omitempty"` // contains filtered or unexported fields }
GetServerFeaturesResponse is the response returned by GetServerFeatures rpc.
func (*GetServerFeaturesResponse) Descriptor
deprecated
func (*GetServerFeaturesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetServerFeaturesResponse.ProtoReflect.Descriptor instead.
func (*GetServerFeaturesResponse) GetFeatures ¶
func (x *GetServerFeaturesResponse) GetFeatures() []string
func (*GetServerFeaturesResponse) ProtoMessage ¶
func (*GetServerFeaturesResponse) ProtoMessage()
func (*GetServerFeaturesResponse) ProtoReflect ¶
func (x *GetServerFeaturesResponse) ProtoReflect() protoreflect.Message
func (*GetServerFeaturesResponse) Reset ¶
func (x *GetServerFeaturesResponse) Reset()
func (*GetServerFeaturesResponse) String ¶
func (x *GetServerFeaturesResponse) String() string
type GetStanzasRequest ¶
type GetStanzasRequest struct {
// contains filtered or unexported fields
}
GetStanzasRequest is the parameter message for GetStanzas rpc.
func (*GetStanzasRequest) Descriptor
deprecated
func (*GetStanzasRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetStanzasRequest.ProtoReflect.Descriptor instead.
func (*GetStanzasRequest) ProtoMessage ¶
func (*GetStanzasRequest) ProtoMessage()
func (*GetStanzasRequest) ProtoReflect ¶
func (x *GetStanzasRequest) ProtoReflect() protoreflect.Message
func (*GetStanzasRequest) Reset ¶
func (x *GetStanzasRequest) Reset()
func (*GetStanzasRequest) String ¶
func (x *GetStanzasRequest) String() string
type GetStreamFeatureRequest ¶
type GetStreamFeatureRequest struct { // domain is the domain value of the requested stream feature. Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"` // contains filtered or unexported fields }
GetStreamFeatureRequest is the parameter message for GetStreamFeature rpc.
func (*GetStreamFeatureRequest) Descriptor
deprecated
func (*GetStreamFeatureRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetStreamFeatureRequest.ProtoReflect.Descriptor instead.
func (*GetStreamFeatureRequest) GetDomain ¶
func (x *GetStreamFeatureRequest) GetDomain() string
func (*GetStreamFeatureRequest) ProtoMessage ¶
func (*GetStreamFeatureRequest) ProtoMessage()
func (*GetStreamFeatureRequest) ProtoReflect ¶
func (x *GetStreamFeatureRequest) ProtoReflect() protoreflect.Message
func (*GetStreamFeatureRequest) Reset ¶
func (x *GetStreamFeatureRequest) Reset()
func (*GetStreamFeatureRequest) String ¶
func (x *GetStreamFeatureRequest) String() string
type GetStreamFeatureResponse ¶
type GetStreamFeatureResponse struct { // feature is the module stream feature stanza. Feature *stravaganza.PBElement `protobuf:"bytes,1,opt,name=feature,proto3" json:"feature,omitempty"` // contains filtered or unexported fields }
GetStreamFeatureResponse is the response returned by GetStreamFeature rpc.
func (*GetStreamFeatureResponse) Descriptor
deprecated
func (*GetStreamFeatureResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetStreamFeatureResponse.ProtoReflect.Descriptor instead.
func (*GetStreamFeatureResponse) GetFeature ¶
func (x *GetStreamFeatureResponse) GetFeature() *stravaganza.PBElement
func (*GetStreamFeatureResponse) ProtoMessage ¶
func (*GetStreamFeatureResponse) ProtoMessage()
func (*GetStreamFeatureResponse) ProtoReflect ¶
func (x *GetStreamFeatureResponse) ProtoReflect() protoreflect.Message
func (*GetStreamFeatureResponse) Reset ¶
func (x *GetStreamFeatureResponse) Reset()
func (*GetStreamFeatureResponse) String ¶
func (x *GetStreamFeatureResponse) String() string
type InterceptStanzaRequest ¶ added in v0.52.2
type InterceptStanzaRequest struct { // id contains the associated interceptor identifier. Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // stanza is the intercepted stanza. Stanza *stravaganza.PBElement `protobuf:"bytes,2,opt,name=stanza,proto3" json:"stanza,omitempty"` // contains filtered or unexported fields }
InterceptStanzaRequest is the parameter message for InterceptStanza rpc.
func (*InterceptStanzaRequest) Descriptor
deprecated
added in
v0.52.2
func (*InterceptStanzaRequest) Descriptor() ([]byte, []int)
Deprecated: Use InterceptStanzaRequest.ProtoReflect.Descriptor instead.
func (*InterceptStanzaRequest) GetId ¶ added in v0.52.2
func (x *InterceptStanzaRequest) GetId() int64
func (*InterceptStanzaRequest) GetStanza ¶ added in v0.52.2
func (x *InterceptStanzaRequest) GetStanza() *stravaganza.PBElement
func (*InterceptStanzaRequest) ProtoMessage ¶ added in v0.52.2
func (*InterceptStanzaRequest) ProtoMessage()
func (*InterceptStanzaRequest) ProtoReflect ¶ added in v0.52.2
func (x *InterceptStanzaRequest) ProtoReflect() protoreflect.Message
func (*InterceptStanzaRequest) Reset ¶ added in v0.52.2
func (x *InterceptStanzaRequest) Reset()
func (*InterceptStanzaRequest) String ¶ added in v0.52.2
func (x *InterceptStanzaRequest) String() string
type InterceptStanzaResponse ¶ added in v0.52.2
type InterceptStanzaResponse struct { // stanza contains the resulting XMPP stanza. Stanza *stravaganza.PBElement `protobuf:"bytes,1,opt,name=stanza,proto3" json:"stanza,omitempty"` // contains filtered or unexported fields }
InterceptStanzaResponse is the response returned by InterceptStanza rpc.
func (*InterceptStanzaResponse) Descriptor
deprecated
added in
v0.52.2
func (*InterceptStanzaResponse) Descriptor() ([]byte, []int)
Deprecated: Use InterceptStanzaResponse.ProtoReflect.Descriptor instead.
func (*InterceptStanzaResponse) GetStanza ¶ added in v0.52.2
func (x *InterceptStanzaResponse) GetStanza() *stravaganza.PBElement
func (*InterceptStanzaResponse) ProtoMessage ¶ added in v0.52.2
func (*InterceptStanzaResponse) ProtoMessage()
func (*InterceptStanzaResponse) ProtoReflect ¶ added in v0.52.2
func (x *InterceptStanzaResponse) ProtoReflect() protoreflect.Message
func (*InterceptStanzaResponse) Reset ¶ added in v0.52.2
func (x *InterceptStanzaResponse) Reset()
func (*InterceptStanzaResponse) String ¶ added in v0.52.2
func (x *InterceptStanzaResponse) String() string
type ModuleClient ¶
type ModuleClient interface { // GetStreamFeature returns module stream feature stanza. GetStreamFeature(ctx context.Context, in *GetStreamFeatureRequest, opts ...grpc.CallOption) (*GetStreamFeatureResponse, error) // GetServerFeatures returns module server disco features. GetServerFeatures(ctx context.Context, in *GetServerFeaturesRequest, opts ...grpc.CallOption) (*GetServerFeaturesResponse, error) // GetAccountFeatures returns module account disco features. GetAccountFeatures(ctx context.Context, in *GetAccountFeaturesRequest, opts ...grpc.CallOption) (*GetAccountFeaturesResponse, error) // ProcessEvent method will be invoked by the server for all generated events associated to this module. ProcessEvent(ctx context.Context, in *ProcessEventRequest, opts ...grpc.CallOption) (*ProcessEventResponse, error) // ProcessIQ method will be invoked by the server for all received IQs associated to this module. ProcessIQ(ctx context.Context, in *ProcessIQRequest, opts ...grpc.CallOption) (*ProcessIQResponse, error) // InterceptStanza will be invoked to perform stanza transformation. InterceptStanza(ctx context.Context, in *InterceptStanzaRequest, opts ...grpc.CallOption) (*InterceptStanzaResponse, error) // GetStanzas returns a stream of stanzas to be routed by server. GetStanzas(ctx context.Context, in *GetStanzasRequest, opts ...grpc.CallOption) (Module_GetStanzasClient, error) }
ModuleClient is the client API for Module service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewModuleClient ¶
func NewModuleClient(cc *grpc.ClientConn) ModuleClient
type ModuleServer ¶
type ModuleServer interface { // GetStreamFeature returns module stream feature stanza. GetStreamFeature(context.Context, *GetStreamFeatureRequest) (*GetStreamFeatureResponse, error) // GetServerFeatures returns module server disco features. GetServerFeatures(context.Context, *GetServerFeaturesRequest) (*GetServerFeaturesResponse, error) // GetAccountFeatures returns module account disco features. GetAccountFeatures(context.Context, *GetAccountFeaturesRequest) (*GetAccountFeaturesResponse, error) // ProcessEvent method will be invoked by the server for all generated events associated to this module. ProcessEvent(context.Context, *ProcessEventRequest) (*ProcessEventResponse, error) // ProcessIQ method will be invoked by the server for all received IQs associated to this module. ProcessIQ(context.Context, *ProcessIQRequest) (*ProcessIQResponse, error) // InterceptStanza will be invoked to perform stanza transformation. InterceptStanza(context.Context, *InterceptStanzaRequest) (*InterceptStanzaResponse, error) // GetStanzas returns a stream of stanzas to be routed by server. GetStanzas(*GetStanzasRequest, Module_GetStanzasServer) error }
ModuleServer is the server API for Module service.
type Module_GetStanzasClient ¶
type Module_GetStanzasClient interface { Recv() (*stravaganza.PBElement, error) grpc.ClientStream }
type Module_GetStanzasServer ¶
type Module_GetStanzasServer interface { Send(*stravaganza.PBElement) error grpc.ServerStream }
type OfflineEventInfo ¶
type OfflineEventInfo struct { // username is the name of the vCard user associated to this event. Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` // message represents the event associated message. Message *stravaganza.PBElement `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
OfflineEventInfo contails all information associated to an offline event.
func (*OfflineEventInfo) Descriptor
deprecated
func (*OfflineEventInfo) Descriptor() ([]byte, []int)
Deprecated: Use OfflineEventInfo.ProtoReflect.Descriptor instead.
func (*OfflineEventInfo) GetMessage ¶
func (x *OfflineEventInfo) GetMessage() *stravaganza.PBElement
func (*OfflineEventInfo) GetUsername ¶
func (x *OfflineEventInfo) GetUsername() string
func (*OfflineEventInfo) ProtoMessage ¶
func (*OfflineEventInfo) ProtoMessage()
func (*OfflineEventInfo) ProtoReflect ¶
func (x *OfflineEventInfo) ProtoReflect() protoreflect.Message
func (*OfflineEventInfo) Reset ¶
func (x *OfflineEventInfo) Reset()
func (*OfflineEventInfo) String ¶
func (x *OfflineEventInfo) String() string
type PrivateEventInfo ¶
type PrivateEventInfo struct { // username is the name of the user associated to this event. Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` // private represents the event associated private element. Private *stravaganza.PBElement `protobuf:"bytes,2,opt,name=private,proto3" json:"private,omitempty"` // contains filtered or unexported fields }
PrivateEventInfo contains all information associated to a private event.
func (*PrivateEventInfo) Descriptor
deprecated
func (*PrivateEventInfo) Descriptor() ([]byte, []int)
Deprecated: Use PrivateEventInfo.ProtoReflect.Descriptor instead.
func (*PrivateEventInfo) GetPrivate ¶
func (x *PrivateEventInfo) GetPrivate() *stravaganza.PBElement
func (*PrivateEventInfo) GetUsername ¶
func (x *PrivateEventInfo) GetUsername() string
func (*PrivateEventInfo) ProtoMessage ¶
func (*PrivateEventInfo) ProtoMessage()
func (*PrivateEventInfo) ProtoReflect ¶
func (x *PrivateEventInfo) ProtoReflect() protoreflect.Message
func (*PrivateEventInfo) Reset ¶
func (x *PrivateEventInfo) Reset()
func (*PrivateEventInfo) String ¶
func (x *PrivateEventInfo) String() string
type ProcessEventRequest ¶
type ProcessEventRequest struct { // instance_id is the id of the server instance that generated the event. InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"` // event_name is the name of the event object. EventName string `protobuf:"bytes,2,opt,name=event_name,json=eventName,proto3" json:"event_name,omitempty"` // payload contains all info specifically associated to the event. // // Types that are assignable to Payload: // *ProcessEventRequest_C2SStreamEvInfo // *ProcessEventRequest_S2SStreamEvInfo // *ProcessEventRequest_ExtComponentEvInfo // *ProcessEventRequest_RosterEvInfo // *ProcessEventRequest_PrivateEvInfo // *ProcessEventRequest_VcardEvInfo // *ProcessEventRequest_OfflineEvInfo // *ProcessEventRequest_UserEvInfo Payload isProcessEventRequest_Payload `protobuf_oneof:"payload"` // contains filtered or unexported fields }
ProcessEventRequest is the parameter message for ProcessEvent rpc.
func (*ProcessEventRequest) Descriptor
deprecated
func (*ProcessEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProcessEventRequest.ProtoReflect.Descriptor instead.
func (*ProcessEventRequest) GetC2SStreamEvInfo ¶
func (x *ProcessEventRequest) GetC2SStreamEvInfo() *C2SStreamEventInfo
func (*ProcessEventRequest) GetEventName ¶
func (x *ProcessEventRequest) GetEventName() string
func (*ProcessEventRequest) GetExtComponentEvInfo ¶
func (x *ProcessEventRequest) GetExtComponentEvInfo() *ExternalComponentEventInfo
func (*ProcessEventRequest) GetInstanceId ¶
func (x *ProcessEventRequest) GetInstanceId() string
func (*ProcessEventRequest) GetOfflineEvInfo ¶
func (x *ProcessEventRequest) GetOfflineEvInfo() *OfflineEventInfo
func (*ProcessEventRequest) GetPayload ¶
func (m *ProcessEventRequest) GetPayload() isProcessEventRequest_Payload
func (*ProcessEventRequest) GetPrivateEvInfo ¶
func (x *ProcessEventRequest) GetPrivateEvInfo() *PrivateEventInfo
func (*ProcessEventRequest) GetRosterEvInfo ¶
func (x *ProcessEventRequest) GetRosterEvInfo() *RosterEventInfo
func (*ProcessEventRequest) GetS2SStreamEvInfo ¶
func (x *ProcessEventRequest) GetS2SStreamEvInfo() *S2SStreamEventInfo
func (*ProcessEventRequest) GetUserEvInfo ¶
func (x *ProcessEventRequest) GetUserEvInfo() *UserEventInfo
func (*ProcessEventRequest) GetVcardEvInfo ¶
func (x *ProcessEventRequest) GetVcardEvInfo() *VCardEventInfo
func (*ProcessEventRequest) ProtoMessage ¶
func (*ProcessEventRequest) ProtoMessage()
func (*ProcessEventRequest) ProtoReflect ¶
func (x *ProcessEventRequest) ProtoReflect() protoreflect.Message
func (*ProcessEventRequest) Reset ¶
func (x *ProcessEventRequest) Reset()
func (*ProcessEventRequest) String ¶
func (x *ProcessEventRequest) String() string
type ProcessEventRequest_C2SStreamEvInfo ¶
type ProcessEventRequest_C2SStreamEvInfo struct {
C2SStreamEvInfo *C2SStreamEventInfo `protobuf:"bytes,3,opt,name=c2s_stream_ev_info,json=c2sStreamEvInfo,proto3,oneof"`
}
type ProcessEventRequest_ExtComponentEvInfo ¶
type ProcessEventRequest_ExtComponentEvInfo struct {
ExtComponentEvInfo *ExternalComponentEventInfo `protobuf:"bytes,5,opt,name=ext_component_ev_info,json=extComponentEvInfo,proto3,oneof"`
}
type ProcessEventRequest_OfflineEvInfo ¶
type ProcessEventRequest_OfflineEvInfo struct {
OfflineEvInfo *OfflineEventInfo `protobuf:"bytes,9,opt,name=offline_ev_info,json=offlineEvInfo,proto3,oneof"`
}
type ProcessEventRequest_PrivateEvInfo ¶
type ProcessEventRequest_PrivateEvInfo struct {
PrivateEvInfo *PrivateEventInfo `protobuf:"bytes,7,opt,name=private_ev_info,json=privateEvInfo,proto3,oneof"`
}
type ProcessEventRequest_RosterEvInfo ¶
type ProcessEventRequest_RosterEvInfo struct {
RosterEvInfo *RosterEventInfo `protobuf:"bytes,6,opt,name=roster_ev_info,json=rosterEvInfo,proto3,oneof"`
}
type ProcessEventRequest_S2SStreamEvInfo ¶
type ProcessEventRequest_S2SStreamEvInfo struct {
S2SStreamEvInfo *S2SStreamEventInfo `protobuf:"bytes,4,opt,name=s2s_stream_ev_info,json=s2sStreamEvInfo,proto3,oneof"`
}
type ProcessEventRequest_UserEvInfo ¶
type ProcessEventRequest_UserEvInfo struct {
UserEvInfo *UserEventInfo `protobuf:"bytes,10,opt,name=user_ev_info,json=userEvInfo,proto3,oneof"`
}
type ProcessEventRequest_VcardEvInfo ¶
type ProcessEventRequest_VcardEvInfo struct {
VcardEvInfo *VCardEventInfo `protobuf:"bytes,8,opt,name=vcard_ev_info,json=vcardEvInfo,proto3,oneof"`
}
type ProcessEventResponse ¶
type ProcessEventResponse struct {
// contains filtered or unexported fields
}
ProcessEventResponse is the response returned by ProcessEvent rpc.
func (*ProcessEventResponse) Descriptor
deprecated
func (*ProcessEventResponse) Descriptor() ([]byte, []int)
Deprecated: Use ProcessEventResponse.ProtoReflect.Descriptor instead.
func (*ProcessEventResponse) ProtoMessage ¶
func (*ProcessEventResponse) ProtoMessage()
func (*ProcessEventResponse) ProtoReflect ¶
func (x *ProcessEventResponse) ProtoReflect() protoreflect.Message
func (*ProcessEventResponse) Reset ¶
func (x *ProcessEventResponse) Reset()
func (*ProcessEventResponse) String ¶
func (x *ProcessEventResponse) String() string
type ProcessIQRequest ¶
type ProcessIQRequest struct { // iq is the module registered IQ to be processed. Iq *stravaganza.PBElement `protobuf:"bytes,1,opt,name=iq,proto3" json:"iq,omitempty"` // contains filtered or unexported fields }
ProcessIQRequest is the parameter message for ProcessIQ rpc.
func (*ProcessIQRequest) Descriptor
deprecated
func (*ProcessIQRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProcessIQRequest.ProtoReflect.Descriptor instead.
func (*ProcessIQRequest) GetIq ¶
func (x *ProcessIQRequest) GetIq() *stravaganza.PBElement
func (*ProcessIQRequest) ProtoMessage ¶
func (*ProcessIQRequest) ProtoMessage()
func (*ProcessIQRequest) ProtoReflect ¶
func (x *ProcessIQRequest) ProtoReflect() protoreflect.Message
func (*ProcessIQRequest) Reset ¶
func (x *ProcessIQRequest) Reset()
func (*ProcessIQRequest) String ¶
func (x *ProcessIQRequest) String() string
type ProcessIQResponse ¶
type ProcessIQResponse struct {
// contains filtered or unexported fields
}
ProcessIQResponse is the response returned by ProcessIQ rpc.
func (*ProcessIQResponse) Descriptor
deprecated
func (*ProcessIQResponse) Descriptor() ([]byte, []int)
Deprecated: Use ProcessIQResponse.ProtoReflect.Descriptor instead.
func (*ProcessIQResponse) ProtoMessage ¶
func (*ProcessIQResponse) ProtoMessage()
func (*ProcessIQResponse) ProtoReflect ¶
func (x *ProcessIQResponse) ProtoReflect() protoreflect.Message
func (*ProcessIQResponse) Reset ¶
func (x *ProcessIQResponse) Reset()
func (*ProcessIQResponse) String ¶
func (x *ProcessIQResponse) String() string
type RosterEventInfo ¶
type RosterEventInfo struct { // username is the name of the roster owner. Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` // jid represents the event associated JID. Jid string `protobuf:"bytes,2,opt,name=jid,proto3" json:"jid,omitempty"` // subscription is the roster event subscription value. Subscription string `protobuf:"bytes,3,opt,name=subscription,proto3" json:"subscription,omitempty"` // contains filtered or unexported fields }
RosterEventInfo contains all information associated to a roster event.
func (*RosterEventInfo) Descriptor
deprecated
func (*RosterEventInfo) Descriptor() ([]byte, []int)
Deprecated: Use RosterEventInfo.ProtoReflect.Descriptor instead.
func (*RosterEventInfo) GetJid ¶
func (x *RosterEventInfo) GetJid() string
func (*RosterEventInfo) GetSubscription ¶
func (x *RosterEventInfo) GetSubscription() string
func (*RosterEventInfo) GetUsername ¶
func (x *RosterEventInfo) GetUsername() string
func (*RosterEventInfo) ProtoMessage ¶
func (*RosterEventInfo) ProtoMessage()
func (*RosterEventInfo) ProtoReflect ¶
func (x *RosterEventInfo) ProtoReflect() protoreflect.Message
func (*RosterEventInfo) Reset ¶
func (x *RosterEventInfo) Reset()
func (*RosterEventInfo) String ¶
func (x *RosterEventInfo) String() string
type S2SStreamEventInfo ¶
type S2SStreamEventInfo struct { // id is the event stream identifier. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // sender is the S2S sender domain. Sender string `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"` // target is the S2S target domain. Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` // stanza contains the XMPP stanza associated to the event. Stanza *stravaganza.PBElement `protobuf:"bytes,4,opt,name=stanza,proto3" json:"stanza,omitempty"` // contains filtered or unexported fields }
S2SStreamEventInfo contains all info associated to a S2S stream event.
func (*S2SStreamEventInfo) Descriptor
deprecated
func (*S2SStreamEventInfo) Descriptor() ([]byte, []int)
Deprecated: Use S2SStreamEventInfo.ProtoReflect.Descriptor instead.
func (*S2SStreamEventInfo) GetId ¶
func (x *S2SStreamEventInfo) GetId() string
func (*S2SStreamEventInfo) GetSender ¶
func (x *S2SStreamEventInfo) GetSender() string
func (*S2SStreamEventInfo) GetStanza ¶
func (x *S2SStreamEventInfo) GetStanza() *stravaganza.PBElement
func (*S2SStreamEventInfo) GetTarget ¶
func (x *S2SStreamEventInfo) GetTarget() string
func (*S2SStreamEventInfo) ProtoMessage ¶
func (*S2SStreamEventInfo) ProtoMessage()
func (*S2SStreamEventInfo) ProtoReflect ¶
func (x *S2SStreamEventInfo) ProtoReflect() protoreflect.Message
func (*S2SStreamEventInfo) Reset ¶
func (x *S2SStreamEventInfo) Reset()
func (*S2SStreamEventInfo) String ¶
func (x *S2SStreamEventInfo) String() string
type UnimplementedModuleServer ¶
type UnimplementedModuleServer struct { }
UnimplementedModuleServer can be embedded to have forward compatible implementations.
func (*UnimplementedModuleServer) GetAccountFeatures ¶
func (*UnimplementedModuleServer) GetAccountFeatures(context.Context, *GetAccountFeaturesRequest) (*GetAccountFeaturesResponse, error)
func (*UnimplementedModuleServer) GetServerFeatures ¶
func (*UnimplementedModuleServer) GetServerFeatures(context.Context, *GetServerFeaturesRequest) (*GetServerFeaturesResponse, error)
func (*UnimplementedModuleServer) GetStanzas ¶
func (*UnimplementedModuleServer) GetStanzas(*GetStanzasRequest, Module_GetStanzasServer) error
func (*UnimplementedModuleServer) GetStreamFeature ¶
func (*UnimplementedModuleServer) GetStreamFeature(context.Context, *GetStreamFeatureRequest) (*GetStreamFeatureResponse, error)
func (*UnimplementedModuleServer) InterceptStanza ¶ added in v0.52.2
func (*UnimplementedModuleServer) InterceptStanza(context.Context, *InterceptStanzaRequest) (*InterceptStanzaResponse, error)
func (*UnimplementedModuleServer) ProcessEvent ¶
func (*UnimplementedModuleServer) ProcessEvent(context.Context, *ProcessEventRequest) (*ProcessEventResponse, error)
func (*UnimplementedModuleServer) ProcessIQ ¶
func (*UnimplementedModuleServer) ProcessIQ(context.Context, *ProcessIQRequest) (*ProcessIQResponse, error)
type UserEventInfo ¶
type UserEventInfo struct { // username is the name of the user associated to this event. Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` // contains filtered or unexported fields }
UserEventInfo contains all information associated to a user event.
func (*UserEventInfo) Descriptor
deprecated
func (*UserEventInfo) Descriptor() ([]byte, []int)
Deprecated: Use UserEventInfo.ProtoReflect.Descriptor instead.
func (*UserEventInfo) GetUsername ¶
func (x *UserEventInfo) GetUsername() string
func (*UserEventInfo) ProtoMessage ¶
func (*UserEventInfo) ProtoMessage()
func (*UserEventInfo) ProtoReflect ¶
func (x *UserEventInfo) ProtoReflect() protoreflect.Message
func (*UserEventInfo) Reset ¶
func (x *UserEventInfo) Reset()
func (*UserEventInfo) String ¶
func (x *UserEventInfo) String() string
type VCardEventInfo ¶
type VCardEventInfo struct { // username is the name of the vCard user associated to this event. Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` // vcard represents the event associated vcard element. Vcard *stravaganza.PBElement `protobuf:"bytes,2,opt,name=vcard,proto3" json:"vcard,omitempty"` // contains filtered or unexported fields }
VCardEventInfo contains all information associated to a vCard event.
func (*VCardEventInfo) Descriptor
deprecated
func (*VCardEventInfo) Descriptor() ([]byte, []int)
Deprecated: Use VCardEventInfo.ProtoReflect.Descriptor instead.
func (*VCardEventInfo) GetUsername ¶
func (x *VCardEventInfo) GetUsername() string
func (*VCardEventInfo) GetVcard ¶
func (x *VCardEventInfo) GetVcard() *stravaganza.PBElement
func (*VCardEventInfo) ProtoMessage ¶
func (*VCardEventInfo) ProtoMessage()
func (*VCardEventInfo) ProtoReflect ¶
func (x *VCardEventInfo) ProtoReflect() protoreflect.Message
func (*VCardEventInfo) Reset ¶
func (x *VCardEventInfo) Reset()
func (*VCardEventInfo) String ¶
func (x *VCardEventInfo) String() string