pools

package
v0.0.0-...-52fa7fc Latest Latest
Warning

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

 Go to latest Published: Feb 17, 2025 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Pool pool

pool to handle operators'es subscriptions

Functions

func ToAgentColorResponse 

func ToAgentColorResponse(agent *ent.Agent) *operatorv1.AgentColorResponse

ToAgentColorResponse converts DB model Agent to protobuf AgentColorResponse

func ToAgentLastResponse 

func ToAgentLastResponse(agent *ent.Agent) *operatorv1.AgentLastResponse

ToAgentLastResponse converts DB model Agent to protobuf AgentLastResponse

func ToAgentNoteResponse 

func ToAgentNoteResponse(agent *ent.Agent) *operatorv1.AgentNoteResponse

ToAgentNoteResponse converts DB model Agent to protobuf AgentColorResponse

func ToAgentResponse 

func ToAgentResponse(agent *ent.Agent) (*operatorv1.AgentResponse, error)

ToAgentResponse converts DB model Agent to protobuf AgentResponse

func ToAgentsResponse 

func ToAgentsResponse(agents []*ent.Agent) *operatorv1.AgentsResponse

ToAgentsResponse converts list of DB model Agent to protobuf AgentsResponse

func ToChatMessageResponse 

func ToChatMessageResponse(chatMessage *ent.Chat) (*operatorv1.ChatResponse, error)

ToChatMessageResponse converts DB model Chat to protobuf ChatResponse

func ToChatMessagesResponse 

func ToChatMessagesResponse(chatMessages []*ent.Chat) *operatorv1.ChatMessagesResponse

ToChatMessagesResponse converts list of DB model Chat to ChatMessagesResponse

func ToCredentialColorResponse 

func ToCredentialColorResponse(credential *ent.Credential) *operatorv1.CredentialColorResponse

ToCredentialColorResponse converts DB model Credential to protobuf CredentialColorResponse

func ToCredentialNoteResponse 

func ToCredentialNoteResponse(credential *ent.Credential) *operatorv1.CredentialNoteResponse

ToCredentialNoteResponse converts DB model Credential to protobuf CredentialNoteResponse

func ToCredentialResponse 

func ToCredentialResponse(credential *ent.Credential) *operatorv1.CredentialResponse

ToCredentialResponse converts DB model Credential to CredentialResponse

func ToCredentialsResponse 

func ToCredentialsResponse(credentials []*ent.Credential) *operatorv1.CredentialsResponse

ToCredentialsResponse converts list of DB model Credential to CredentialsResponse

func ToListenerColorResponse 

func ToListenerColorResponse(listener *ent.Listener) *operatorv1.ListenerColorResponse

ToListenerColorResponse converts DB model Listener to protobuf ListenerColorResponse

func ToListenerInfoResponse 

func ToListenerInfoResponse(listener *ent.Listener) *operatorv1.ListenerInfoResponse

ToListenerInfoResponse converts DB model Listener to protobuf ListenerInfoResponse

func ToListenerNoteResponse 

func ToListenerNoteResponse(listener *ent.Listener) *operatorv1.ListenerNoteResponse

ToListenerNoteResponse converts DB model Listener to protobuf ListenerNoteResponse

func ToListenerResponse 

func ToListenerResponse(listener *ent.Listener) *operatorv1.ListenerResponse

ToListenerResponse converts DB model Listener to protobuf ListenerResponse

func ToListenersResponse 

func ToListenersResponse(listeners []*ent.Listener) *operatorv1.ListenersResponse

ToListenersResponse converts list of DB models Listener to protobuf ListenersResponse

func ToOperatorColorResponse 

func ToOperatorColorResponse(operator *ent.Operator) *operatorv1.OperatorColorResponse

ToOperatorColorResponse converts DB model Operator to protobuf OperatorColorResponse

func ToOperatorResponse 

func ToOperatorResponse(operator *ent.Operator) *operatorv1.OperatorResponse

ToOperatorResponse converts DB model Operator to protobuf OperatorResponse

func ToOperatorsResponse 

func ToOperatorsResponse(operators []*ent.Operator) *operatorv1.OperatorsResponse

ToOperatorsResponse converts list of DB model Operator to protobuf OperatorsResponse

Types

type PoolAgents 

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

func (*PoolAgents) Add 

func (p *PoolAgents) Add(cookie, username string, stream operatorv1.OperatorService_SubscribeAgentsServer)

Add adds operator's stream to pool

func (*PoolAgents) Disconnect 

func (p *PoolAgents) Disconnect(cookie string)

Disconnect notify about necessity of operator's disconnection

func (*PoolAgents) Exists 

func (p *PoolAgents) Exists(username string) bool

Exists check if operator exists in pool by its username

func (*PoolAgents) Get 

func (p *PoolAgents) Get(cookie string) *SubscribeAgents

Get returns operator's subscription object

func (*PoolAgents) Remove 

func (p *PoolAgents) Remove(cookie string)

Remove removes operator's stream from pool

func (*PoolAgents) Send 

func (p *PoolAgents) Send(val any)

Send sends proto message to subscribed operators

type PoolChat 

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

func (*PoolChat) Add 

func (p *PoolChat) Add(cookie, username string, stream operatorv1.OperatorService_SubscribeChatServer)

Add adds operator's stream to pool

func (*PoolChat) Disconnect 

func (p *PoolChat) Disconnect(cookie string)

Disconnect notify about necessity of operator's disconnection

func (*PoolChat) Exists 

func (p *PoolChat) Exists(username string) bool

Exists check if operator exists in pool by its username

func (*PoolChat) Get 

func (p *PoolChat) Get(cookie string) *SubscribeChat

Get returns operator's subscription object

func (*PoolChat) Remove 

func (p *PoolChat) Remove(cookie string)

Remove removes operator's stream from pool

func (*PoolChat) Send 

func (p *PoolChat) Send(val any)

Send sends proto message to subscribed operators

type PoolCredentials 

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

func (*PoolCredentials) Add 

func (p *PoolCredentials) Add(cookie, username string, stream operatorv1.OperatorService_SubscribeCredentialsServer)

Add adds operator's stream to pool

func (*PoolCredentials) Disconnect 

func (p *PoolCredentials) Disconnect(cookie string)

Disconnect notify about necessity of operator's disconnection

func (*PoolCredentials) Exists 

func (p *PoolCredentials) Exists(username string) bool

Exists check if operator exists in pool by its username

func (*PoolCredentials) Get 

func (p *PoolCredentials) Get(cookie string) *SubscribeCredentials

Get returns operator's subscription object

func (*PoolCredentials) Remove 

func (p *PoolCredentials) Remove(cookie string)

Remove removes operator's stream from pool

func (*PoolCredentials) Send 

func (p *PoolCredentials) Send(val any)

Send sends proto message to subscribed operators

type PoolHello 

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

func (*PoolHello) Add 

func (p *PoolHello) Add(cookie, username string, stream operatorv1.OperatorService_HelloServer)

Add adds operator's stream to pool

func (*PoolHello) Exists 

func (p *PoolHello) Exists(username string) bool

Exists check if operator exists in pool by its username

func (*PoolHello) Remove 

func (p *PoolHello) Remove(cookie string)

Remove removes operator's stream from pool

func (*PoolHello) Validate 

func (p *PoolHello) Validate(username, cookie string) bool

Validate checks if supplied by operator cookie is valid and stores in pool

type PoolListeners 

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

func (*PoolListeners) Add 

func (p *PoolListeners) Add(cookie, username string, stream operatorv1.OperatorService_SubscribeListenersServer)

Add adds operator's stream to pool

func (*PoolListeners) Disconnect 

func (p *PoolListeners) Disconnect(cookie string)

Disconnect notify about necessity of operator's disconnection

func (*PoolListeners) Exists 

func (p *PoolListeners) Exists(username string) bool

Exists check if operator exists in pool by its username

func (*PoolListeners) Get 

func (p *PoolListeners) Get(cookie string) *SubscribeListeners

Get returns operator's subscription object

func (*PoolListeners) Remove 

func (p *PoolListeners) Remove(cookie string)

Remove removes operator's stream from pool

func (*PoolListeners) Send 

func (p *PoolListeners) Send(val any)

Send sends proto message to subscribed operators

type PoolOperators 

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

func (*PoolOperators) Add 

func (p *PoolOperators) Add(cookie, username string, stream operatorv1.OperatorService_SubscribeOperatorsServer)

Add adds operator's stream to pool

func (*PoolOperators) Disconnect 

func (p *PoolOperators) Disconnect(cookie string)

Disconnect notify about necessity of operator's disconnection

func (*PoolOperators) Exists 

func (p *PoolOperators) Exists(username string) bool

Exists check if operator exists in pool by its username

func (*PoolOperators) Get 

func (p *PoolOperators) Get(cookie string) *SubscribeOperators

Get returns operator's subscription object

func (*PoolOperators) Remove 

func (p *PoolOperators) Remove(cookie string)

Remove removes operator's stream from pool

func (*PoolOperators) Send 

func (p *PoolOperators) Send(val any)

Send sends proto message to subscribed operators

type PoolTasks 

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

func (*PoolTasks) Add 

func (p *PoolTasks) Add(cookie, username string, stream operatorv1.OperatorService_SubscribeTasksServer)

Add adds operator's stream to pool

func (*PoolTasks) AddAgent 

func (p *PoolTasks) AddAgent(cookie string, id uint32)

AddAgent saves ID of agent for operator's polling

func (*PoolTasks) DeleteAgent 

func (p *PoolTasks) DeleteAgent(cookie string, id uint32)

DeleteAgent removes ID of agent from operator's polling

func (*PoolTasks) Disconnect 

func (p *PoolTasks) Disconnect(cookie string)

Disconnect notify about necessity of operator's disconnection

func (*PoolTasks) Exists 

func (p *PoolTasks) Exists(username string) bool

Exists check if operator exists in pool by its username

func (*PoolTasks) Get 

func (p *PoolTasks) Get(cookie string) *SubscribeTasks

Get returns operator's subscription object

func (*PoolTasks) Remove 

func (p *PoolTasks) Remove(cookie string)

Remove removes operator's stream from pool

func (*PoolTasks) Send 

func (p *PoolTasks) Send(val any)

Send sends proto message to subscribed operators

type SubscribeAgents 

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

func (*SubscribeAgents) Error 

func (s *SubscribeAgents) Error() chan error

Error returns error appeared in process of stream handling

func (*SubscribeAgents) IsDisconnect 

func (s *SubscribeAgents) IsDisconnect() chan struct{}

IsDisconnect notify if operator must be disconnected

type SubscribeChat 

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

func (*SubscribeChat) Error 

func (s *SubscribeChat) Error() chan error

Error returns error appeared in process of stream handling

func (*SubscribeChat) IsDisconnect 

func (s *SubscribeChat) IsDisconnect() chan struct{}

IsDisconnect notify if operator must be disconnected

type SubscribeCredentials 

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

func (*SubscribeCredentials) Error 

func (s *SubscribeCredentials) Error() chan error

Error returns error appeared in process of stream handling

func (*SubscribeCredentials) IsDisconnect 

func (s *SubscribeCredentials) IsDisconnect() chan struct{}

IsDisconnect notify if operator must be disconnected

type SubscribeListeners 

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

func (*SubscribeListeners) Error 

func (s *SubscribeListeners) Error() chan error

Error returns error appeared in process of stream handling

func (*SubscribeListeners) IsDisconnect 

func (s *SubscribeListeners) IsDisconnect() chan struct{}

IsDisconnect notify if operator must be disconnected

type SubscribeOperators 

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

func (*SubscribeOperators) Error 

func (s *SubscribeOperators) Error() chan error

Error returns error appeared in process of stream handling

func (*SubscribeOperators) IsDisconnect 

func (s *SubscribeOperators) IsDisconnect() chan struct{}

IsDisconnect notify if operator must be disconnected

type SubscribeTasks 

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

func (*SubscribeTasks) Error 

func (s *SubscribeTasks) Error() chan error

Error returns error appeared in process of stream handling

func (*SubscribeTasks) IsDisconnect 

func (s *SubscribeTasks) IsDisconnect() chan struct{}

IsDisconnect notify if operator must be disconnected

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.
JackTT - Gopher 🇻🇳