entry

package

v0.0.0-...-9835270 Latest Latest Go to latest Published: Sep 22, 2021 License: AGPL-3.0, Apache-2.0, MIT Imports: 33 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/finogeeks/ligase

Documentation ¶

Index ¶

Variables
func Backfill(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func ClaimClientKeys(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func EventAuth(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func GetAvatarURL(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func GetDisplayName(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func GetProfile(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func GetPublicRooms(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func GetUserInfo(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func Invite(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func MakeJoin(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func MakeLeave(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func NotaryNotice(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func PostPublicRooms(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func QueryAuth(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func QueryClientKeys(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func QueryEvent(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func QueryStateIDs(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func Register(cmd model.Command, f FedApiEntryCB)
func RoomDirectory(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func RoomState(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func Send(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func SendJoin(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func SendLeave(ctx context.Context, msg *model.GobMessage, cache service.Cache, ...) (*model.GobMessage, error)
func SetBackFillProcessor(p backfilltypes.BackFillProcessor)
func SetBackfillRepo(repo *repos.BackfillRepo)
func SetCert(c *cert.Cert)
func SetCfg(v *config.Fed)
func SetComplexCache(cache *common.ComplexCache)
func SetEncryptionDB(db dbmodel.EncryptorAPIDatabase)
func SetFedDomains(v *common.FedDomains)
func SetIDG(v *uid.UidGenerator)
func SetJoinRoomsRepo(repo *repos.JoinRoomsRepo)
func SetKeyDB(kdb dbmodel.KeyDatabase)
func SetLocalCache(lc service.LocalCache)
func SetPublicRoomsAPI(api publicroomsapi.PublicRoomsQueryAPI)
func SetRepo(repo *modelRepos.RoomServerCurStateRepo)
func SetRpcClient(rpcCli *common.RpcClient)
type FedApiEntryCB
type InviteWaitItem

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	FedApiFunc = make(map[model.Command]FedApiEntryCB)
)

Functions ¶

func Backfill ¶

func Backfill(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func ClaimClientKeys ¶

func ClaimClientKeys(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func EventAuth ¶

func EventAuth(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func GetAvatarURL ¶

func GetAvatarURL(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func GetDisplayName ¶

func GetDisplayName(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func GetProfile ¶

func GetProfile(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func GetPublicRooms ¶

func GetPublicRooms(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func GetUserInfo ¶

func GetUserInfo(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func Invite ¶

func Invite(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func MakeJoin ¶

func MakeJoin(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func MakeLeave ¶

func MakeLeave(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func NotaryNotice ¶

func NotaryNotice(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func PostPublicRooms ¶

func PostPublicRooms(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func QueryAuth ¶

func QueryAuth(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func QueryClientKeys ¶

func QueryClientKeys(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func QueryEvent ¶

func QueryEvent(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func QueryStateIDs ¶

func QueryStateIDs(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func Register ¶

func Register(cmd model.Command, f FedApiEntryCB)

func RoomDirectory ¶

func RoomDirectory(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func RoomState ¶

func RoomState(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func Send ¶

func Send(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func SendJoin ¶

func SendJoin(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func SendLeave ¶

func SendLeave(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

func SetBackFillProcessor ¶

func SetBackFillProcessor(p backfilltypes.BackFillProcessor)

func SetBackfillRepo ¶

func SetBackfillRepo(repo *repos.BackfillRepo)

func SetCert ¶

func SetCert(c *cert.Cert)

func SetCfg ¶

func SetCfg(v *config.Fed)

func SetComplexCache ¶

func SetComplexCache(cache *common.ComplexCache)

func SetEncryptionDB ¶

func SetEncryptionDB(db dbmodel.EncryptorAPIDatabase)

func SetFedDomains ¶

func SetFedDomains(v *common.FedDomains)

func SetIDG ¶

func SetIDG(v *uid.UidGenerator)

func SetJoinRoomsRepo ¶

func SetJoinRoomsRepo(repo *repos.JoinRoomsRepo)

func SetKeyDB ¶

func SetKeyDB(kdb dbmodel.KeyDatabase)

func SetLocalCache ¶

func SetLocalCache(lc service.LocalCache)

func SetPublicRoomsAPI ¶

func SetPublicRoomsAPI(api publicroomsapi.PublicRoomsQueryAPI)

func SetRepo ¶

func SetRepo(repo *modelRepos.RoomServerCurStateRepo)

func SetRpcClient ¶

func SetRpcClient(rpcCli *common.RpcClient)

Types ¶

type FedApiEntryCB ¶

type FedApiEntryCB func(ctx context.Context, msg *model.GobMessage, cache service.Cache, rpcCli roomserverapi.RoomserverRPCAPI, fedClient *client.FedClientWrap, db fedmodel.FederationDatabase) (*model.GobMessage, error)

type InviteWaitItem ¶

type InviteWaitItem struct {
	Event    *gomatrixserverlib.Event
	IsDelete int32
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL