server

package

v1.0.0 Latest Latest Go to latest Published: Apr 21, 2019 License: MIT Imports: 21 Imported by: 0

Documentation ¶

Index ¶

func NewLogger() zerolog.Logger
func StartCommand()
type Configuration
type Consumer
- func NewConsumer(ctx context.Context, brokers []string, topic string, offset int64, ...) (*Consumer, error)
- func (c Consumer) Start()
type LoggerFunc
- func KafkaMessageAsZerologObject(message kafka.Message) LoggerFunc
- func (f LoggerFunc) MarshalZerologObject(e *zerolog.Event)
type Resolver
- func NewResolver(cfg *Configuration, log zerolog.Logger) *Resolver
- func (r *Resolver) Event(ctx context.Context, args ...) (<-chan *graphql.JSONObject, error)
- func (r *Resolver) Topics() []string
type Server
- func NewServer(cfg *Configuration) *Server
- func (s *Server) Start()

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewLogger ¶

func NewLogger() zerolog.Logger

func StartCommand ¶

func StartCommand()

Types ¶

type Configuration ¶

type Configuration struct {
	// The port the server will listen to.
	Port uint16
	// The list of broker addresses used to connect to the kafka cluster.
	Brokers []string
	// The list of topics subscribers can consume.
	Topics []string
}

type Consumer ¶

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

func NewConsumer ¶

func NewConsumer(
	ctx context.Context,
	brokers []string,
	topic string,
	offset int64,
	matching *string,
	channel chan<- *scalar.JSONObject) (*Consumer, error)

func (Consumer) Start ¶

func (c Consumer) Start()

type LoggerFunc ¶

type LoggerFunc func(e *zerolog.Event)

LoggerFunc turns a function into an a zerolog marshaller.

func KafkaMessageAsZerologObject ¶

func KafkaMessageAsZerologObject(message kafka.Message) LoggerFunc

AsEventTraitZerologObject converts a

func (LoggerFunc) MarshalZerologObject ¶

func (f LoggerFunc) MarshalZerologObject(e *zerolog.Event)

MarshalZerologObject makes the LoggerFunc type a LogObjectMarshaler.

type Resolver ¶

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

func NewResolver ¶

func NewResolver(cfg *Configuration, log zerolog.Logger) *Resolver

func (*Resolver) Event ¶

func (r *Resolver) Event(
	ctx context.Context,
	args *struct {
		On       string
		At       graphql.Offset
		Matching *string
	}) (<-chan *graphql.JSONObject, error)

func (*Resolver) Topics ¶

func (r *Resolver) Topics() []string

type Server ¶

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

func NewServer ¶

func NewServer(cfg *Configuration) *Server

func (*Server) Start ¶

func (s *Server) Start()

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
scalar

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