gocloud

README

go-webhookd-gocloud

Go package to implement the whosonfirst/go-webhookd interfaces for dispatching messages to gocloud.dev/blob resources.

Documentation

go-webhookd

Before you begin please read the go-webhookd documentation for an overview of concepts and principles.

Usage

import (
	_ "github.com/whosonfirst/go-webhookd-gocloud"
)

Example

import (
	_ "gocloud.dev/blob/memblob"
)

import (
	"context"
	"github.com/whosonfirst/go-webhookd/v3/dispatcher"
	_ "github.com/whosonfirst/go-webhookd-gocloud"
)

func main()

	ctx := context.Background()          
	d, _ := dispatcher.NewDispatcher(ctx, "mem://")
	
	d.Dispatch(ctx, []byte("hello world"))
}	

Error handling omitted for the sake of brevity.

See also

• https://github.com/whosonfirst/go-webhookd
• https://gocloud.dev/

Documentation

Overview

package gocloud provides implementations of the whosonfirst/go-webhookd 'Dispatcher' interfaces for GoCloud resources.

Index

• func HashBody(ctx context.Context, body []byte) (string, error)
• func NewBlobDispatcher(ctx context.Context, uri string) (webhookd.WebhookDispatcher, error)
• type BlobDispatcher
  • func (d *BlobDispatcher) Dispatch(ctx context.Context, body []byte) *webhookd.WebhookError

Functions

func HashBody

func HashBody(ctx context.Context, body []byte) (string, error)

HashBody returns the hex-encoded SHA-256 sum of ' body'

func NewBlobDispatcher

func NewBlobDispatcher(ctx context.Context, uri string) (webhookd.WebhookDispatcher, error)

NewBlobDispatcher returns a new `BlobDispatcher` instance configured by 'uri' which is expected to be a valid and registered `gocloud.dev/blob.Bucket` URI. The following extra parameters are supported (and removed before the underelying bucket instance is created): - `?dispatch_prefix=_ts_` If present a unix timestamp will be prepended to the final filename.

Types

type BlobDispatcher

type BlobDispatcher struct {
	webhookd.WebhookDispatcher
	// contains filtered or unexported fields
}

BlobDispatcher implements the `webhookd.WebhookDispatcher` interface for dispatching messages to a gocloud.dev/blob.Bucket instance. Messages are written to the underlying bucket instance with a filename derived from the SHA-256 hash of the message body.

func (*BlobDispatcher) Dispatch

func (d *BlobDispatcher) Dispatch(ctx context.Context, body []byte) *webhookd.WebhookError

Dispatch will write 'body' to the underlying `gocloud.dev/blob.Bucket` instance contained by 'd'. Filenames are derived from the SHA-256 hash for 'body'.