msgservices

package

v0.0.0-...-4e281dc Latest Latest Go to latest Published: Dec 11, 2020 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cloudfresco/vilom-ms

Documentation ¶

Index ¶

func StartChannelServer(log *zap.Logger, isTest bool, pwd string, dbOpt *common.DBOptions, ...)
func StartMessageServer(log *zap.Logger, isTest bool, pwd string, dbOpt *common.DBOptions, ...)
func StartWorkspaceServer(log *zap.Logger, isTest bool, pwd string, dbOpt *common.DBOptions, ...)
type ChannelService
- func NewChannelService(log *zap.Logger, dbOpt *common.DBService, redisOpt *common.RedisService, ...) *ChannelService
type MessageService
- func NewMessageService(log *zap.Logger, dbOpt *common.DBService, redisOpt *common.RedisService, ...) *MessageService
type WorkspaceService
- func NewWorkspaceService(log *zap.Logger, dbOpt *common.DBService, redisOpt *common.RedisService, ...) *WorkspaceService

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL