main.go

/*
 * Copyright (c) 2022, 2024 Oracle and/or its affiliates.
 * Licensed under the Universal Permissive License v 1.0 as shown at
 * https://oss.oracle.com/licenses/upl.
 */

/*
Package main shows how to run queries against a NamedMap or NamedCache using keys.
*/
package main

import (
	"context"
	"fmt"
	"github.com/oracle/coherence-go-client/v2/coherence"
)

type Person struct {
	ID   int    `json:"id"`
	Name string `json:"name"`
	Age  int    `json:"age"`
}

func main() {
	var ctx = context.Background()

	// create a new Session to the default gRPC port of 1408 using plain text
	session, err := coherence.NewSession(ctx, coherence.WithPlainText())
	if err != nil {
		panic(err)
	}
	defer session.Close()

	namedMap, err := coherence.GetNamedMap[int, Person](session, "people")
	if err != nil {
		panic(err)
	}

	_ = namedMap.Clear(ctx)

	fmt.Println("Adding 10 random people for querying against keys")
	for i := 1; i <= 10; i++ {
		p := Person{ID: i, Name: fmt.Sprintf("Name-%d", i), Age: 15 + i}
		_, err = namedMap.Put(ctx, p.ID, p)
		if err != nil {
			panic(err)
		}
	}

	size, _ := namedMap.Size(ctx)
	fmt.Println("Cache size is", size)

	fmt.Println("Retrieve the people with keys 1, 4 and 5")
	ch := namedMap.GetAll(ctx, []int{1, 4, 5})
	for result := range ch {
		if result.Err != nil {
			panic(err)
		}
		fmt.Println("Key:", result.Key, "Value:", result.Value)
	}
}