interfaces

Documentation

Index

• type APNSPushQueue
• type DB
• type FeedbackReporter
• type GCMClient
• type InvalidTokenHandler
• type KafkaConsumerClient
• type KafkaProducerClient
• type MessageHandler
• type Queue
• type StatsDClient
• type StatsReporter

Types

type APNSPushQueue

type APNSPushQueue interface {
	// Responses chan *push.Response
	Push(string, *push.Headers, []byte)
	Close()
}

APNSPushQueue represents the contract for a APNS Push Queue

type DB

type DB interface {
	Exec(interface{}, ...interface{}) (*types.Result, error)
	ExecOne(interface{}, ...interface{}) (*types.Result, error)
	Query(interface{}, interface{}, ...interface{}) (*types.Result, error)
	Close() error
}

DB represents the contract for a Postgres DB

type FeedbackReporter

type FeedbackReporter interface {
	SendFeedback(feedback []byte)
}

FeedbackReporter interface for making new feedback reporters pluggable easily

type GCMClient

type GCMClient interface {
	SendXMPP(gcm.XMPPMessage) (string, int, error)
	Close() error
}

GCMClient represents the contract for a GCM Client

type InvalidTokenHandler

type InvalidTokenHandler interface {
	HandleToken(token string) error
}

InvalidTokenHandler interface for defining functions that handle invalid tokens easily pluggable

type KafkaConsumerClient

type KafkaConsumerClient interface {
	SubscribeTopics([]string, kafka.RebalanceCb) error
	Events() chan kafka.Event
	Assign([]kafka.TopicPartition) error
	Unassign() error
	Close() error
}

KafkaConsumerClient interface

type KafkaProducerClient

type KafkaProducerClient interface {
	Events() chan kafka.Event
	ProduceChannel() chan *kafka.Message
}

KafkaProducerClient interface

type MessageHandler

type MessageHandler interface {
	HandleMessages(msgChan *chan []byte)
	HandleResponses()
	LogStats()
}

MessageHandler interface for making message handlers pluggable easily

type Queue

type Queue interface {
	MessagesChannel() *chan []byte
	ConsumeLoop() error
	StopConsuming()
	PendingMessagesWaitGroup() *sync.WaitGroup
}

Queue interface for making new queues pluggable easily

type StatsDClient

type StatsDClient interface {
	Increment(string)
	Gauge(string, interface{})
	Timing(string, interface{})
	Close()
}

StatsDClient interface

type StatsReporter

type StatsReporter interface {
	HandleNotificationSent()
	HandleNotificationSuccess()
	HandleNotificationFailure(*errors.PushError)
	ReportGoStats(numGoRoutines int, allocatedAndNotFreed, heapObjects, nextGCBytes, pauseGCNano uint64)
}

StatsReporter interface for making stats reporters pluggable easily