Documentation ¶
Index ¶
- type EduSender
- func (e *EduSender) Clean()
- func (e *EduSender) GetCB() common.MsgHandlerWithContext
- func (e *EduSender) GetTopic() string
- func (e *EduSender) OnMessage(ctx context.Context, topic string, partition int32, data []byte, ...)
- func (e *EduSender) SetSender(sender *FederationSender)
- func (e *EduSender) Start() error
- type FedSendMsg
- type FederationDispatch
- type FederationSender
- func (c *FederationSender) AddConsumer(domain string) error
- func (c *FederationSender) AssignRoomPartition(ctx context.Context, roomID, domain string, retryTime time.Duration, ...) (*fedrepos.RecordItem, bool)
- func (c *FederationSender) HasAssgined(ctx context.Context, roomID, domain string) (*fedrepos.RecordItem, bool)
- func (c *FederationSender) OnMessage(ctx context.Context, topic string, partition int32, data []byte, ...)
- func (c *FederationSender) OnRoomDomainRelease(ctx context.Context, origin, roomID, domain string)
- func (c *FederationSender) SetRecRepo(repo *fedrepos.SendRecRepo)
- func (c *FederationSender) SetRsRepo(repo *repos.RoomServerCurStateRepo)
- func (c *FederationSender) Start()
- func (c *FederationSender) TryAssignRoomPartition(ctx context.Context, roomID, domain string) (*fedrepos.RecordItem, bool)
- func (c *FederationSender) UnassignRoomPartition(ctx context.Context, roomID, domain string)
- type ServerName
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EduSender ¶
type EduSender struct {
// contains filtered or unexported fields
}
func (*EduSender) GetCB ¶
func (e *EduSender) GetCB() common.MsgHandlerWithContext
func (*EduSender) SetSender ¶
func (e *EduSender) SetSender(sender *FederationSender)
type FedSendMsg ¶
type FedSendMsg struct {
// contains filtered or unexported fields
}
type FederationDispatch ¶
type FederationDispatch struct { Repo *repos.RoomServerCurStateRepo // contains filtered or unexported fields }
func NewFederationDispatch ¶
func NewFederationDispatch(cfg *config.Fed) *FederationDispatch
func (*FederationDispatch) SetRepo ¶
func (c *FederationDispatch) SetRepo(repo *repos.RoomServerCurStateRepo)
func (*FederationDispatch) SetSender ¶
func (c *FederationDispatch) SetSender(sender *FederationSender)
func (*FederationDispatch) Start ¶
func (c *FederationDispatch) Start() error
type FederationSender ¶
type FederationSender struct {
// contains filtered or unexported fields
}
func NewFederationSender ¶
func NewFederationSender(cfg *config.Fed, rpcClient *common.RpcClient, feddomains *common.FedDomains) *FederationSender
func (*FederationSender) AddConsumer ¶
func (c *FederationSender) AddConsumer(domain string) error
func (*FederationSender) AssignRoomPartition ¶
func (*FederationSender) HasAssgined ¶
func (c *FederationSender) HasAssgined(ctx context.Context, roomID, domain string) (*fedrepos.RecordItem, bool)
func (*FederationSender) OnRoomDomainRelease ¶
func (c *FederationSender) OnRoomDomainRelease(ctx context.Context, origin, roomID, domain string)
func (*FederationSender) SetRecRepo ¶
func (c *FederationSender) SetRecRepo(repo *fedrepos.SendRecRepo)
func (*FederationSender) SetRsRepo ¶
func (c *FederationSender) SetRsRepo(repo *repos.RoomServerCurStateRepo)
func (*FederationSender) Start ¶
func (c *FederationSender) Start()
func (*FederationSender) TryAssignRoomPartition ¶
func (c *FederationSender) TryAssignRoomPartition(ctx context.Context, roomID, domain string) (*fedrepos.RecordItem, bool)
func (*FederationSender) UnassignRoomPartition ¶
func (c *FederationSender) UnassignRoomPartition(ctx context.Context, roomID, domain string)
type ServerName ¶
type ServerName = gomatrixserverlib.ServerName
Click to show internal directories.
Click to hide internal directories.