client

Documentation

Index

• Variables
• type Option
  • func WithBasePolicy(basePolicy *aero.BasePolicy) Option
  • func WithBypassConfiguredTimeout() Option
  • func WithClientPolicy(clientPolicy *aero.ClientPolicy) Option
• type Pool
• type Service
  • func New(config *datastore.Connection) (*Service, error)
  • func NewWithOptions(config *datastore.Connection, options ...Option) (*Service, error)
  • func (s *Service) Get(ctx context.Context, key *aero.Key, binNames ...string) (record *aero.Record, err error)
  • func (s *Service) Probe()
  • func (s *Service) Put(writePolicy *aero.WritePolicy, key *aero.Key, value aero.BinMap) error

Variables

var DefaultAerospikePool = &Pool{}

Types

type Option

type Option func(srv *Service)

func WithBasePolicy

func WithBasePolicy(basePolicy *aero.BasePolicy) Option

WithBasePolicy will provide an initial BasePolicy. Even when overridden, the timeout will be applied UNLESS using WithBypassConfiguredTimeout.

func WithBypassConfiguredTimeout

func WithBypassConfiguredTimeout() Option

WithBypassConfiguredTimeout will bypass the configured timeout if using WithClientPolicy or WithBasePolicy.

func WithClientPolicy

func WithClientPolicy(clientPolicy *aero.ClientPolicy) Option

WithClientPolicy will provide an initial ClientPolicy. Even when overridden, the timeout will be applied UNLESS using WithBypassConfiguredTimeout.

type Pool

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

type Service

type Service struct {
	*aero.Client

	*circut.Breaker
	// contains filtered or unexported fields
}

Service represents aerospike client Service

func New

func New(config *datastore.Connection) (*Service, error)

New creates a new Aerospike service

func NewWithOptions

func NewWithOptions(config *datastore.Connection, options ...Option) (*Service, error)

func (*Service) Get

func (s *Service) Get(ctx context.Context, key *aero.Key, binNames ...string) (record *aero.Record, err error)

Get returns record for supplied key and optional bin names.

func (*Service) Probe

func (s *Service) Probe()

func (*Service) Put

func (s *Service) Put(writePolicy *aero.WritePolicy, key *aero.Key, value aero.BinMap) error

Put puts a record to Aerospike. Context is not supported since the Aerospike library does not support it.