2015-06-03 03:25:37 +03:00
|
|
|
package server
|
|
|
|
|
2019-01-24 00:46:26 +03:00
|
|
|
import "context"
|
|
|
|
|
|
|
|
type HandlerOption func(*HandlerOptions)
|
|
|
|
|
2016-01-08 17:02:32 +03:00
|
|
|
type HandlerOptions struct {
|
|
|
|
Internal bool
|
2016-05-26 20:01:02 +03:00
|
|
|
Metadata map[string]map[string]string
|
2020-09-11 11:55:31 +03:00
|
|
|
Context context.Context
|
2016-01-08 17:02:32 +03:00
|
|
|
}
|
|
|
|
|
2020-09-05 02:11:29 +03:00
|
|
|
func NewHandlerOptions() HandlerOptions {
|
2020-09-11 11:55:31 +03:00
|
|
|
return HandlerOptions{Context: context.Background()}
|
2020-09-05 02:11:29 +03:00
|
|
|
}
|
|
|
|
|
2019-01-24 00:46:26 +03:00
|
|
|
type SubscriberOption func(*SubscriberOptions)
|
|
|
|
|
2016-01-08 17:02:32 +03:00
|
|
|
type SubscriberOptions struct {
|
2019-05-24 15:06:27 +03:00
|
|
|
// AutoAck defaults to true. When a handler returns
|
|
|
|
// with a nil error the message is acked.
|
|
|
|
AutoAck bool
|
2016-01-23 00:48:43 +03:00
|
|
|
Queue string
|
2016-01-08 17:02:32 +03:00
|
|
|
Internal bool
|
2019-01-24 00:46:26 +03:00
|
|
|
Context context.Context
|
2016-01-08 17:02:32 +03:00
|
|
|
}
|
|
|
|
|
2020-09-05 02:11:29 +03:00
|
|
|
func NewSubscriberOptions(opts ...SubscriberOption) SubscriberOptions {
|
|
|
|
opt := SubscriberOptions{
|
|
|
|
AutoAck: true,
|
|
|
|
Context: context.Background(),
|
|
|
|
}
|
|
|
|
|
|
|
|
for _, o := range opts {
|
|
|
|
o(&opt)
|
|
|
|
}
|
|
|
|
|
|
|
|
return opt
|
|
|
|
}
|
|
|
|
|
2016-05-26 22:43:05 +03:00
|
|
|
// EndpointMetadata is a Handler option that allows metadata to be added to
|
|
|
|
// individual endpoints.
|
|
|
|
func EndpointMetadata(name string, md map[string]string) HandlerOption {
|
|
|
|
return func(o *HandlerOptions) {
|
|
|
|
o.Metadata[name] = md
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2016-01-08 17:02:32 +03:00
|
|
|
// Internal Handler options specifies that a handler is not advertised
|
|
|
|
// to the discovery system. In the future this may also limit request
|
|
|
|
// to the internal network or authorised user.
|
|
|
|
func InternalHandler(b bool) HandlerOption {
|
|
|
|
return func(o *HandlerOptions) {
|
|
|
|
o.Internal = b
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// Internal Subscriber options specifies that a subscriber is not advertised
|
|
|
|
// to the discovery system.
|
|
|
|
func InternalSubscriber(b bool) SubscriberOption {
|
|
|
|
return func(o *SubscriberOptions) {
|
|
|
|
o.Internal = b
|
|
|
|
}
|
2015-06-12 21:52:27 +03:00
|
|
|
}
|
2016-01-23 00:48:43 +03:00
|
|
|
|
2019-05-24 15:06:27 +03:00
|
|
|
// DisableAutoAck will disable auto acking of messages
|
|
|
|
// after they have been handled.
|
|
|
|
func DisableAutoAck() SubscriberOption {
|
|
|
|
return func(o *SubscriberOptions) {
|
|
|
|
o.AutoAck = false
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2016-01-23 00:48:43 +03:00
|
|
|
// Shared queue name distributed messages across subscribers
|
|
|
|
func SubscriberQueue(n string) SubscriberOption {
|
|
|
|
return func(o *SubscriberOptions) {
|
|
|
|
o.Queue = n
|
|
|
|
}
|
|
|
|
}
|
2019-01-24 00:46:26 +03:00
|
|
|
|
|
|
|
// SubscriberContext set context options to allow broker SubscriberOption passed
|
|
|
|
func SubscriberContext(ctx context.Context) SubscriberOption {
|
|
|
|
return func(o *SubscriberOptions) {
|
|
|
|
o.Context = ctx
|
|
|
|
}
|
|
|
|
}
|