base

Documentation

Index

• Constants
• type BaseDendrite
  • func NewBaseDendrite(cfg *config.Dendrite, componentName string, options ...BaseDendriteOptions) *BaseDendrite
  • func (b *BaseDendrite) AppserviceHTTPClient() appserviceAPI.AppServiceQueryAPI
  • func (b *BaseDendrite) Close() error
  • func (b *BaseDendrite) CreateAccountsDB() accounts.Database
  • func (b *BaseDendrite) CreateClient() *gomatrixserverlib.Client
  • func (b *BaseDendrite) CreateFederationClient() *gomatrixserverlib.FederationClient
  • func (b *BaseDendrite) EDUServerClient() eduServerAPI.EDUServerInputAPI
  • func (b *BaseDendrite) FederationAPIHTTPClient() federationAPI.FederationInternalAPI
  • func (b *BaseDendrite) KeyServerHTTPClient() keyserverAPI.KeyInternalAPI
  • func (b *BaseDendrite) RoomserverHTTPClient() roomserverAPI.RoomserverInternalAPI
  • func (b *BaseDendrite) SetupAndServeHTTP(internalHTTPAddr, externalHTTPAddr config.HTTPAddress, ...)
  • func (b *BaseDendrite) UserAPIClient() userapi.UserInternalAPI
  • func (b *BaseDendrite) WaitForShutdown()
• type BaseDendriteOptions

Constants

const HTTPClientTimeout = time.Second * 30

const HTTPServerTimeout = time.Minute * 5

const NoListener = ""

Types

type BaseDendrite

type BaseDendrite struct {
	*process.ProcessContext

	PublicClientAPIMux     *mux.Router
	PublicFederationAPIMux *mux.Router
	PublicKeyAPIMux        *mux.Router
	PublicMediaAPIMux      *mux.Router
	PublicWellKnownAPIMux  *mux.Router
	InternalAPIMux         *mux.Router
	SynapseAdminMux        *mux.Router
	UseHTTPAPIs            bool

	Cfg      *config.Dendrite
	Caches   *caching.Caches
	DNSCache *gomatrixserverlib.DNSCache
	// contains filtered or unexported fields
}

BaseDendrite is a base for creating new instances of dendrite. It parses command line flags and config, and exposes methods for creating various resources. All errors are handled by logging then exiting, so all methods should only be used during start up. Must be closed when shutting down.

func NewBaseDendrite

func NewBaseDendrite(cfg *config.Dendrite, componentName string, options ...BaseDendriteOptions) *BaseDendrite

NewBaseDendrite creates a new instance to be used by a component. The componentName is used for logging purposes, and should be a friendly name of the compontent running, e.g. "SyncAPI"

func (*BaseDendrite) AppserviceHTTPClient

func (b *BaseDendrite) AppserviceHTTPClient() appserviceAPI.AppServiceQueryAPI

AppserviceHTTPClient returns the AppServiceQueryAPI for hitting the appservice component over HTTP.

func (*BaseDendrite) Close

func (b *BaseDendrite) Close() error

Close implements io.Closer

func (*BaseDendrite) CreateAccountsDB

func (b *BaseDendrite) CreateAccountsDB() accounts.Database

CreateAccountsDB creates a new instance of the accounts database. Should only be called once per component.

func (*BaseDendrite) CreateClient

func (b *BaseDendrite) CreateClient() *gomatrixserverlib.Client

CreateClient creates a new client (normally used for media fetch requests). Should only be called once per component.

func (*BaseDendrite) CreateFederationClient

func (b *BaseDendrite) CreateFederationClient() *gomatrixserverlib.FederationClient

CreateFederationClient creates a new federation client. Should only be called once per component.

func (*BaseDendrite) EDUServerClient

func (b *BaseDendrite) EDUServerClient() eduServerAPI.EDUServerInputAPI

EDUServerClient returns EDUServerInputAPI for hitting the EDU server over HTTP

func (*BaseDendrite) FederationAPIHTTPClient

func (b *BaseDendrite) FederationAPIHTTPClient() federationAPI.FederationInternalAPI

FederationAPIHTTPClient returns FederationInternalAPI for hitting the federation API server over HTTP

func (*BaseDendrite) KeyServerHTTPClient

func (b *BaseDendrite) KeyServerHTTPClient() keyserverAPI.KeyInternalAPI

KeyServerHTTPClient returns KeyInternalAPI for hitting the key server over HTTP

func (*BaseDendrite) RoomserverHTTPClient

func (b *BaseDendrite) RoomserverHTTPClient() roomserverAPI.RoomserverInternalAPI

RoomserverHTTPClient returns RoomserverInternalAPI for hitting the roomserver over HTTP.

func (*BaseDendrite) SetupAndServeHTTP

func (b *BaseDendrite) SetupAndServeHTTP(
	internalHTTPAddr, externalHTTPAddr config.HTTPAddress,
	certFile, keyFile *string,
)

SetupAndServeHTTP sets up the HTTP server to serve endpoints registered on ApiMux under /api/ and adds a prometheus handler under /metrics.

func (*BaseDendrite) UserAPIClient

func (b *BaseDendrite) UserAPIClient() userapi.UserInternalAPI

UserAPIClient returns UserInternalAPI for hitting the userapi over HTTP.

func (*BaseDendrite) WaitForShutdown

func (b *BaseDendrite) WaitForShutdown()

type BaseDendriteOptions

type BaseDendriteOptions int

const (
	NoCacheMetrics BaseDendriteOptions = iota
	UseHTTPAPIs
)