tlantic / go-couchbase-adapter Goto Github PK

An attempt to connect to the specified bucket should be made. Not doing so will cause the program to panic while trying to access a nil pointer to an non-existing bucket.

func (b *Bucket) insert(key string, value interface{}, expiry uint32) (Cas, MutationToken, error) {
	bytes, flags, err := b.transcoder.Encode(value)
	if err != nil {	return 0, MutationToken{}, err
	}
	return b.hlpCasExec(func(cb ioCasCallback) (pendingOp, error) {
		op, err := b.client.Add([]byte(key), bytes, flags, expiry, gocbcore.StoreCallback(cb))
		return op, err
	})
}

Current workaround is checking the bucket connection placing a dummy request post-initialization, but this should be done internally. Calling NewCouchbaseStore should return an error or in worst cases, since it is a safer place, panic.