moderator

package

v0.6.0-dev Latest Latest Go to latest Published: Dec 27, 2025 License: AGPL-3.0, AGPL-3.0-or-later Imports: 14 Imported by: 0

Details

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

Repository

github.com/Warp-net/warpnet

Links

Open Source Insights

Documentation ¶

Overview ¶

This program is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more details.

You should have received a copy of the GNU Affero General Public License along with this program. If not, see <https://www.gnu.org/licenses/>.

WarpNet is provided “as is” without warranty of any kind, either expressed or implied. Use at your own risk. The maintainers shall not be liable for any damages or data loss resulting from the use or misuse of this software.

Index ¶

Constants
type CacheKey
type Engine
type Moderator
- func NewModerator(ctx context.Context, node ModeratorNode, pub Publisher) (_ *Moderator, err error)
- func (m *Moderator) Close()
- func (m *Moderator) Start() (err error)
type ModeratorNode
type Publisher

Constants ¶

View Source

const (
	ErrNoTweetsForModeration warpnet.WarpError = "no tweets for moderation found"
	ErrModeratorInitFailed   warpnet.WarpError = "failed to init moderator engine"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type CacheKey ¶ added in v0.5.134

type CacheKey struct {
	Type   domain.ModerationObjectType
	PeerId string
	Cursor *string
}

type Engine ¶ added in v0.5.21

type Engine interface {
	Moderate(content string) (bool, string, error)
	Close()
}

type Moderator ¶

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

func NewModerator ¶ added in v0.5.21

func NewModerator(
	ctx context.Context,
	node ModeratorNode,
	pub Publisher,
) (_ *Moderator, err error)

func (*Moderator) Close ¶

func (m *Moderator) Close()

func (*Moderator) Start ¶ added in v0.5.21

func (m *Moderator) Start() (err error)

type ModeratorNode ¶

type ModeratorNode interface {
	Start() error
	Stop()
	Node() warpnet.P2PNode
	ID() warpnet.WarpPeerID
	ClosestPeers() []warpnet.WarpPeerID
	NodeInfo() warpnet.NodeInfo
	GenericStream(nodeIdStr string, path stream.WarpRoute, data any) (_ []byte, err error)
}

type Publisher ¶ added in v0.5.21

type Publisher interface {
	PublishUpdateToFollowers(ownerId, dest string, body any) (err error)
}

Source Files ¶

View all Source files

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