Hazelcast Go Client

package main

import (
	"context"
	"fmt"

	"github.com/hazelcast/hazelcast-go-client"
)

func main() {
	ctx := context.TODO()
	// Start the client with defaults.
	client, err := hazelcast.StartNewClient(ctx)
	if err != nil {
		panic(err)
	}
	// Get a reference to the replicated map.
	myMap, err := client.GetReplicatedMap(ctx, "my-replicated-map")
	if err != nil {
		panic(err)
	}
	// Put a value in the map and retrieve the previous value.
	oldValue, err := myMap.Put(ctx, "some-key", "some-value")
	if err != nil {
		panic(err)
	}
	fmt.Println("Previous value:", oldValue)
	// Get the value back and print it.
	value, err := myMap.Get(ctx, "some-key")
	if err != nil {
		panic(err)
	}
	fmt.Println("Got the value back:", value)
}

package main

import (
	"context"
	"fmt"

	"github.com/hazelcast/hazelcast-go-client"
)

func main() {
	ctx := context.TODO()
	// Start the client with defaults.
	client, err := hazelcast.StartNewClient(ctx)
	if err != nil {
		panic(err)
	}
	// Get a reference to the multi map.
	myMap, err := client.GetMultiMap(ctx, "my-multi-map")
	if err != nil {
		panic(err)
	}
	// Put values in the map with the same key.
	err = myMap.PutAll(ctx, "some-key", "some-value-1", "some-value-2", "some-value-3")
	if err != nil {
		panic(err)
	}
	// Get the values back and print it.
	values, err := myMap.Get(ctx, "some-key")
	if err != nil {
		panic(err)
	}
	fmt.Println("Got the values back:", values)
}

package main

import (
	"context"
	"fmt"

	"github.com/hazelcast/hazelcast-go-client"
)

func main() {
	ctx := context.TODO()
	// Start the client with defaults.
	client, err := hazelcast.StartNewClient(ctx)
	if err != nil {
		panic(err)
	}
	// Get a reference to the set.
	mySet, err := client.GetSet(ctx, "my-set")
	if err != nil {
		panic(err)
	}
	// Add items to set.
	// Note that value1 is added twice.
	changed, err := mySet.AddAll(ctx, "value1", "value2", "value1", "value3")
	if err != nil {
		panic(err)
	}
	fmt.Println("Was the set changed?", changed)
	// Print contents of the set
	items, err := mySet.GetAll(ctx)
	if err != nil {
		panic(err)
	}
	// Get the items back and print them.
	fmt.Println("Got the items back:", items)
}

package main

import (
	"context"
	"fmt"

	"github.com/hazelcast/hazelcast-go-client"
)

func main() {
	ctx := context.TODO()
	// Start the client with defaults.
	client, err := hazelcast.StartNewClient(ctx)
	if err != nil {
		panic(err)
	}
	// Get a reference to the list.
	myList, err := client.GetList(ctx, "my-list")
	if err != nil {
		panic(err)
	}
	_, err = myList.AddAll(ctx, "tic", "toc")
	if err != nil {
		panic(err)
	}
	// Get and print list items.
	items, err := myList.GetAll(ctx)
	if err != nil {
		panic(err)
	}
	fmt.Println("List items:", items)
} 

package main

import (
	"context"
	"fmt"

	"github.com/hazelcast/hazelcast-go-client"
)

func main() {
	ctx := context.TODO()
	// Start the client with defaults.
	client, err := hazelcast.StartNewClient(ctx)
	if err != nil {
		panic(err)
	}
	// Get a reference to the queue.
	myQueue, err := client.GetQueue(ctx, "my-queue")
	if err != nil {
		panic(err)
	}
	// Add an item to the queue if space is available (non-blocking).
	added, err := myQueue.Add(ctx, "item 1")
	if err != nil {
		panic(err)
	}
	fmt.Println("Added?", added)
	// Get the head of the queue if available and print item.
	item, err := myQueue.Poll(ctx)
	if err != nil {
		panic(err)
	}
	fmt.Println("Got item:", item)
}

package main

import (
	"context"
	"fmt"

	"github.com/hazelcast/hazelcast-go-client"
)

// messageListener handles incoming messages to the topic.
func messageListener(event *hazelcast.MessagePublished) {
	fmt.Println("Received message: ", event.Value)
}

func main() {
	ctx := context.TODO()
	// Start the client with defaults.
	client, err := hazelcast.StartNewClient(ctx)
	if err != nil {
		panic(err)
	}
	// Get a reference to the queue.
	myTopic, err := client.GetTopic(ctx, "my-topic")
	if err != nil {
		panic(err)
	}
	// Add a message listener to the topic.
	_, err = myTopic.AddMessageListener(ctx, messageListener)
	if err != nil {
		panic(err)
	}
	// Publish messages to topic
	for i := 0; i < 10; i++ {
		err = myTopic.Publish(ctx, fmt.Sprintf("Message %d", i))
		if err != nil {
			panic(err)
		}
	}
	// Shutdown the client.
	client.Shutdown(ctx)
}

package main

import (
	"context"
	"fmt"

	"github.com/hazelcast/hazelcast-go-client"
	"github.com/hazelcast/hazelcast-go-client/predicate"
	"github.com/hazelcast/hazelcast-go-client/serialization"
)

func main() {
	ctx := context.TODO()
	// Start the client with defaults.
	client, err := hazelcast.StartNewClient(ctx)
	if err != nil {
		panic(err)
	}
	// Get a reference to the map.
	myMap, err := client.GetMap(ctx, "my-map")
	if err != nil {
		panic(err)
	}
	// Populate the map, error handling is omitted here for brevity
	_ = myMap.Set(ctx, "key-1", serialization.JSON(`{"property: 5}`))
	_ = myMap.Set(ctx, "key-2", serialization.JSON(`{"property": 10}`))
	_ = myMap.Set(ctx, "key-3", serialization.JSON(`{"property": 15}`))
	// Filter the entries in the map based on a predicate and print those.
	pred := predicate.And(predicate.Greater("property", 8), predicate.Less("property", 12))
	entries, err := myMap.GetEntrySetWithPredicate(ctx, pred)
	if err != nil {
		panic(err)
	}
	fmt.Println(entries)
}