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: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EventRpcConsumer 

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

func NewEventRpcConsumer 

func NewEventRpcConsumer(
	rpcClient *common.RpcClient,
	userTimeLine *repos.UserTimeLineRepo,
	syncDB model.SyncAPIDatabase,
	cfg *config.Dendrite,
) *EventRpcConsumer

func (*EventRpcConsumer) GetTopic 

func (s *EventRpcConsumer) GetTopic() string

func (*EventRpcConsumer) Start 

func (s *EventRpcConsumer) Start() error

type JoinedRoomRpcConsumer 

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

func NewJoinedRoomRpcConsumer 

func NewJoinedRoomRpcConsumer(
	rpcClient *common.RpcClient,
	userTimeLine *repos.UserTimeLineRepo,
	cfg *config.Dendrite,
) *JoinedRoomRpcConsumer

func (*JoinedRoomRpcConsumer) GetTopic 

func (s *JoinedRoomRpcConsumer) GetTopic() string

func (*JoinedRoomRpcConsumer) Start 

func (s *JoinedRoomRpcConsumer) Start() error

type KeyChangeRpcConsumer 

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

func NewKeyChangeRpcConsumer 

func NewKeyChangeRpcConsumer(
	keyChangeRepo *repos.KeyChangeStreamRepo,
	userTimeLine *repos.UserTimeLineRepo,
	rpcClient *common.RpcClient,
	cfg *config.Dendrite,
) *KeyChangeRpcConsumer

func (*KeyChangeRpcConsumer) GetTopic 

func (s *KeyChangeRpcConsumer) GetTopic() string

func (*KeyChangeRpcConsumer) Start 

func (s *KeyChangeRpcConsumer) Start() error

type KeyUpdateRpcConsumer 

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

func NewKeyUpdateRpcConsumer 

func NewKeyUpdateRpcConsumer(
	keyChangeRepo *repos.KeyChangeStreamRepo,
	rpcClient *common.RpcClient,
	cfg *config.Dendrite,
) *KeyUpdateRpcConsumer

func (*KeyUpdateRpcConsumer) GetTopic 

func (s *KeyUpdateRpcConsumer) GetTopic() string

func (*KeyUpdateRpcConsumer) Start 

func (s *KeyUpdateRpcConsumer) Start() error

type PresenceRpcConsumer 

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

func NewPresenceRpcConsumer 

func NewPresenceRpcConsumer(
	rpcClient *common.RpcClient,
	olRepo *repos.OnlineUserRepo,
	presenceRepo *repos.PresenceDataStreamRepo,
	cfg *config.Dendrite,
) *PresenceRpcConsumer

func (*PresenceRpcConsumer) Clean 

func (s *PresenceRpcConsumer) Clean()

func (*PresenceRpcConsumer) GetCB 

func (s *PresenceRpcConsumer) GetCB() common.MsgHandlerWithContext

func (*PresenceRpcConsumer) GetTopic 

func (s *PresenceRpcConsumer) GetTopic() string

func (*PresenceRpcConsumer) Start 

func (s *PresenceRpcConsumer) Start() error

type ReceiptUpdateRpcConsumer 

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

func NewReceiptUpdateRpcConsumer 

func NewReceiptUpdateRpcConsumer(
	userTimeLine *repos.UserTimeLineRepo,
	rpcClient *common.RpcClient,
	cfg *config.Dendrite,
) *ReceiptUpdateRpcConsumer

func (*ReceiptUpdateRpcConsumer) GetTopic 

func (s *ReceiptUpdateRpcConsumer) GetTopic() string

func (*ReceiptUpdateRpcConsumer) Start 

func (s *ReceiptUpdateRpcConsumer) Start() error

type StdRpcConsumer 

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

func NewStdRpcConsumer 

func NewStdRpcConsumer(
	rpcClient *common.RpcClient,
	stdEventTimeline *repos.STDEventStreamRepo,
	cache service.Cache,
	syncDB model.SyncAPIDatabase,
	cfg *config.Dendrite,
) *StdRpcConsumer

func (*StdRpcConsumer) Clean 

func (s *StdRpcConsumer) Clean()

func (*StdRpcConsumer) GetCB 

func (s *StdRpcConsumer) GetCB() common.MsgHandlerWithContext

func (*StdRpcConsumer) GetTopic 

func (s *StdRpcConsumer) GetTopic() string

func (*StdRpcConsumer) Start 

func (s *StdRpcConsumer) Start() error

type SyncRpcConsumer 

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

func NewSyncRpcConsumer 

func NewSyncRpcConsumer(
	rpcClient *common.RpcClient,
	sm *sync.SyncMng,
	cfg *config.Dendrite,
) *SyncRpcConsumer

func (*SyncRpcConsumer) Clean 

func (s *SyncRpcConsumer) Clean()

func (*SyncRpcConsumer) GetCB 

func (s *SyncRpcConsumer) GetCB() common.MsgHandlerWithContext

func (*SyncRpcConsumer) GetTopic 

func (s *SyncRpcConsumer) GetTopic() string

func (*SyncRpcConsumer) Start 

func (s *SyncRpcConsumer) Start() error

type TypingRpcConsumer 

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

func NewTypingRpcConsumer 

func NewTypingRpcConsumer(
	consumer *consumers.TypingConsumer,
	rpcClient *common.RpcClient,
	cfg *config.Dendrite,
) *TypingRpcConsumer

func (*TypingRpcConsumer) GetTopic 

func (s *TypingRpcConsumer) GetTopic() string

func (*TypingRpcConsumer) Start 

func (s *TypingRpcConsumer) Start() error

type UnReadRpcConsumer 

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

func NewUnReadRpcConsumer 

func NewUnReadRpcConsumer(
	rpcClient *common.RpcClient,
	userTimeLine *repos.UserTimeLineRepo,
	cfg *config.Dendrite,
) *UnReadRpcConsumer

func (*UnReadRpcConsumer) GetTopic 

func (s *UnReadRpcConsumer) GetTopic() string

func (*UnReadRpcConsumer) Start 

func (s *UnReadRpcConsumer) Start() error

type UpdateReceiptOffset 

type UpdateReceiptOffset struct {
	Users  []string
	Offset int64
}

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.