msgservices

package
v0.0.0-...-4e281dc Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 11, 2020 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func StartChannelServer 

func StartChannelServer(log *zap.Logger, isTest bool, pwd string, dbOpt *common.DBOptions, redisOpt *common.RedisOptions, mailerOpt *common.MailerOptions, grpcServerOpt *common.GrpcServerOptions, jwtOpt *common.JWTOptions, oauthOpt *common.OauthOptions, userOpt *common.UserOptions, jaegerTracerOpt *common.JaegerTracerOptions, promOpt *common.PromOptions, elasticOpt *common.ElasticOptions, roleOpt *common.RoleOptions, dbService *common.DBService, redisService *common.RedisService, mailerService common.MailerIntf)

StartChannelServer - Start Channel Server

func StartMessageServer 

func StartMessageServer(log *zap.Logger, isTest bool, pwd string, dbOpt *common.DBOptions, redisOpt *common.RedisOptions, mailerOpt *common.MailerOptions, grpcServerOpt *common.GrpcServerOptions, jwtOpt *common.JWTOptions, oauthOpt *common.OauthOptions, userOpt *common.UserOptions, jaegerTracerOpt *common.JaegerTracerOptions, promOpt *common.PromOptions, elasticOpt *common.ElasticOptions, roleOpt *common.RoleOptions, dbService *common.DBService, redisService *common.RedisService, mailerService common.MailerIntf)

StartMessageServer - Start Message Server

func StartWorkspaceServer 

func StartWorkspaceServer(log *zap.Logger, isTest bool, pwd string, dbOpt *common.DBOptions, redisOpt *common.RedisOptions, mailerOpt *common.MailerOptions, grpcServerOpt *common.GrpcServerOptions, jwtOpt *common.JWTOptions, oauthOpt *common.OauthOptions, userOpt *common.UserOptions, jaegerTracerOpt *common.JaegerTracerOptions, promOpt *common.PromOptions, elasticOpt *common.ElasticOptions, roleOpt *common.RoleOptions, dbService *common.DBService, redisService *common.RedisService, mailerService common.MailerIntf)

StartWorkspaceServer - Start Workspace server

Types

type ChannelService 

type ChannelService struct {
	DBService         *common.DBService
	RedisService      *common.RedisService
	UserServiceClient userproto.UserServiceClient
	msgproto.UnimplementedChannelServiceServer
	// contains filtered or unexported fields
}

ChannelService - For accessing channel services

func NewChannelService 

func NewChannelService(log *zap.Logger, dbOpt *common.DBService, redisOpt *common.RedisService, userServiceClient userproto.UserServiceClient) *ChannelService

NewChannelService - Create channel service

func (*ChannelService) CreateChannel 

func (t *ChannelService) CreateChannel(ctx context.Context, in *msgproto.CreateChannelRequest) (*msgproto.Channel, error)

CreateChannel - Create channel

func (*ChannelService) DeleteChannel 

func (t *ChannelService) DeleteChannel(ctx context.Context, in *commonproto.GetRequest) (*commonproto.Empty, error)

DeleteChannel - Delete channel

func (*ChannelService) GetChannel 

func (t *ChannelService) GetChannel(ctx context.Context, in *commonproto.GetRequest) (*msgproto.Channel, error)

GetChannel - Get channel

func (*ChannelService) GetChannelByName 

func (t *ChannelService) GetChannelByName(ctx context.Context, in *msgproto.GetChannelByNameRequest) (*msgproto.Channel, error)

GetChannelByName - Get channel by name

func (*ChannelService) GetChannelByPk 

func (t *ChannelService) GetChannelByPk(ctx context.Context, in *commonproto.GetByIdRequest) (*msgproto.Channel, error)

GetChannelByPk - Get channel by Primary Key(Id)

func (*ChannelService) GetChannelMessages 

func (t *ChannelService) GetChannelMessages(ctx context.Context, in *msgproto.GetChannelMessagesRequest) (*msgproto.Channel, error)

GetChannelMessages - get channel with messages

func (*ChannelService) GetChannelWithMessages 

func (t *ChannelService) GetChannelWithMessages(ctx context.Context, in *commonproto.GetRequest) (*msgproto.Channel, error)

GetChannelWithMessages - Get channel with messages

func (*ChannelService) GetChannelsUser 

func (t *ChannelService) GetChannelsUser(ctx context.Context, in *msgproto.GetChannelsUserRequest) (*msgproto.ChannelsUser, error)

GetChannelsUser - Get user channels

func (*ChannelService) ShowChannel 

func (t *ChannelService) ShowChannel(ctx context.Context, in *msgproto.GetChannelRequest) (*msgproto.Channel, error)

ShowChannel - Get channel details

func (*ChannelService) UpdateChannel 

func (t *ChannelService) UpdateChannel(ctx context.Context, in *msgproto.UpdateChannelRequest) (*commonproto.Empty, error)

UpdateChannel - Update channel

type MessageService 

type MessageService struct {
	DBService         *common.DBService
	RedisService      *common.RedisService
	UserServiceClient userproto.UserServiceClient
	msgproto.UnimplementedMessageServiceServer
	// contains filtered or unexported fields
}

MessageService - For accessing message services

func NewMessageService 

func NewMessageService(log *zap.Logger, dbOpt *common.DBService, redisOpt *common.RedisService, userServiceClient userproto.UserServiceClient) *MessageService

NewMessageService - Create message service

func (*MessageService) CreateMessage 

func (m *MessageService) CreateMessage(ctx context.Context, in *msgproto.CreateMessageRequest) (*msgproto.Message, error)

CreateMessage - Create message

func (*MessageService) CreateUserLike 

func (m *MessageService) CreateUserLike(ctx context.Context, in *msgproto.UserLikeRequest) (*msgproto.UserLike, error)

CreateUserLike - Create user likes messages

func (*MessageService) CreateUserVote 

func (m *MessageService) CreateUserVote(ctx context.Context, in *msgproto.UserVoteRequest) (*msgproto.UserVote, error)

CreateUserVote - Create User Vote

func (*MessageService) DeleteMessage 

func (m *MessageService) DeleteMessage(ctx context.Context, in *commonproto.GetRequest) (*commonproto.Empty, error)

DeleteMessage - Delete message

func (*MessageService) GetMessage 

func (m *MessageService) GetMessage(ctx context.Context, in *commonproto.GetRequest) (*msgproto.Message, error)

GetMessage - Get message

func (*MessageService) GetMessageAttachments 

func (m *MessageService) GetMessageAttachments(ctx context.Context, in *msgproto.GetMessagesTextsRequest) (*msgproto.MessageAttachments, error)

GetMessageAttachments - get message attachements

func (*MessageService) GetMessagesTexts 

func (m *MessageService) GetMessagesTexts(ctx context.Context, in *msgproto.GetMessagesTextsRequest) (*msgproto.MessageTexts, error)

GetMessagesTexts - get message texts

func (*MessageService) GetMessagesWithTextAttach 

func (m *MessageService) GetMessagesWithTextAttach(ctx context.Context, in *msgproto.GetMessagesWithTextAttachRequest) (*msgproto.Messages, error)

GetMessagesWithTextAttach - Get messages with attachements

func (*MessageService) UpdateMessage 

func (m *MessageService) UpdateMessage(ctx context.Context, in *msgproto.UpdateMessageRequest) (*commonproto.Empty, error)

UpdateMessage - Update message

type WorkspaceService 

type WorkspaceService struct {
	DBService         *common.DBService
	RedisService      *common.RedisService
	UserServiceClient userproto.UserServiceClient
	msgproto.UnimplementedWorkspaceServiceServer
	// contains filtered or unexported fields
}

WorkspaceService - For accessing workspace services

func NewWorkspaceService 

func NewWorkspaceService(log *zap.Logger, dbOpt *common.DBService, redisOpt *common.RedisService, userServiceClient userproto.UserServiceClient) *WorkspaceService

NewWorkspaceService - Create workspace service

func (*WorkspaceService) CreateChild 

func (c *WorkspaceService) CreateChild(ctx context.Context, in *msgproto.CreateWorkspaceRequest) (*msgproto.Workspace, error)

CreateChild - Create Child Workspace

func (*WorkspaceService) CreateWorkspace 

func (c *WorkspaceService) CreateWorkspace(ctx context.Context, in *msgproto.CreateWorkspaceRequest) (*msgproto.Workspace, error)

CreateWorkspace - Create Workspace

func (*WorkspaceService) DeleteWorkspace 

func (c *WorkspaceService) DeleteWorkspace(ctx context.Context, in *commonproto.GetRequest) (*commonproto.Empty, error)

DeleteWorkspace - Delete workspace

func (*WorkspaceService) GetChildWorkspaces 

func (c *WorkspaceService) GetChildWorkspaces(ctx context.Context, in *commonproto.GetRequest) (*msgproto.Workspaces, error)

GetChildWorkspaces - Get child Workspaces

func (*WorkspaceService) GetParentWorkspace 

func (c *WorkspaceService) GetParentWorkspace(ctx context.Context, in *commonproto.GetRequest) (*msgproto.Workspace, error)

GetParentWorkspace - Get Parent Workspace

func (*WorkspaceService) GetTopLevelWorkspaces 

func (c *WorkspaceService) GetTopLevelWorkspaces(ctx context.Context, in *msgproto.GetTopLevelWorkspacesRequest) (*msgproto.Workspaces, error)

GetTopLevelWorkspaces - Get top level Workspaces

func (*WorkspaceService) GetWorkspace 

func (c *WorkspaceService) GetWorkspace(ctx context.Context, in *commonproto.GetRequest) (*msgproto.Workspace, error)

GetWorkspace - Get Workspace

func (*WorkspaceService) GetWorkspaceByPk 

func (c *WorkspaceService) GetWorkspaceByPk(ctx context.Context, in *commonproto.GetByIdRequest) (*msgproto.Workspace, error)

GetWorkspaceByPk - Get Workspace By Primary key(Id)

func (*WorkspaceService) GetWorkspaceWithChannels 

func (c *WorkspaceService) GetWorkspaceWithChannels(ctx context.Context, in *commonproto.GetRequest) (*msgproto.Workspace, error)

GetWorkspaceWithChannels - Get workspace with channels

func (*WorkspaceService) GetWorkspaces 

func (c *WorkspaceService) GetWorkspaces(ctx context.Context, in *msgproto.GetWorkspacesRequest) (*msgproto.WorkspaceCursor, error)

GetWorkspaces - Get Workspaces

func (*WorkspaceService) UpdateWorkspace 

func (c *WorkspaceService) UpdateWorkspace(ctx context.Context, in *msgproto.UpdateWorkspaceRequest) (*commonproto.Empty, error)

UpdateWorkspace - Update workspace

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.