azure

README

Azure Blob Storage

This sink implements Azure Blob Storage protocol. It can can be enabled by adding the following configuration in the storage section:

storage:
  compact:                               # enable compaction
    interval: 60                         # compact every 60 seconds
    nameFunc: "s3://bucket/namefunc.lua" # file name function
    azure:                               # sink to use
      container: "container-id-1"        # the container ID
      prefix: ""                         # (optional) prefix to add
...

Documentation

Index

• type Writer
  • func New(container, prefix string) (*Writer, error)
  • func (w *Writer) Write(key key.Key, val []byte) error

Types

type Writer

type Writer struct {
	// contains filtered or unexported fields
}

Writer represents a writer for Microsoft Azure.

func New

func New(container, prefix string) (*Writer, error)

New creates a new writer.

func (*Writer) Write

func (w *Writer) Write(key key.Key, val []byte) error

Write writes the data to the sink.