graphql

package

v0.0.0-...-9f34937 Latest Latest Go to latest Published: Nov 3, 2023 License: Apache-2.0 Imports: 41 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
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 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)
}

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) ReportFileRefCount ¶

func (r *Resolver) ReportFileRefCount(ctx context.Context, newFileIDs, oldFileIDs []int) error

ReportFileRefCount 文件引用上报

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"
)

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