Documentation ¶
Index ¶
- func NewRoomserverRpcClient(cfg *config.Dendrite, rpcClient *common.RpcClient, ...) roomserverapi.RoomserverRPCAPI
- type RoomAliasRpcConsumer
- type RoomserverRpcClient
- func (c *RoomserverRpcClient) AllocRoomAlias(ctx context.Context, req *roomserverapi.SetRoomAliasRequest, ...) error
- func (c *RoomserverRpcClient) GetAliasRoomID(ctx context.Context, req *roomserverapi.GetAliasRoomIDRequest, ...) error
- func (c *RoomserverRpcClient) InputRoomEvents(ctx context.Context, rawEvent *roomserverapi.RawEvent) (int, error)
- func (c *RoomserverRpcClient) ProcessProfile(edu *gomatrixserverlib.EDU)
- func (c *RoomserverRpcClient) ProcessReceipt(edu *gomatrixserverlib.EDU)
- func (c *RoomserverRpcClient) ProcessTyping(edu *gomatrixserverlib.EDU)
- func (c *RoomserverRpcClient) QueryBackFillEvents(ctx context.Context, req *roomserverapi.QueryBackFillEventsRequest, ...) error
- func (c *RoomserverRpcClient) QueryEventAuth(ctx context.Context, req *roomserverapi.QueryEventAuthRequest, ...) error
- func (c *RoomserverRpcClient) QueryEventsByDomainOffset(ctx context.Context, req *roomserverapi.QueryEventsByDomainOffsetRequest, ...) error
- func (c *RoomserverRpcClient) QueryEventsByID(ctx context.Context, req *roomserverapi.QueryEventsByIDRequest, ...) error
- func (c *RoomserverRpcClient) QueryJoinRooms(ctx context.Context, req *roomserverapi.QueryJoinRoomsRequest, ...) error
- func (c *RoomserverRpcClient) QueryRoomEventByID(ctx context.Context, req *roomserverapi.QueryRoomEventByIDRequest, ...) error
- func (c *RoomserverRpcClient) QueryRoomState(ctx context.Context, req *roomserverapi.QueryRoomStateRequest, ...) error
- func (c *RoomserverRpcClient) RemoveRoomAlias(ctx context.Context, req *roomserverapi.RemoveRoomAliasRequest, ...) error
- func (c *RoomserverRpcClient) SetRoomAlias(ctx context.Context, req *roomserverapi.SetRoomAliasRequest, ...) error
- type RoomserverRpcConsumer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewRoomserverRpcClient ¶
func NewRoomserverRpcClient( cfg *config.Dendrite, rpcClient *common.RpcClient, aliase roomserverapi.RoomserverAliasAPI, qry roomserverapi.RoomserverQueryAPI, input roomserverapi.RoomserverInputAPI, ) roomserverapi.RoomserverRPCAPI
Types ¶
type RoomAliasRpcConsumer ¶
type RoomAliasRpcConsumer struct { DB model.RoomServerDatabase Repo *repos.RoomServerCurStateRepo UmsRepo *repos.RoomServerUserMembershipRepo Proc roomserverapi.RoomserverAliasAPI // contains filtered or unexported fields }
func NewRoomAliasRpcConsumer ¶
func NewRoomAliasRpcConsumer( cfg *config.Dendrite, rpcClient *common.RpcClient, db model.RoomServerDatabase, repo *repos.RoomServerCurStateRepo, umsRepo *repos.RoomServerUserMembershipRepo, proc roomserverapi.RoomserverAliasAPI, ) *RoomAliasRpcConsumer
func (*RoomAliasRpcConsumer) GetTopic ¶
func (s *RoomAliasRpcConsumer) GetTopic() string
func (*RoomAliasRpcConsumer) Start ¶
func (s *RoomAliasRpcConsumer) Start() error
type RoomserverRpcClient ¶
type RoomserverRpcClient struct {
// contains filtered or unexported fields
}
func (*RoomserverRpcClient) AllocRoomAlias ¶
func (c *RoomserverRpcClient) AllocRoomAlias( ctx context.Context, req *roomserverapi.SetRoomAliasRequest, response *roomserverapi.SetRoomAliasResponse, ) error
func (*RoomserverRpcClient) GetAliasRoomID ¶
func (c *RoomserverRpcClient) GetAliasRoomID( ctx context.Context, req *roomserverapi.GetAliasRoomIDRequest, response *roomserverapi.GetAliasRoomIDResponse, ) error
func (*RoomserverRpcClient) InputRoomEvents ¶
func (c *RoomserverRpcClient) InputRoomEvents( ctx context.Context, rawEvent *roomserverapi.RawEvent, ) (int, error)
use kafka in a async way, use nats in a sync way
func (*RoomserverRpcClient) ProcessProfile ¶
func (c *RoomserverRpcClient) ProcessProfile(edu *gomatrixserverlib.EDU)
func (*RoomserverRpcClient) ProcessReceipt ¶
func (c *RoomserverRpcClient) ProcessReceipt(edu *gomatrixserverlib.EDU)
func (*RoomserverRpcClient) ProcessTyping ¶
func (c *RoomserverRpcClient) ProcessTyping(edu *gomatrixserverlib.EDU)
func (*RoomserverRpcClient) QueryBackFillEvents ¶
func (c *RoomserverRpcClient) QueryBackFillEvents( ctx context.Context, req *roomserverapi.QueryBackFillEventsRequest, response *roomserverapi.QueryBackFillEventsResponse, ) error
func (*RoomserverRpcClient) QueryEventAuth ¶
func (c *RoomserverRpcClient) QueryEventAuth( ctx context.Context, req *roomserverapi.QueryEventAuthRequest, response *roomserverapi.QueryEventAuthResponse, ) error
func (*RoomserverRpcClient) QueryEventsByDomainOffset ¶
func (c *RoomserverRpcClient) QueryEventsByDomainOffset( ctx context.Context, req *roomserverapi.QueryEventsByDomainOffsetRequest, response *roomserverapi.QueryEventsByDomainOffsetResponse, ) error
func (*RoomserverRpcClient) QueryEventsByID ¶
func (c *RoomserverRpcClient) QueryEventsByID( ctx context.Context, req *roomserverapi.QueryEventsByIDRequest, response *roomserverapi.QueryEventsByIDResponse, ) error
func (*RoomserverRpcClient) QueryJoinRooms ¶
func (c *RoomserverRpcClient) QueryJoinRooms( ctx context.Context, req *roomserverapi.QueryJoinRoomsRequest, response *roomserverapi.QueryJoinRoomsResponse, ) error
func (*RoomserverRpcClient) QueryRoomEventByID ¶
func (c *RoomserverRpcClient) QueryRoomEventByID( ctx context.Context, req *roomserverapi.QueryRoomEventByIDRequest, response *roomserverapi.QueryRoomEventByIDResponse, ) error
func (*RoomserverRpcClient) QueryRoomState ¶
func (c *RoomserverRpcClient) QueryRoomState( ctx context.Context, req *roomserverapi.QueryRoomStateRequest, response *roomserverapi.QueryRoomStateResponse, ) error
func (*RoomserverRpcClient) RemoveRoomAlias ¶
func (c *RoomserverRpcClient) RemoveRoomAlias( ctx context.Context, req *roomserverapi.RemoveRoomAliasRequest, response *roomserverapi.RemoveRoomAliasResponse, ) error
func (*RoomserverRpcClient) SetRoomAlias ¶
func (c *RoomserverRpcClient) SetRoomAlias( ctx context.Context, req *roomserverapi.SetRoomAliasRequest, response *roomserverapi.SetRoomAliasResponse, ) error
type RoomserverRpcConsumer ¶
type RoomserverRpcConsumer struct { DB model.RoomServerDatabase Repo *repos.RoomServerCurStateRepo UmsRepo *repos.RoomServerUserMembershipRepo Proc roomserverapi.RoomserverQueryAPI // contains filtered or unexported fields }
func NewRoomserverRpcConsumer ¶
func NewRoomserverRpcConsumer( cfg *config.Dendrite, rpcClient *common.RpcClient, db model.RoomServerDatabase, repo *repos.RoomServerCurStateRepo, umsRepo *repos.RoomServerUserMembershipRepo, proc roomserverapi.RoomserverQueryAPI, ) *RoomserverRpcConsumer
func (*RoomserverRpcConsumer) GetTopic ¶
func (s *RoomserverRpcConsumer) GetTopic() string
func (*RoomserverRpcConsumer) Start ¶
func (s *RoomserverRpcConsumer) Start() error
Click to show internal directories.
Click to hide internal directories.