graphql

package

v0.0.0-...-38edf11 Latest Latest Go to latest Published: Jul 17, 2025 License: Apache-2.0 Imports: 37 Imported by: 0

Details

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

Repository

github.com/woocoos/msgcenter

Links

Open Source Insights

Documentation ¶

Index ¶

func NewSchema(opts ...Option) graphql.ExecutableSchema
func RemoveDuplicateElement[T int | int64 | string | float32 | float64](arr []T) []T
func SubTopics() []string
type Option
type PubSub
type Resolver
- func NewResolver(opt ...Option) *Resolver
type Server
- func NewServer(app *woocoo.App, am *service.AlertManager) (*Server, error)
- func (s *Server) Start(ctx context.Context) error
- func (s *Server) Stop(ctx context.Context) error
type SubTopic

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewSchema ¶

func NewSchema(opts ...Option) graphql.ExecutableSchema

NewSchema creates a graphql executable schema.

func RemoveDuplicateElement ¶

func RemoveDuplicateElement[T int | int64 | string | float32 | float64](arr []T) []T

RemoveDuplicateElement 去重

func SubTopics ¶

func SubTopics() []string

Types ¶

type Option ¶

type Option func(*Resolver)

func WithClient ¶

func WithClient(client *ent.Client) Option

func WithCoordinator ¶

func WithCoordinator(coordinator *service.Coordinator) Option

func WithKOClient ¶

func WithKOClient(client *api.SDK) Option

func WithMsgClient ¶

func WithMsgClient(client redis.UniversalClient) Option

func WithPubSub ¶

func WithPubSub(pubSub PubSub) Option

func WithSilences ¶

func WithSilences(silences *silence.Silences) Option

type PubSub ¶

type PubSub interface {
	Subscribe(ctx context.Context, topic string) (chan *model.Message, error)
}

type Resolver ¶

type Resolver struct {
	Silences  *silence.Silences
	MsgClient redis.UniversalClient
	PubSub    PubSub
	// contains filtered or unexported fields
}

Resolver is the root resolver.

func NewResolver ¶

func NewResolver(opt ...Option) *Resolver

func (*Resolver) MsgAlert ¶

func (r *Resolver) MsgAlert() generated.MsgAlertResolver

MsgAlert returns generated.MsgAlertResolver implementation.

func (*Resolver) MsgEvent ¶

func (r *Resolver) MsgEvent() generated.MsgEventResolver

MsgEvent returns generated.MsgEventResolver implementation.

func (*Resolver) MsgInternal ¶

func (r *Resolver) MsgInternal() generated.MsgInternalResolver

MsgInternal returns generated.MsgInternalResolver implementation.

func (*Resolver) MsgType ¶

func (r *Resolver) MsgType() generated.MsgTypeResolver

MsgType returns generated.MsgTypeResolver implementation.

func (*Resolver) Mutation ¶

func (r *Resolver) Mutation() generated.MutationResolver

Mutation returns generated.MutationResolver implementation.

func (*Resolver) Query ¶

func (r *Resolver) Query() generated.QueryResolver

Query returns generated.QueryResolver implementation.

func (*Resolver) Route ¶

func (r *Resolver) Route() generated.RouteResolver

Route returns generated.RouteResolver implementation.

func (*Resolver) RouteInput ¶

func (r *Resolver) RouteInput() generated.RouteInputResolver

RouteInput returns generated.RouteInputResolver implementation.

func (*Resolver) Subscription ¶

func (r *Resolver) Subscription() generated.SubscriptionResolver

Subscription returns generated.SubscriptionResolver implementation.

type Server ¶

type Server struct {
	DB        *ent.Client
	WebServer *web.Server
}

func NewServer ¶

func NewServer(app *woocoo.App, am *service.AlertManager) (*Server, error)

func (*Server) Start ¶

func (s *Server) Start(ctx context.Context) error

func (*Server) Stop ¶

func (s *Server) Stop(ctx context.Context) error

type SubTopic ¶

type SubTopic string

var (
	SubTopicMessage SubTopic = "message"
)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
generated
model

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