v1

Documentation

Index

• Variables
• func RegisterIQHandlerServer(s *grpc.Server, srv IQHandlerServer)
• type GetDiscoFeaturesRequest
  • func (*GetDiscoFeaturesRequest) Descriptor() ([]byte, []int)
  • func (*GetDiscoFeaturesRequest) ProtoMessage()
  • func (x *GetDiscoFeaturesRequest) ProtoReflect() protoreflect.Message
  • func (x *GetDiscoFeaturesRequest) Reset()
  • func (x *GetDiscoFeaturesRequest) String() string
• type GetDiscoFeaturesResponse
  • func (*GetDiscoFeaturesResponse) Descriptor() ([]byte, []int)
  • func (x *GetDiscoFeaturesResponse) GetAccountFeatures() []string
  • func (x *GetDiscoFeaturesResponse) GetServerFeatures() []string
  • func (*GetDiscoFeaturesResponse) ProtoMessage()
  • func (x *GetDiscoFeaturesResponse) ProtoReflect() protoreflect.Message
  • func (x *GetDiscoFeaturesResponse) Reset()
  • func (x *GetDiscoFeaturesResponse) String() string
• type IQHandlerClient
  • func NewIQHandlerClient(cc *grpc.ClientConn) IQHandlerClient
• type IQHandlerServer
• type ProcessIQRequest
  • func (*ProcessIQRequest) Descriptor() ([]byte, []int)
  • 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
  • func (*ProcessIQResponse) Descriptor() ([]byte, []int)
  • func (x *ProcessIQResponse) GetRespStanzas() []*stravaganza.PBElement
  • func (*ProcessIQResponse) ProtoMessage()
  • func (x *ProcessIQResponse) ProtoReflect() protoreflect.Message
  • func (x *ProcessIQResponse) Reset()
  • func (x *ProcessIQResponse) String() string
• type UnimplementedIQHandlerServer
  • func (*UnimplementedIQHandlerServer) GetDiscoFeatures(context.Context, *GetDiscoFeaturesRequest) (*GetDiscoFeaturesResponse, error)
  • func (*UnimplementedIQHandlerServer) ProcessIQ(context.Context, *ProcessIQRequest) (*ProcessIQResponse, error)

Variables

var File_iqhandler_proto protoreflect.FileDescriptor

Functions

func RegisterIQHandlerServer

func RegisterIQHandlerServer(s *grpc.Server, srv IQHandlerServer)

Types

type GetDiscoFeaturesRequest

type GetDiscoFeaturesRequest struct {
	// contains filtered or unexported fields
}

GetDiscoFeaturesRequest is the parameter message for GetDiscoFeatures rpc.

func (*GetDiscoFeaturesRequest) Descriptor

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

Deprecated: Use GetDiscoFeaturesRequest.ProtoReflect.Descriptor instead.

func (*GetDiscoFeaturesRequest) ProtoMessage

func (*GetDiscoFeaturesRequest) ProtoMessage()

func (*GetDiscoFeaturesRequest) ProtoReflect

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

func (*GetDiscoFeaturesRequest) Reset

func (x *GetDiscoFeaturesRequest) Reset()

func (*GetDiscoFeaturesRequest) String

func (x *GetDiscoFeaturesRequest) String() string

type GetDiscoFeaturesResponse

type GetDiscoFeaturesResponse struct {

	// server_features contains features that should be announced by server entity.
	ServerFeatures []string `protobuf:"bytes,1,rep,name=server_features,json=serverFeatures,proto3" json:"server_features,omitempty"`
	// account_features contains features that should be announced by account entities.
	AccountFeatures []string `protobuf:"bytes,2,rep,name=account_features,json=accountFeatures,proto3" json:"account_features,omitempty"`
	// contains filtered or unexported fields
}

GetDiscoFeaturesResponse is the response returned by GetDiscoFeatures rpc.

func (*GetDiscoFeaturesResponse) Descriptor

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

Deprecated: Use GetDiscoFeaturesResponse.ProtoReflect.Descriptor instead.

func (*GetDiscoFeaturesResponse) GetAccountFeatures

func (x *GetDiscoFeaturesResponse) GetAccountFeatures() []string

func (*GetDiscoFeaturesResponse) GetServerFeatures

func (x *GetDiscoFeaturesResponse) GetServerFeatures() []string

func (*GetDiscoFeaturesResponse) ProtoMessage

func (*GetDiscoFeaturesResponse) ProtoMessage()

func (*GetDiscoFeaturesResponse) ProtoReflect

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

func (*GetDiscoFeaturesResponse) Reset

func (x *GetDiscoFeaturesResponse) Reset()

func (*GetDiscoFeaturesResponse) String

func (x *GetDiscoFeaturesResponse) String() string

type IQHandlerClient

type IQHandlerClient interface {
	// GetDiscoFeatures returns IQ handler disco features.
	GetDiscoFeatures(ctx context.Context, in *GetDiscoFeaturesRequest, opts ...grpc.CallOption) (*GetDiscoFeaturesResponse, error)
	// ProcessIQ method will be invoked by the server for all received IQs associated to this handler.
	ProcessIQ(ctx context.Context, in *ProcessIQRequest, opts ...grpc.CallOption) (*ProcessIQResponse, error)
}

IQHandlerClient is the client API for IQHandler service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewIQHandlerClient

func NewIQHandlerClient(cc *grpc.ClientConn) IQHandlerClient

type IQHandlerServer

type IQHandlerServer interface {
	// GetDiscoFeatures returns IQ handler disco features.
	GetDiscoFeatures(context.Context, *GetDiscoFeaturesRequest) (*GetDiscoFeaturesResponse, error)
	// ProcessIQ method will be invoked by the server for all received IQs associated to this handler.
	ProcessIQ(context.Context, *ProcessIQRequest) (*ProcessIQResponse, error)
}

IQHandlerServer is the server API for IQHandler service.

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

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 {

	// resp_stanzas contains all module response stanzas to be routed by server.
	RespStanzas []*stravaganza.PBElement `protobuf:"bytes,1,rep,name=resp_stanzas,json=respStanzas,proto3" json:"resp_stanzas,omitempty"`
	// contains filtered or unexported fields
}

ProcessIQResponse is the response returned by ProcessIQ rpc.

func (*ProcessIQResponse) Descriptor

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

Deprecated: Use ProcessIQResponse.ProtoReflect.Descriptor instead.

func (*ProcessIQResponse) GetRespStanzas

func (x *ProcessIQResponse) GetRespStanzas() []*stravaganza.PBElement

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 UnimplementedIQHandlerServer

type UnimplementedIQHandlerServer struct {
}

UnimplementedIQHandlerServer can be embedded to have forward compatible implementations.

func (*UnimplementedIQHandlerServer) GetDiscoFeatures

func (*UnimplementedIQHandlerServer) GetDiscoFeatures(context.Context, *GetDiscoFeaturesRequest) (*GetDiscoFeaturesResponse, error)

func (*UnimplementedIQHandlerServer) ProcessIQ

func (*UnimplementedIQHandlerServer) ProcessIQ(context.Context, *ProcessIQRequest) (*ProcessIQResponse, error)