channels

package

v0.0.1 Latest Latest Go to latest Published: Feb 9, 2026 License: MIT Imports: 16 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/sipeed/picoclaw

Links

Open Source Insights

Documentation ¶

Index ¶

type BaseChannel
- func NewBaseChannel(name string, config interface{}, bus *bus.MessageBus, allowList []string) *BaseChannel
- func (c *BaseChannel) HandleMessage(senderID, chatID, content string, media []string, metadata map[string]string)
- func (c *BaseChannel) IsAllowed(senderID string) bool
- func (c *BaseChannel) IsRunning() bool
- func (c *BaseChannel) Name() string
type Channel
type DiscordChannel
- func NewDiscordChannel(cfg config.DiscordConfig, bus *bus.MessageBus) (*DiscordChannel, error)
- func (c *DiscordChannel) Send(ctx context.Context, msg bus.OutboundMessage) error
- func (c *DiscordChannel) Start(ctx context.Context) error
- func (c *DiscordChannel) Stop(ctx context.Context) error
type FeishuChannel
- func NewFeishuChannel(cfg config.FeishuConfig, bus *bus.MessageBus) (*FeishuChannel, error)
- func (c *FeishuChannel) Send(ctx context.Context, msg bus.OutboundMessage) error
- func (c *FeishuChannel) Start(ctx context.Context) error
- func (c *FeishuChannel) Stop(ctx context.Context) error
type MaixCamChannel
- func NewMaixCamChannel(cfg config.MaixCamConfig, bus *bus.MessageBus) (*MaixCamChannel, error)
- func (c *MaixCamChannel) Send(ctx context.Context, msg bus.OutboundMessage) error
- func (c *MaixCamChannel) Start(ctx context.Context) error
- func (c *MaixCamChannel) Stop(ctx context.Context) error
type MaixCamMessage
type Manager
- func NewManager(cfg *config.Config, messageBus *bus.MessageBus) (*Manager, error)
- func (m *Manager) GetChannel(name string) (Channel, bool)
- func (m *Manager) GetEnabledChannels() []string
- func (m *Manager) GetStatus() map[string]interface{}
- func (m *Manager) RegisterChannel(name string, channel Channel)
- func (m *Manager) SendToChannel(ctx context.Context, channelName, chatID, content string) error
- func (m *Manager) StartAll(ctx context.Context) error
- func (m *Manager) StopAll(ctx context.Context) error
- func (m *Manager) UnregisterChannel(name string)
type TelegramChannel
- func NewTelegramChannel(cfg config.TelegramConfig, bus *bus.MessageBus) (*TelegramChannel, error)
- func (c *TelegramChannel) Send(ctx context.Context, msg bus.OutboundMessage) error
- func (c *TelegramChannel) SetTranscriber(transcriber *voice.GroqTranscriber)
- func (c *TelegramChannel) Start(ctx context.Context) error
- func (c *TelegramChannel) Stop(ctx context.Context) error
type WhatsAppChannel
- func NewWhatsAppChannel(cfg config.WhatsAppConfig, bus *bus.MessageBus) (*WhatsAppChannel, error)
- func (c *WhatsAppChannel) Send(ctx context.Context, msg bus.OutboundMessage) error
- func (c *WhatsAppChannel) Start(ctx context.Context) error
- func (c *WhatsAppChannel) Stop(ctx context.Context) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BaseChannel ¶

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

func NewBaseChannel ¶

func NewBaseChannel(name string, config interface{}, bus *bus.MessageBus, allowList []string) *BaseChannel

func (*BaseChannel) HandleMessage ¶

func (c *BaseChannel) HandleMessage(senderID, chatID, content string, media []string, metadata map[string]string)

func (*BaseChannel) IsAllowed ¶

func (c *BaseChannel) IsAllowed(senderID string) bool

func (*BaseChannel) IsRunning ¶

func (c *BaseChannel) IsRunning() bool

func (*BaseChannel) Name ¶

func (c *BaseChannel) Name() string

type Channel ¶

type Channel interface {
	Name() string
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	Send(ctx context.Context, msg bus.OutboundMessage) error
	IsRunning() bool
	IsAllowed(senderID string) bool
}

type DiscordChannel ¶

type DiscordChannel struct {
	*BaseChannel
	// contains filtered or unexported fields
}

func NewDiscordChannel ¶

func NewDiscordChannel(cfg config.DiscordConfig, bus *bus.MessageBus) (*DiscordChannel, error)

func (*DiscordChannel) Send ¶

func (c *DiscordChannel) Send(ctx context.Context, msg bus.OutboundMessage) error

func (*DiscordChannel) Start ¶

func (c *DiscordChannel) Start(ctx context.Context) error

func (*DiscordChannel) Stop ¶

func (c *DiscordChannel) Stop(ctx context.Context) error

type FeishuChannel ¶

type FeishuChannel struct {
	*BaseChannel
	// contains filtered or unexported fields
}

func NewFeishuChannel ¶

func NewFeishuChannel(cfg config.FeishuConfig, bus *bus.MessageBus) (*FeishuChannel, error)

func (*FeishuChannel) Send ¶

func (c *FeishuChannel) Send(ctx context.Context, msg bus.OutboundMessage) error

func (*FeishuChannel) Start ¶

func (c *FeishuChannel) Start(ctx context.Context) error

func (*FeishuChannel) Stop ¶

func (c *FeishuChannel) Stop(ctx context.Context) error

type MaixCamChannel ¶

type MaixCamChannel struct {
	*BaseChannel
	// contains filtered or unexported fields
}

func NewMaixCamChannel ¶

func NewMaixCamChannel(cfg config.MaixCamConfig, bus *bus.MessageBus) (*MaixCamChannel, error)

func (*MaixCamChannel) Send ¶

func (c *MaixCamChannel) Send(ctx context.Context, msg bus.OutboundMessage) error

func (*MaixCamChannel) Start ¶

func (c *MaixCamChannel) Start(ctx context.Context) error

func (*MaixCamChannel) Stop ¶

func (c *MaixCamChannel) Stop(ctx context.Context) error

type MaixCamMessage ¶

type MaixCamMessage struct {
	Type      string                 `json:"type"`
	Tips      string                 `json:"tips"`
	Timestamp float64                `json:"timestamp"`
	Data      map[string]interface{} `json:"data"`
}

type Manager ¶

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

func NewManager ¶

func NewManager(cfg *config.Config, messageBus *bus.MessageBus) (*Manager, error)

func (*Manager) GetChannel ¶

func (m *Manager) GetChannel(name string) (Channel, bool)

func (*Manager) GetEnabledChannels ¶

func (m *Manager) GetEnabledChannels() []string

func (*Manager) GetStatus ¶

func (m *Manager) GetStatus() map[string]interface{}

func (*Manager) RegisterChannel ¶

func (m *Manager) RegisterChannel(name string, channel Channel)

func (*Manager) SendToChannel ¶

func (m *Manager) SendToChannel(ctx context.Context, channelName, chatID, content string) error

func (*Manager) StartAll ¶

func (m *Manager) StartAll(ctx context.Context) error

func (*Manager) StopAll ¶

func (m *Manager) StopAll(ctx context.Context) error

func (*Manager) UnregisterChannel ¶

func (m *Manager) UnregisterChannel(name string)

type TelegramChannel ¶

type TelegramChannel struct {
	*BaseChannel
	// contains filtered or unexported fields
}

func NewTelegramChannel ¶

func NewTelegramChannel(cfg config.TelegramConfig, bus *bus.MessageBus) (*TelegramChannel, error)

func (*TelegramChannel) Send ¶

func (c *TelegramChannel) Send(ctx context.Context, msg bus.OutboundMessage) error

func (*TelegramChannel) SetTranscriber ¶

func (c *TelegramChannel) SetTranscriber(transcriber *voice.GroqTranscriber)

func (*TelegramChannel) Start ¶

func (c *TelegramChannel) Start(ctx context.Context) error

func (*TelegramChannel) Stop ¶

func (c *TelegramChannel) Stop(ctx context.Context) error

type WhatsAppChannel ¶

type WhatsAppChannel struct {
	*BaseChannel
	// contains filtered or unexported fields
}

func NewWhatsAppChannel ¶

func NewWhatsAppChannel(cfg config.WhatsAppConfig, bus *bus.MessageBus) (*WhatsAppChannel, error)

func (*WhatsAppChannel) Send ¶

func (c *WhatsAppChannel) Send(ctx context.Context, msg bus.OutboundMessage) error

func (*WhatsAppChannel) Start ¶

func (c *WhatsAppChannel) Start(ctx context.Context) error

func (*WhatsAppChannel) Stop ¶

func (c *WhatsAppChannel) Stop(ctx context.Context) error

Source Files ¶

View all Source files

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