Me complace anunciar el Couchbase Go SDK 2.0 Alpha. Este nuevo SDK trae una serie de cambios en todos los SDKs de Couchbase que el equipo ha estado creando. Los nuevos SDKs traen una API completamente nueva que es m\u00e1s simple, a prueba de futuro y se integra con los \u00faltimos desarrollos del ecosistema.<\/p>\n
La versi\u00f3n 2.0 del SDK Go se alinea con las nuevas caracter\u00edsticas de Couchbase Server que se extienden fuera de la interfaz tradicional Bucket: soporte para Scopes y Collection. Adem\u00e1s, consolida y refina la interfaz, mejorando la conformidad entre SDKs.<\/p>\n
En versiones anteriores de Couchbase Server, los buckets se utilizaban como entidades l\u00f3gicas con nombre de usuario que agrupaban elementos. Esto permit\u00eda acceder a ellos, indexarlos, replicarlos y controlar el acceso. Este era realmente el \u00fanico medio de lograr multi-tenancy usando Couchbase Server y ven\u00eda con algunas limitaciones: Los buckets en s\u00ed son bastante intensivos en recursos y un cluster s\u00f3lo puede gestionar eficientemente un n\u00famero finito de buckets. Para las modernas arquitecturas de micro-servicios, o realmente cualquier arquitectura en la que se necesite multi-tenancy, esto supon\u00eda algunos retos a la hora de servir a una gran cantidad de inquilinos. Esto se resolver\u00e1 en una futura versi\u00f3n de Couchbase Server con los conceptos de Scopes y Collections.<\/p>\n
Un \u00c1mbito representa una unidad de multitenencia y se construye a partir de Colecciones. Una colecci\u00f3n es un nombre \u00fanico para un grupo de documentos. Dentro de un \u00e1mbito, el nombre de una colecci\u00f3n debe ser \u00fanico, pero el mismo nombre de colecci\u00f3n puede utilizarse en varios \u00e1mbitos. Cada cubo contiene un \u00e1mbito predeterminado con el nombre \"_default\" y un identificador 0 (cero), que a su vez contiene una colecci\u00f3n predeterminada con el nombre \"_default\" y un identificador 0 (cero).<\/p>\n
Esto tiene el efecto de trasladar las operaciones clave\/valor que estaban en el contexto de bucket para SDK 1.0 al contexto de colecci\u00f3n para SDK 2.0. Las operaciones entre buckets como Search, Analytics y N1QL se realizan ahora a nivel de cl\u00faster.<\/p>\n
Couchbase Server 6.5 soportar\u00e1 Scopes y Collections como parte de \"Developer Preview\", Developer Preview es no<\/em>\u00a0para su uso en producci\u00f3n. Mientras tanto, el SDK 2.0 tambi\u00e9n es compatible con Couchbase 5.0 y superiores utilizando el Scope y la Collection por defecto.<\/p>\n El objetivo de esta alfa es proporcionar la API para usar Couchbase Server con operaciones Key\/Value, N1QL, b\u00fasqueda y consultas anal\u00edticas, as\u00ed como vistas. Contiene las conocidas estructuras l\u00f3gicas Cluster y Bucket, as\u00ed como las nuevas estructuras Scope y Collections. Los aspectos m\u00e1s destacados pueden agruparse en dos secciones. La primera es la nueva API, que se ha renovado en todos los SDK para ofrecer patrones de acceso m\u00e1s sencillos y preparados para el futuro. La segunda son las mejoras espec\u00edficas de Go SDK.<\/p>\n La API ha sido significativamente adelgazada y reelaborada para que las llamadas a m\u00e9todos individuales sean m\u00e1s f\u00e1ciles de encontrar y m\u00e1s uniformes. Para Go esto significa que ya no necesitamos tener m\u00faltiples llamadas para funciones similares, pero diferentes. Tambi\u00e9n hemos reducido el n\u00famero de par\u00e1metros necesarios en algunas funciones.<\/p>\n Por ejemplo, en SDK 1.0 hab\u00eda firmas de m\u00e9todos como:<\/p>\n En SDK 2.0 esto ha cambiado a:<\/p>\n Cada m\u00e9todo devuelve un *Result<\/span> y tiene un par\u00e1metro opcional llamado *Options<\/span>. Todo lo necesario para que una operaci\u00f3n funcione es un par\u00e1metro y las propiedades opcionales (como el tiempo de espera, los requisitos de durabilidad, el valor cas, etc.) se han trasladado a bloques de opciones. Esto ha dado lugar a un menor n\u00famero de funciones \"sobrecargadas\" y a una API general m\u00e1s sencilla. Los resultados de las operaciones de tipo mutaci\u00f3n contienen elementos como los valores CAS y el token de mutaci\u00f3n. Para las operaciones de tipo Fetch, los resultados contienen formas de obtener su valor y la caducidad del documento (si se solicita).<\/p>\n Los bloques de opciones son structs con el siguiente aspecto<\/p>\n Esto proporciona mucha m\u00e1s flexibilidad a nivel de operaciones que la API anterior. Esto significa que antes si quer\u00edas hacer una inserci\u00f3n con persist to<\/span>\u00a0 conjunto entonces ten\u00edas que hacer InsertDura(“key”, “value”, 0, 0, 1)<\/span> , ahora es s\u00f3lo Insert(“key”, “value”, &InsertOptions{PersistTo: 1})<\/span>\u00a0.<\/p>\n Ahora tenemos soporte para context.Context<\/span> para la cancelaci\u00f3n. Lo que esto significa es que puedes usar cosas como tomar el contexto de tu manejador HTTP y suministrarlo directamente a tu operaci\u00f3n gocb, de modo que tengas la misma estructura de cancelaci\u00f3n usada en todo tu manejador de peticiones HTTP. Si no quieres usar Contexto<\/span> no se preocupe, puede utilizar el bot\u00f3n Tiempo de espera<\/span>\u00a0 en su lugar.<\/p>\n Las API de consulta, al igual que la API de valor clave, utilizan ahora\u00a0*Options<\/span> para propiedades de consulta opcionales. Anteriormente, las API ten\u00edan el aspecto siguiente:<\/p>\n Ahora parece:<\/p>\n Los bloques de opciones son demasiado grandes para incluirlos aqu\u00ed, pero su aspecto y funcionamiento son similares a los del ejemplo de valor clave anterior. Tambi\u00e9n hemos mejorado la coherencia de la API en todos los servicios de consulta actualizando la forma de acceder a los resultados. Todav\u00eda estamos trabajando en la transcodificaci\u00f3n personalizada de estos resultados. Ahora todos los servicios tambi\u00e9n utilizan streaming para recuperar los resultados, lo que significa que puedes consultar conjuntos de datos enormes sin tener que preocuparte por quedarte sin memoria.<\/p>\n Anteriormente, expusimos errores centinela (p. ej. if err == gocb.ErrKeyNotFound<\/span> ) que deb\u00edas comparar si tu operaci\u00f3n devolv\u00eda un error y ten\u00edas tipos de error espec\u00edficos que deb\u00edas manejar. Hemos cambiado esto, ahora exponemos los errores como tipos y tambi\u00e9n proporcionamos funciones de ayuda para categorizar los errores. Ahora puedes hacer if gocb.IsKeyNotFound(err)<\/span>o escriba el error completo kvErr := err.(gocb.KeyValueError)<\/span>\u00a0 y accede al contexto subyacente sobre el error si tambi\u00e9n lo necesitas.<\/p>\n Puedes empezar a utilizar todas estas mejoras haciendo: go get github.com\/couchbase\/gocb@v2.0.0-alpha.3<\/span><\/p>\n Una vez que tengas el SDK podr\u00e1s conectarte a un cluster, abrir un bucket y usar la colecci\u00f3n por defecto. Por ahora, a menos que uses el modo Developer Preview en Couchbase Server 6.5, solo podr\u00e1s usar la colecci\u00f3n por defecto.<\/p>\n Observe que la apertura de cubos ya no devuelve un error, aunque sigue siendo el lugar donde se produce la conexi\u00f3n. En su lugar, aplazamos la devoluci\u00f3n de errores hasta la primera operaci\u00f3n. En el futuro podr\u00e1s comprobar la salud de la conexi\u00f3n del cubo antes de realizar operaciones.<\/p>\n Si quiere saber m\u00e1s, eche un vistazo a nuestro nuevo\u00a0documentaci\u00f3n<\/a>\u00a0que tambi\u00e9n est\u00e1 empezando a cuajar.<\/p>\n La API es bastante nueva, y alfa, por lo que todav\u00eda est\u00e1 sujeta a cambios - aunque no deber\u00eda cambiar dr\u00e1sticamente. Apreciar\u00edamos todos los comentarios y reportes de errores para hacer de este el mejor SDK que hayamos entregado. Esta es tu oportunidad para ayudar a dar forma al futuro del SDK de Couchbase Go.<\/p>\nAspectos destacados de la API SDK 2.0<\/h2>\n
Mejoras en la API de valores clave<\/h3>\n
func (b *Bucket) Insert(key string, value interface{}, expiry uint32) (Cas, error)\r\nfunc (b *Bucket) InsertDura(key string, value interface{}, expiry uint32, replicateTo, persistTo uint) (Cas, error)\r\nfunc (b *Bucket) Get(key string, valuePtr interface{}) (Cas, error)\r\n<\/pre>\nfunc (c *Collection) Insert(key string, val interface{}, opts *InsertOptions) (*MutationResult, error)\r\nfunc (c *Collection) Get(key string, opts *GetOptions) (*GetResult, error)<\/pre>\ntype InsertOptions struct {\r\n\tParentSpanContext opentracing.SpanContext\r\n\tTimeout time.Duration\r\n\tContext context.Context\r\n\t\/\/ The expiration length in seconds\r\n\tExpiration uint32\r\n\tPersistTo uint\r\n\tReplicateTo uint\r\n\tDurabilityLevel DurabilityLevel\r\n\tEncoder Encode\r\n}<\/pre>\nMejoras en la API de consulta<\/h3>\n
func (c *Cluster) ExecuteN1qlQuery(q *N1qlQuery, params interface{}) (QueryResults, error)\r\nfunc (c *Cluster) ExecuteAnalyticsQuery(q *AnalyticsQuery, params interface{}) (AnalyticsResults, error)\r\nfunc (c *Cluster) ExecuteSearchQuery(q *SearchQuery) (SearchResults, error)\r\nfunc (b *Bucket) ViewQuery(designDoc string, viewName string, opts *ViewOptions) (*ViewResults, error)<\/pre>\nfunc (c *Cluster) Query(statement string, opts *QueryOptions) (*QueryResults, error)\r\nfunc (c *Cluster) AnalyticsQuery(statement string, opts *AnalyticsQueryOptions) (*AnalyticsResults, error)\r\nfunc (c *Cluster) SearchQuery(q SearchQuery, opts *SearchQueryOptions) (*SearchResults, error)\r\nfunc (b *Bucket) ViewQuery(designDoc string, viewName string, opts *ViewOptions) (*ViewResults, error)<\/pre>\n
Mejoras en la gesti\u00f3n de errores<\/h3>\n
Primeros pasos<\/h2>\n
cluster, err := gocb.Connect(\"localhost\", gocb.ClusterOptions{Authenticator: gocb.PasswordAuthenticator{\r\n Username: \"username\",\r\n Password: \"password\",\r\n}})\r\nif err != nil {\r\n panic(\"error connecting to cluster:\" + err.Error())\r\n}\r\nbucket := cluster.Bucket(\"bucket-name\", nil)\r\ncollection := bucket.DefaultCollection(nil)\r\n\r\n\/\/ Now you can perform operations:\r\n\r\nupsertResult, err := collection.Upsert(\"somekey\", \"somevalue\", &gocb.UpsertOptions{Timeout: 10*time.Millisecond})\r\nif err != nil {\r\n panic(err)\r\n}\r\n\r\nfmt.Println(upsertResult.Cas())\r\n\r\ngetResult, err := collection.Get(\"somekey\", nil)\r\nif err != nil {\r\n panic(err)\r\n}\r\n\r\nvar myValue string\r\nerr = getResult.Content(&myValue)\r\nif err != nil {\r\n panic(err)\r\n}\r\n\r\nctx, cancel := context.WithTimeout(context.Background(), 10*time.Millisecond)\r\ndefer cancel()\r\nresults, err := cluster.Query(\"SELECT `bucket-name`.* from `bucket-name` LIMIT 10\", &gocb.QueryOptions{\r\n\tContext: ctx,\r\n})\r\nif err != nil {\r\n panic(err)\r\n}\r\nvar myQueryValue interface{}\r\nfor results.Next(&myQueryValue) {\r\n}\r\n\r\nerr = results.Close() \r\nif err != nil { \r\n panic(err) \r\n}\r\n<\/pre>\n\u00bfC\u00f3mo se versiona?<\/h2>\n