rpc

Documentation

Index

• type FedPublicRoomsRpcClient
  • func NewFedPublicRoomsRpcClient(cfg *config.Fed, rpcClient *common.RpcClient) *FedPublicRoomsRpcClient
  • func (fed *FedPublicRoomsRpcClient) QueryPublicRooms(ctx context.Context, request *publicroomsapi.QueryPublicRoomsRequest, ...) error
  • func (fed *FedPublicRoomsRpcClient) Start()
• type FederationRpcClient
  • func NewFederationRpcClient(cfg *config.Fed, rpcClient *common.RpcClient, ...) *FederationRpcClient
  • func (fed *FederationRpcClient) AllocRoomAlias(ctx context.Context, request *roomserverapi.SetRoomAliasRequest, ...) error
  • func (fed *FederationRpcClient) GetAliasRoomID(ctx context.Context, req *roomserverapi.GetAliasRoomIDRequest, ...) error
  • func (fed *FederationRpcClient) InputRoomEvents(ctx context.Context, rawEvent *roomserverapi.RawEvent) (int, error)
  • func (fed *FederationRpcClient) ProcessProfile(edu *gomatrixserverlib.EDU)
  • func (fed *FederationRpcClient) ProcessReceipt(edu *gomatrixserverlib.EDU)
  • func (fed *FederationRpcClient) ProcessTyping(edu *gomatrixserverlib.EDU)
  • func (fed *FederationRpcClient) QueryBackFillEvents(ctx context.Context, req *roomserverapi.QueryBackFillEventsRequest, ...) error
  • func (fed *FederationRpcClient) QueryEventAuth(ctx context.Context, req *roomserverapi.QueryEventAuthRequest, ...) error
  • func (fed *FederationRpcClient) QueryEventsByDomainOffset(ctx context.Context, req *roomserverapi.QueryEventsByDomainOffsetRequest, ...) error
  • func (fed *FederationRpcClient) QueryEventsByID(ctx context.Context, request *roomserverapi.QueryEventsByIDRequest, ...) error
  • func (fed *FederationRpcClient) QueryJoinRooms(ctx context.Context, request *roomserverapi.QueryJoinRoomsRequest, ...) error
  • func (fed *FederationRpcClient) QueryRoomEventByID(ctx context.Context, request *roomserverapi.QueryRoomEventByIDRequest, ...) error
  • func (fed *FederationRpcClient) QueryRoomState(ctx context.Context, request *roomserverapi.QueryRoomStateRequest, ...) error
  • func (fed *FederationRpcClient) RemoveRoomAlias(ctx context.Context, request *roomserverapi.RemoveRoomAliasRequest, ...) error
  • func (fed *FederationRpcClient) SetRoomAlias(ctx context.Context, request *roomserverapi.SetRoomAliasRequest, ...) error
  • func (fed *FederationRpcClient) Start()

Types

type FedPublicRoomsRpcClient

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

func NewFedPublicRoomsRpcClient

func NewFedPublicRoomsRpcClient(
	cfg *config.Fed,
	rpcClient *common.RpcClient,
) *FedPublicRoomsRpcClient

func (*FedPublicRoomsRpcClient) QueryPublicRooms

func (fed *FedPublicRoomsRpcClient) QueryPublicRooms(ctx context.Context, request *publicroomsapi.QueryPublicRoomsRequest, response *publicroomsapi.QueryPublicRoomsResponse) error

func (*FedPublicRoomsRpcClient) Start

func (fed *FedPublicRoomsRpcClient) Start()

type FederationRpcClient

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

func NewFederationRpcClient

func NewFederationRpcClient(
	cfg *config.Fed,
	rpcClient *common.RpcClient,
	aliase roomserverapi.RoomserverAliasAPI,
	qry roomserverapi.RoomserverQueryAPI,
	input roomserverapi.RoomserverInputAPI,
) *FederationRpcClient

func (*FederationRpcClient) AllocRoomAlias

func (fed *FederationRpcClient) AllocRoomAlias(
	ctx context.Context,
	request *roomserverapi.SetRoomAliasRequest,
	response *roomserverapi.SetRoomAliasResponse,
) error

func (*FederationRpcClient) GetAliasRoomID

func (fed *FederationRpcClient) GetAliasRoomID(
	ctx context.Context,
	req *roomserverapi.GetAliasRoomIDRequest,
	response *roomserverapi.GetAliasRoomIDResponse,
) error

func (*FederationRpcClient) InputRoomEvents

func (fed *FederationRpcClient) InputRoomEvents(
	ctx context.Context,
	rawEvent *roomserverapi.RawEvent,
) (int, error)

func (*FederationRpcClient) ProcessProfile

func (fed *FederationRpcClient) ProcessProfile(edu *gomatrixserverlib.EDU)

func (*FederationRpcClient) ProcessReceipt

func (fed *FederationRpcClient) ProcessReceipt(edu *gomatrixserverlib.EDU)

func (*FederationRpcClient) ProcessTyping

func (fed *FederationRpcClient) ProcessTyping(edu *gomatrixserverlib.EDU)

func (*FederationRpcClient) QueryBackFillEvents

func (fed *FederationRpcClient) QueryBackFillEvents(
	ctx context.Context,
	req *roomserverapi.QueryBackFillEventsRequest,
	response *roomserverapi.QueryBackFillEventsResponse,
) error

func (*FederationRpcClient) QueryEventAuth

func (fed *FederationRpcClient) QueryEventAuth(
	ctx context.Context,
	req *roomserverapi.QueryEventAuthRequest,
	response *roomserverapi.QueryEventAuthResponse,
) error

func (*FederationRpcClient) QueryEventsByDomainOffset

func (fed *FederationRpcClient) QueryEventsByDomainOffset(
	ctx context.Context,
	req *roomserverapi.QueryEventsByDomainOffsetRequest,
	response *roomserverapi.QueryEventsByDomainOffsetResponse,
) error

func (*FederationRpcClient) QueryEventsByID

func (fed *FederationRpcClient) QueryEventsByID(
	ctx context.Context,
	request *roomserverapi.QueryEventsByIDRequest,
	response *roomserverapi.QueryEventsByIDResponse,
) error

func (*FederationRpcClient) QueryJoinRooms

func (fed *FederationRpcClient) QueryJoinRooms(
	ctx context.Context,
	request *roomserverapi.QueryJoinRoomsRequest,
	response *roomserverapi.QueryJoinRoomsResponse,
) error

func (*FederationRpcClient) QueryRoomEventByID

func (fed *FederationRpcClient) QueryRoomEventByID(
	ctx context.Context,
	request *roomserverapi.QueryRoomEventByIDRequest,
	response *roomserverapi.QueryRoomEventByIDResponse,
) error

func (*FederationRpcClient) QueryRoomState

func (fed *FederationRpcClient) QueryRoomState(
	ctx context.Context,
	request *roomserverapi.QueryRoomStateRequest,
	response *roomserverapi.QueryRoomStateResponse,
) error

func (*FederationRpcClient) RemoveRoomAlias

func (fed *FederationRpcClient) RemoveRoomAlias(
	ctx context.Context,
	request *roomserverapi.RemoveRoomAliasRequest,
	response *roomserverapi.RemoveRoomAliasResponse,
) error

func (*FederationRpcClient) SetRoomAlias

func (fed *FederationRpcClient) SetRoomAlias(
	ctx context.Context,
	request *roomserverapi.SetRoomAliasRequest,
	response *roomserverapi.SetRoomAliasResponse,
) error

func (*FederationRpcClient) Start

func (fed *FederationRpcClient) Start()