rpc

package
v0.0.0-...-9835270 Latest Latest
Warning

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

 Go to latest Published: Sep 22, 2021 License: AGPL-3.0, Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

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

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.