logic

Documentation

Index

• func GetIp() (ipStr string, err error)
• type CloseSessionLogic
  • func NewCloseSessionLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CloseSessionLogic
  • func (l *CloseSessionLogic) CloseSession(in *gotalk.RequestWithSessionId) (*gotalk.ResponseUser, error)
• type HealthLogic
  • func NewHealthLogic(ctx context.Context, svcCtx *svc.ServiceContext) *HealthLogic
  • func (l *HealthLogic) Health(_ *gotalk.RequestHealthCheck) (*gotalk.ResponseHealthCheck, error)
• type HiLogic
  • func NewHiLogic(ctx context.Context, svcCtx *svc.ServiceContext) *HiLogic
  • func (l *HiLogic) Hi(_ *gotalk.Request) (*gotalk.Response, error)
• type ListenerLogic
  • func NewListenerLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ListenerLogic
  • func (l *ListenerLogic) Listener(in *gotalk.SessionId, stream gotalk.ChatService_ListenerServer) error
• type SendLogic
  • func NewSendLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SendLogic
  • func (l *SendLogic) Send(stream gotalk.ChatService_SendServer) error
• type SessionLogic
  • func GetSessionLogic() *SessionLogic
  • func (sessionLogic *SessionLogic) CloseSession(req *gotalk.RequestWithSessionId) (resp *gotalk.ResponseUser, err error)
  • func (sessionLogic *SessionLogic) StartSession(req *gotalk.RequestWithUserName) (resp *gotalk.ResponseWithSessionId, err error)
• type StartSessionLogic
  • func NewStartSessionLogic(ctx context.Context, svcCtx *svc.ServiceContext) *StartSessionLogic
  • func (l *StartSessionLogic) StartSession(in *gotalk.RequestWithUserName) (*gotalk.ResponseWithSessionId, error)
• type UsersLogic
  • func NewUsersLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UsersLogic
  • func (l *UsersLogic) Users(_ *gotalk.RequestUser) (*gotalk.ResponseUsers, error)

Functions

func GetIp

func GetIp() (ipStr string, err error)

Types

type CloseSessionLogic

type CloseSessionLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewCloseSessionLogic

func NewCloseSessionLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CloseSessionLogic

func (*CloseSessionLogic) CloseSession

func (l *CloseSessionLogic) CloseSession(in *gotalk.RequestWithSessionId) (*gotalk.ResponseUser, error)

type HealthLogic

type HealthLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewHealthLogic

func NewHealthLogic(ctx context.Context, svcCtx *svc.ServiceContext) *HealthLogic

func (*HealthLogic) Health

func (l *HealthLogic) Health(_ *gotalk.RequestHealthCheck) (*gotalk.ResponseHealthCheck, error)

type HiLogic

type HiLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewHiLogic

func NewHiLogic(ctx context.Context, svcCtx *svc.ServiceContext) *HiLogic

func (*HiLogic) Hi

func (l *HiLogic) Hi(_ *gotalk.Request) (*gotalk.Response, error)

type ListenerLogic

type ListenerLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewListenerLogic

func NewListenerLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ListenerLogic

func (*ListenerLogic) Listener

func (l *ListenerLogic) Listener(in *gotalk.SessionId, stream gotalk.ChatService_ListenerServer) error

type SendLogic

type SendLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewSendLogic

func NewSendLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SendLogic

func (*SendLogic) Send

func (l *SendLogic) Send(stream gotalk.ChatService_SendServer) error

type SessionLogic

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

func GetSessionLogic

func GetSessionLogic() *SessionLogic

func (*SessionLogic) CloseSession

func (sessionLogic *SessionLogic) CloseSession(req *gotalk.RequestWithSessionId) (resp *gotalk.ResponseUser, err error)

func (*SessionLogic) StartSession

func (sessionLogic *SessionLogic) StartSession(req *gotalk.RequestWithUserName) (resp *gotalk.ResponseWithSessionId, err error)

type StartSessionLogic

type StartSessionLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewStartSessionLogic

func NewStartSessionLogic(ctx context.Context, svcCtx *svc.ServiceContext) *StartSessionLogic

func (*StartSessionLogic) StartSession

func (l *StartSessionLogic) StartSession(in *gotalk.RequestWithUserName) (*gotalk.ResponseWithSessionId, error)

type UsersLogic

type UsersLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewUsersLogic

func NewUsersLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UsersLogic

func (*UsersLogic) Users

func (l *UsersLogic) Users(_ *gotalk.RequestUser) (*gotalk.ResponseUsers, error)