transports

Documentation

Index

• Variables
• type BoltTransport
  • func NewBoltTransport(u *url.URL) (*BoltTransport, error)
  • func (b *BoltTransport) Count() (int64, error)
  • func (b *BoltTransport) Get(id string) (string, error)
  • func (b *BoltTransport) Put(id string, url string) error
• type RedisTransport
  • func NewRedisTransport(u *url.URL) (*RedisTransport, error)
  • func (r *RedisTransport) Count() (int64, error)
  • func (r *RedisTransport) Get(id string) (string, error)
  • func (r *RedisTransport) Put(id string, url string) error
• type Transport
  • func NewTransport(config *c.Config) (Transport, error)

Variables

var (
	// ErrInvalidTransportDSN is returned when the Transport's DSN is invalid.
	ErrInvalidTransportDSN = errors.New("invalid transport DSN")
	// ErrClosedTransport is returned by the Transport's Dispatch and AddSubscriber methods after a call to Close.
	ErrClosedTransport = errors.New("hub: read/write on closed Transport")
)

Types

type BoltTransport

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

BoltTransport implements the TransportInterface using the Bolt database.

func NewBoltTransport

func NewBoltTransport(u *url.URL) (*BoltTransport, error)

NewBoltTransport create a new BoltTransport.

func (*BoltTransport) Count

func (b *BoltTransport) Count() (int64, error)

func (*BoltTransport) Get

func (b *BoltTransport) Get(id string) (string, error)

func (*BoltTransport) Put

func (b *BoltTransport) Put(id string, url string) error

type RedisTransport

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

RedisTransport implements the TransportInterface using the Bolt database.

func NewRedisTransport

func NewRedisTransport(u *url.URL) (*RedisTransport, error)

NewBoltTransport create a new RedisTransport.

func (*RedisTransport) Count

func (r *RedisTransport) Count() (int64, error)

func (*RedisTransport) Get

func (r *RedisTransport) Get(id string) (string, error)

func (*RedisTransport) Put

func (r *RedisTransport) Put(id string, url string) error

type Transport

type Transport interface {
	Put(id string, url string) error
	Get(id string) (string, error)
	Count() (int64, error)
}

func NewTransport

func NewTransport(config *c.Config) (Transport, error)

NewTransport create a transport using the backend matching the given TransportURL.