mirror of
https://github.com/FlipsideCrypto/go-data-bridge-client.git
synced 2026-02-06 02:37:33 +00:00
| .gitignore | ||
| client_test.go | ||
| client.go | ||
| consumer.go | ||
| go.mod | ||
| go.sum | ||
| README.md | ||
| record.go | ||
go-data-bridge-client
Go client for accessing Data Bridge
https://data-bridge-docs.flipsidecrypto.com/#section/Introduction
Usage
Initialization
config := Config{APIKey: "api-key", TopicSlug: "my-topic-slug"}
client, err := NewClient(config)
Get Registered Consumers
consumers, err := client.GetRegisteredConsumers()
Get Available Consumers
consumers, err := client.GetAvailableConsumers()
Register Consumer
consumer, err := client.RegisterConsumer()
Get Next Record
record, err := client.GetNextRecord(consumerID)
Mark Record Completed
err := client.CompleteRecord(record)
Mark Record Failed
err := client.FailRecord(record)
Publish New Record
err := client.PublishRecord(data)