graphql

Documentation

Index

• func NewSchema(opts ...Option) graphql.ExecutableSchema
• func RemoveDuplicateElement[T int | int64 | string | float32 | float64](arr []T) []T
• func SubTopics() []string
• type Option
  • func WithClient(client *ent.Client) Option
  • func WithCoordinator(coordinator *service.Coordinator) Option
  • func WithKOClient(client *api.SDK) Option
  • func WithMsgClient(client redis.UniversalClient) Option
  • func WithPubSub(pubSub PubSub) Option
  • func WithSilences(silences *silence.Silences) Option
• type PubSub
• type Resolver
  • func NewResolver(opt ...Option) *Resolver
  • func (r *Resolver) MsgAlert() generated.MsgAlertResolver
  • func (r *Resolver) MsgEvent() generated.MsgEventResolver
  • func (r *Resolver) MsgInternal() generated.MsgInternalResolver
  • func (r *Resolver) MsgType() generated.MsgTypeResolver
  • func (r *Resolver) Mutation() generated.MutationResolver
  • func (r *Resolver) Query() generated.QueryResolver
  • func (r *Resolver) Route() generated.RouteResolver
  • func (r *Resolver) RouteInput() generated.RouteInputResolver
  • func (r *Resolver) Subscription() generated.SubscriptionResolver
• 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

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

!!! WARNING !!! The code below was going to be deleted when updating resolvers. It has been copied here so you have one last chance to move it out of harms way if you want. There are two reasons this happens:

• When renaming or deleting a resolver the old code will be put in here. You can safely delete it when you're done.
• You have helper methods in this file. Move them out to keep these resolver files clean.

var (
	SubTopicMessage SubTopic = "message"
)