utils

Documentation

Index

• func GetDomainFromEmail(email string) (string, error)
• type AtomicBool
  • func (b *AtomicBool) CompareFalseAndSetTrue() bool
  • func (b *AtomicBool) CompareTrueAndSetFalse() bool
  • func (b *AtomicBool) IsSet() bool
  • func (b *AtomicBool) SetFalse()
  • func (b *AtomicBool) SetTrue()
• type Broadcaster
  • func NewBroadcaster() *Broadcaster
  • func (b *Broadcaster) Broadcast(msg interface{})
  • func (b *Broadcaster) SetBufferSize(bufferSize int)
  • func (b *Broadcaster) Start(ctx context.Context)
  • func (b *Broadcaster) Stop()
  • func (b *Broadcaster) Subscribe() chan interface{}
  • func (b *Broadcaster) SubscribeChannel(messageCh chan interface{})
  • func (b *Broadcaster) Unsubscribe(messageCh chan interface{})

Functions

func GetDomainFromEmail

func GetDomainFromEmail(email string) (string, error)

GetDomainFromEmail returns the domain part as defined in RFC 5322 of the provided email address.

Types

type AtomicBool

type AtomicBool int32

func (*AtomicBool) CompareFalseAndSetTrue

func (b *AtomicBool) CompareFalseAndSetTrue() bool

func (*AtomicBool) CompareTrueAndSetFalse

func (b *AtomicBool) CompareTrueAndSetFalse() bool

func (*AtomicBool) IsSet

func (b *AtomicBool) IsSet() bool

func (*AtomicBool) SetFalse

func (b *AtomicBool) SetFalse()

func (*AtomicBool) SetTrue

func (b *AtomicBool) SetTrue()

type Broadcaster

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

A Broadcaster is a implementation of channels where clients can subscribe and unsubscribe to messages. Messages published to the Broadcaster are sent to all subcribers.

func NewBroadcaster

func NewBroadcaster() *Broadcaster

func (*Broadcaster) Broadcast

func (b *Broadcaster) Broadcast(msg interface{})

func (*Broadcaster) SetBufferSize

func (b *Broadcaster) SetBufferSize(bufferSize int)

func (*Broadcaster) Start

func (b *Broadcaster) Start(ctx context.Context)

func (*Broadcaster) Stop

func (b *Broadcaster) Stop()

func (*Broadcaster) Subscribe

func (b *Broadcaster) Subscribe() chan interface{}

func (*Broadcaster) SubscribeChannel

func (b *Broadcaster) SubscribeChannel(messageCh chan interface{})

func (*Broadcaster) Unsubscribe

func (b *Broadcaster) Unsubscribe(messageCh chan interface{})