server

package
v0.35.3 Latest Latest
Warning

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

 Go to latest Published: Sep 29, 2025 License: GPL-3.0 Imports: 83 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ContentTypeKey  = "Content-Type"
	JsonContextType = "application/json"
)

Variables

View Source 
var MediaModules = fx.Options(
	fx.Invoke(
		fs.Register,
		minio.Register,
	),
)
View Source 
var Modules = fx.Options(
	bots.Modules,
	NotifyModules,
	MediaModules,
	fx.Provide(
		config.NewConfig,
		cache.NewCache,
		rdb.NewClient,
		search.NewClient,
		event.NewRouter,
		event.NewSubscriber,
		event.NewPublisher,
		slack.NewDriver,
		newController,
		newDatabaseAdapter,
		newHTTPServer,
	),
	fx.Invoke(
		handleRoutes,
		handleEvents,
		handleChatbot,
		handlePlatform,
		RunServer,
	),
)
View Source 
var NotifyModules = fx.Options(
	fx.Invoke(
		message_pusher.Register,
		ntfy.Register,
		pushover.Register,
		slack.Register,
	),
)

Functions

func RunServer added in v0.31.1 

func RunServer(lc fx.Lifecycle, app *fiber.App, _ store.Adapter, _ *cache.Cache, _ *redis.Client, _ *search.Client, _ message.Publisher)

Types

type Config added in v0.32.1 

type Config struct {
	AllowCors bool
}

type Controller added in v0.31.1 

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

type Endpoint added in v0.32.1 

type Endpoint = RestEndpoint

type RequestMessage added in v0.32.1 

type RequestMessage struct {
	Ctx fiber.Ctx

	Params map[string]string

	Metadata *types.Metadata
	// contains filtered or unexported fields
}

func (*RequestMessage) Body added in v0.32.1 

func (r *RequestMessage) Body() []byte

func (RequestMessage) From added in v0.32.1 

func (r RequestMessage) From() string

func (*RequestMessage) GetError added in v0.32.1 

func (r *RequestMessage) GetError() error

func (*RequestMessage) GetMsg added in v0.32.1 

func (r *RequestMessage) GetMsg() *types.RuleMsg

func (*RequestMessage) GetParam added in v0.32.1 

func (r *RequestMessage) GetParam(key string) string

func (*RequestMessage) Headers added in v0.32.1 

func (r *RequestMessage) Headers() textproto.MIMEHeader

func (*RequestMessage) SetBody added in v0.32.1 

func (r *RequestMessage) SetBody(body []byte)

func (*RequestMessage) SetError added in v0.32.1 

func (r *RequestMessage) SetError(err error)

func (*RequestMessage) SetMsg added in v0.32.1 

func (r *RequestMessage) SetMsg(msg *types.RuleMsg)

func (*RequestMessage) SetStatusCode added in v0.32.1 

func (r *RequestMessage) SetStatusCode(statusCode int)

type ResponseMessage added in v0.32.1 

type ResponseMessage struct {
	Ctx fiber.Ctx
	// contains filtered or unexported fields
}

ResponseMessage http响应消息

func (*ResponseMessage) Body added in v0.32.1 

func (r *ResponseMessage) Body() []byte

func (*ResponseMessage) From added in v0.32.1 

func (r *ResponseMessage) From() string

func (*ResponseMessage) GetError added in v0.32.1 

func (r *ResponseMessage) GetError() error

func (*ResponseMessage) GetMsg added in v0.32.1 

func (r *ResponseMessage) GetMsg() *types.RuleMsg

func (*ResponseMessage) GetParam added in v0.32.1 

func (r *ResponseMessage) GetParam(key string) string

func (*ResponseMessage) Headers added in v0.32.1 

func (r *ResponseMessage) Headers() textproto.MIMEHeader

func (*ResponseMessage) SetBody added in v0.32.1 

func (r *ResponseMessage) SetBody(body []byte)

func (*ResponseMessage) SetError added in v0.32.1 

func (r *ResponseMessage) SetError(err error)

func (*ResponseMessage) SetMsg added in v0.32.1 

func (r *ResponseMessage) SetMsg(msg *types.RuleMsg)

func (*ResponseMessage) SetStatusCode added in v0.32.1 

func (r *ResponseMessage) SetStatusCode(statusCode int)

type RestEndpoint added in v0.32.1 

type RestEndpoint struct {
	impl.BaseEndpoint
	nodeBase.SharedNode[*RestEndpoint]

	Config     Config
	RuleConfig types.Config
	Server     *fiber.App
	// contains filtered or unexported fields
}

func (*RestEndpoint) AddRouter added in v0.32.1 

func (rest *RestEndpoint) AddRouter(router endpoint.Router, params ...interface{}) (id string, err error)

func (*RestEndpoint) Close added in v0.32.1 

func (rest *RestEndpoint) Close() error

func (*RestEndpoint) DELETE added in v0.32.1 

func (rest *RestEndpoint) DELETE(routers ...endpoint.Router) *RestEndpoint

func (*RestEndpoint) Destroy added in v0.32.1 

func (rest *RestEndpoint) Destroy()

func (*RestEndpoint) GET added in v0.32.1 

func (rest *RestEndpoint) GET(routers ...endpoint.Router) *RestEndpoint

func (*RestEndpoint) GetServer added in v0.32.1 

func (rest *RestEndpoint) GetServer() *fiber.App

func (*RestEndpoint) HEAD added in v0.32.1 

func (rest *RestEndpoint) HEAD(routers ...endpoint.Router) *RestEndpoint

func (*RestEndpoint) Id added in v0.32.1 

func (rest *RestEndpoint) Id() string

func (*RestEndpoint) Init added in v0.32.1 

func (rest *RestEndpoint) Init(ruleConfig types.Config, configuration types.Configuration) error

func (*RestEndpoint) New added in v0.32.1 

func (rest *RestEndpoint) New() types.Node

func (*RestEndpoint) OPTIONS added in v0.32.1 

func (rest *RestEndpoint) OPTIONS(routers ...endpoint.Router) *RestEndpoint

func (*RestEndpoint) PATCH added in v0.32.1 

func (rest *RestEndpoint) PATCH(routers ...endpoint.Router) *RestEndpoint

func (*RestEndpoint) POST added in v0.32.1 

func (rest *RestEndpoint) POST(routers ...endpoint.Router) *RestEndpoint

func (*RestEndpoint) PUT added in v0.32.1 

func (rest *RestEndpoint) PUT(routers ...endpoint.Router) *RestEndpoint

func (*RestEndpoint) Printf added in v0.32.1 

func (rest *RestEndpoint) Printf(format string, v ...interface{})

func (*RestEndpoint) RemoveRouter added in v0.32.1 

func (rest *RestEndpoint) RemoveRouter(routerId string, params ...interface{}) error

func (*RestEndpoint) Restart added in v0.32.1 

func (rest *RestEndpoint) Restart() error

func (*RestEndpoint) RouterKey added in v0.32.1 

func (rest *RestEndpoint) RouterKey(method string, from string) string

func (*RestEndpoint) Start added in v0.32.1 

func (rest *RestEndpoint) Start() error

func (*RestEndpoint) Started added in v0.32.1 

func (rest *RestEndpoint) Started() bool

func (*RestEndpoint) Type added in v0.32.1 

func (rest *RestEndpoint) Type() string

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.