loader

Documentation

Index

• type ConversationLoader
  • func NewConversationLoader(messageUsecase usecase.MessageUsecase) *ConversationLoader
  • func (l *ConversationLoader) LoadConversation(ctx context.Context, conversationID entity.ID) (*entity.Conversation, error)
  • func (l *ConversationLoader) LoadConversationIDsFromUser(ctx context.Context, input entity.RelayQueryInput) (*entity.IDsConnection, error)
  • func (l *ConversationLoader) LoadParticipantsInConversation(ctx context.Context, conversationID entity.ID) ([]*entity.User, error)
• type MessageLoader
  • func NewMessageLoader(messageFetcher usecase.MessageUsecase) *MessageLoader
  • func (l *MessageLoader) LoadMessagesInConversation(ctx context.Context, input entity.RelayQueryInput) (*entity.ConversationMessagesConnection, error)
• type UserLoader
  • func NewUserLoader(userFetcher usecase.UserUsecase) *UserLoader
  • func (l *UserLoader) LoadFriendIDs(ctx context.Context, input entity.RelayQueryInput) (*entity.IDsConnection, error)
  • func (l *UserLoader) LoadUser(ctx context.Context, userID entity.ID) (*entity.User, error)

Types

type ConversationLoader

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

func NewConversationLoader

func NewConversationLoader(
	messageUsecase usecase.MessageUsecase,
) *ConversationLoader

func (*ConversationLoader) LoadConversation

func (l *ConversationLoader) LoadConversation(
	ctx context.Context,
	conversationID entity.ID,
) (*entity.Conversation, error)

func (*ConversationLoader) LoadConversationIDsFromUser

func (l *ConversationLoader) LoadConversationIDsFromUser(ctx context.Context,
	input entity.RelayQueryInput) (*entity.IDsConnection, error)

func (*ConversationLoader) LoadParticipantsInConversation

func (l *ConversationLoader) LoadParticipantsInConversation(ctx context.Context,
	conversationID entity.ID) ([]*entity.User, error)

type MessageLoader

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

func NewMessageLoader

func NewMessageLoader(
	messageFetcher usecase.MessageUsecase,
) *MessageLoader

func (*MessageLoader) LoadMessagesInConversation

func (l *MessageLoader) LoadMessagesInConversation(
	ctx context.Context,
	input entity.RelayQueryInput,
) (*entity.ConversationMessagesConnection, error)

type UserLoader

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

func NewUserLoader

func NewUserLoader(
	userFetcher usecase.UserUsecase,
) *UserLoader

func (*UserLoader) LoadFriendIDs

func (l *UserLoader) LoadFriendIDs(ctx context.Context,
	input entity.RelayQueryInput) (*entity.IDsConnection, error)

func (*UserLoader) LoadUser

func (l *UserLoader) LoadUser(
	ctx context.Context,
	userID entity.ID,
) (*entity.User, error)