Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

writer

package

Go to main page

Versions in this module

v3

v3.15.4

May 30, 2020

v3.15.2

May 30, 2020

Changes in this version

type AmazonS3Config

+ DisableSSL bool

+ InsecureSkipVerify bool

v3.15.1

May 30, 2020

Changes in this version

+ type AMQP struct

+ func NewAMQP(conf AMQPConfig, log log.Modular, stats metrics.Type) (*AMQP, error)

+ func (a *AMQP) CloseAsync()

+ func (a *AMQP) Connect() error

+ func (a *AMQP) ConnectWithContext(ctx context.Context) error

+ func (a *AMQP) WaitForClose(timeout time.Duration) error

+ func (a *AMQP) Write(msg types.Message) error

+ func (a *AMQP) WriteWithContext(ctx context.Context, msg types.Message) error

+ type AMQPConfig struct

+ BindingKey string

+ Exchange string

+ ExchangeDeclare AMQPExchangeDeclareConfig

+ Immediate bool

+ Mandatory bool

+ MaxInFlight int

+ Persistent bool

+ TLS btls.Config

+ URL string

+ func NewAMQPConfig() AMQPConfig

+ type AMQPExchangeDeclareConfig struct

+ Durable bool

+ Enabled bool

+ Type string

+ type AmazonS3 struct

+ func NewAmazonS3(conf AmazonS3Config, log log.Modular, stats metrics.Type) (*AmazonS3, error)

+ func (a *AmazonS3) CloseAsync()

+ func (a *AmazonS3) Connect() error

+ func (a *AmazonS3) ConnectWithContext(ctx context.Context) error

+ func (a *AmazonS3) WaitForClose(time.Duration) error

+ func (a *AmazonS3) Write(msg types.Message) error

+ func (a *AmazonS3) WriteWithContext(wctx context.Context, msg types.Message) error

+ type AmazonS3Config struct

+ Bucket string

+ ContentEncoding string

+ ContentType string

+ ForcePathStyleURLs bool

+ KMSKeyID string

+ MaxInFlight int

+ Path string

+ StorageClass string

+ Timeout string

+ func NewAmazonS3Config() AmazonS3Config

+ type AmazonSQS struct

+ func NewAmazonSQS(conf AmazonSQSConfig, log log.Modular, stats metrics.Type) (*AmazonSQS, error)

+ func (a *AmazonSQS) CloseAsync()

+ func (a *AmazonSQS) Connect() error

+ func (a *AmazonSQS) ConnectWithContext(ctx context.Context) error

+ func (a *AmazonSQS) WaitForClose(time.Duration) error

+ func (a *AmazonSQS) Write(msg types.Message) error

+ func (a *AmazonSQS) WriteWithContext(ctx context.Context, msg types.Message) error

+ type AmazonSQSConfig struct

+ Batching batch.PolicyConfig

+ MaxInFlight int

+ MessageDeduplicationID string

+ MessageGroupID string

+ URL string

+ func NewAmazonSQSConfig() AmazonSQSConfig

+ type Cache struct

+ func NewCache(conf CacheConfig, mgr types.Manager, log log.Modular, stats metrics.Type) (*Cache, error)

+ func (c *Cache) CloseAsync()

+ func (c *Cache) Connect() error

+ func (c *Cache) ConnectWithContext(ctx context.Context) error

+ func (c *Cache) WaitForClose(time.Duration) error

+ func (c *Cache) Write(msg types.Message) error

+ func (c *Cache) WriteWithContext(ctx context.Context, msg types.Message) error

+ type CacheConfig struct

+ Key string

+ MaxInFlight int

+ Target string

+ func NewCacheConfig() CacheConfig

+ type Drop struct

+ func NewDrop(conf DropConfig, log log.Modular, stats metrics.Type) *Drop

+ func (d *Drop) CloseAsync()

+ func (d *Drop) Connect() error

+ func (d *Drop) WaitForClose(time.Duration) error

+ func (d *Drop) Write(msg types.Message) error

+ type DropConfig struct

+ func NewDropConfig() DropConfig

+ type DynamoDB struct

+ func NewDynamoDB(conf DynamoDBConfig, log log.Modular, stats metrics.Type) (*DynamoDB, error)

+ func (d *DynamoDB) CloseAsync()

+ func (d *DynamoDB) Connect() error

+ func (d *DynamoDB) ConnectWithContext(ctx context.Context) error

+ func (d *DynamoDB) WaitForClose(time.Duration) error

+ func (d *DynamoDB) Write(msg types.Message) error

+ func (d *DynamoDB) WriteWithContext(ctx context.Context, msg types.Message) error

+ type DynamoDBConfig struct

+ Batching batch.PolicyConfig

+ JSONMapColumns map[string]string

+ MaxInFlight int

+ StringColumns map[string]string

+ TTL string

+ TTLKey string

+ Table string

+ func NewDynamoDBConfig() DynamoDBConfig

+ type Elasticsearch struct

+ func NewElasticsearch(conf ElasticsearchConfig, log log.Modular, stats metrics.Type) (*Elasticsearch, error)

+ func (e *Elasticsearch) CloseAsync()

+ func (e *Elasticsearch) Connect() error

+ func (e *Elasticsearch) ConnectWithContext(ctx context.Context) error

+ func (e *Elasticsearch) WaitForClose(timeout time.Duration) error

+ func (e *Elasticsearch) Write(msg types.Message) error

+ func (e *Elasticsearch) WriteWithContext(ctx context.Context, msg types.Message) error

+ type ElasticsearchConfig struct

+ AWS OptionalAWSConfig

+ Auth auth.BasicAuthConfig

+ Batching batch.PolicyConfig

+ Healthcheck bool

+ ID string

+ Index string

+ MaxInFlight int

+ Pipeline string

+ Sniff bool

+ Timeout string

+ Type string

+ URLs []string

+ func NewElasticsearchConfig() ElasticsearchConfig

+ type Files struct

+ func NewFiles(conf FilesConfig, log log.Modular, stats metrics.Type) (*Files, error)

+ func (f *Files) CloseAsync()

+ func (f *Files) Connect() error

+ func (f *Files) ConnectWithContext(ctx context.Context) error

+ func (f *Files) WaitForClose(time.Duration) error

+ func (f *Files) Write(msg types.Message) error

+ func (f *Files) WriteWithContext(ctx context.Context, msg types.Message) error

+ type FilesConfig struct

+ Path string

+ func NewFilesConfig() FilesConfig

+ type GCPPubSub struct

+ func NewGCPPubSub(conf GCPPubSubConfig, log log.Modular, stats metrics.Type) (*GCPPubSub, error)

+ func (c *GCPPubSub) CloseAsync()

+ func (c *GCPPubSub) Connect() error

+ func (c *GCPPubSub) ConnectWithContext(ctx context.Context) error

+ func (c *GCPPubSub) WaitForClose(time.Duration) error

+ func (c *GCPPubSub) Write(msg types.Message) error

+ func (c *GCPPubSub) WriteWithContext(ctx context.Context, msg types.Message) error

+ type GCPPubSubConfig struct

+ MaxInFlight int

+ ProjectID string

+ TopicID string

+ func NewGCPPubSubConfig() GCPPubSubConfig

+ type HDFS struct

+ func NewHDFS(conf HDFSConfig, log log.Modular, stats metrics.Type) (*HDFS, error)

+ func (h *HDFS) CloseAsync()

+ func (h *HDFS) Connect() error

+ func (h *HDFS) ConnectWithContext(ctx context.Context) error

+ func (h *HDFS) WaitForClose(time.Duration) error

+ func (h *HDFS) Write(msg types.Message) error

+ func (h *HDFS) WriteWithContext(ctx context.Context, msg types.Message) error

+ type HDFSConfig struct

+ Directory string

+ Hosts []string

+ MaxInFlight int

+ Path string

+ User string

+ func NewHDFSConfig() HDFSConfig

+ type HTTPClient struct

+ func NewHTTPClient(conf HTTPClientConfig, mgr types.Manager, log log.Modular, stats metrics.Type) (*HTTPClient, error)

+ func (h *HTTPClient) CloseAsync()

+ func (h *HTTPClient) Connect() error

+ func (h *HTTPClient) ConnectWithContext(ctx context.Context) error

+ func (h *HTTPClient) WaitForClose(timeout time.Duration) error

+ func (h *HTTPClient) Write(msg types.Message) error

+ func (h *HTTPClient) WriteWithContext(ctx context.Context, msg types.Message) error

+ type HTTPClientConfig struct

+ Batching batch.PolicyConfig

+ MaxInFlight int

+ PropagateResponse bool

+ func NewHTTPClientConfig() HTTPClientConfig

+ type Kafka struct

+ func NewKafka(conf KafkaConfig, mgr types.Manager, log log.Modular, stats metrics.Type) (*Kafka, error)

+ func (k *Kafka) CloseAsync()

+ func (k *Kafka) Connect() error

+ func (k *Kafka) ConnectWithContext(ctx context.Context) error

+ func (k *Kafka) WaitForClose(timeout time.Duration) error

+ func (k *Kafka) Write(msg types.Message) error

+ func (k *Kafka) WriteWithContext(ctx context.Context, msg types.Message) error

+ type KafkaConfig struct

+ AckReplicas bool

+ Addresses []string

+ Batching batch.PolicyConfig

+ ClientID string

+ Compression string

+ Key string

+ MaxInFlight int

+ MaxMsgBytes int

+ Partitioner string

+ RoundRobinPartitions bool

+ SASL sasl.Config

+ TLS btls.Config

+ TargetVersion string

+ Timeout string

+ Topic string

+ func NewKafkaConfig() KafkaConfig

+ type Kinesis struct

+ func NewKinesis(conf KinesisConfig, log log.Modular, stats metrics.Type) (*Kinesis, error)

+ func (a *Kinesis) CloseAsync()

+ func (a *Kinesis) Connect() error

+ func (a *Kinesis) ConnectWithContext(ctx context.Context) error

+ func (a *Kinesis) WaitForClose(time.Duration) error

+ func (a *Kinesis) Write(msg types.Message) error

+ func (a *Kinesis) WriteWithContext(ctx context.Context, msg types.Message) error

+ type KinesisConfig struct

+ Batching batch.PolicyConfig

+ HashKey string

+ MaxInFlight int

+ PartitionKey string

+ Stream string

+ func NewKinesisConfig() KinesisConfig

+ type KinesisFirehose struct

+ func NewKinesisFirehose(conf KinesisFirehoseConfig, log log.Modular, stats metrics.Type) (*KinesisFirehose, error)

+ func (a *KinesisFirehose) CloseAsync()

+ func (a *KinesisFirehose) Connect() error

+ func (a *KinesisFirehose) ConnectWithContext(ctx context.Context) error

+ func (a *KinesisFirehose) WaitForClose(time.Duration) error

+ func (a *KinesisFirehose) Write(msg types.Message) error

+ func (a *KinesisFirehose) WriteWithContext(ctx context.Context, msg types.Message) error

+ type KinesisFirehoseConfig struct

+ Batching batch.PolicyConfig

+ MaxInFlight int

+ Stream string

+ func NewKinesisFirehoseConfig() KinesisFirehoseConfig

+ type MQTT struct

+ func NewMQTT(conf MQTTConfig, log log.Modular, stats metrics.Type) (*MQTT, error)

+ func (m *MQTT) CloseAsync()

+ func (m *MQTT) Connect() error

+ func (m *MQTT) ConnectWithContext(ctx context.Context) error

+ func (m *MQTT) WaitForClose(timeout time.Duration) error

+ func (m *MQTT) Write(msg types.Message) error

+ func (m *MQTT) WriteWithContext(ctx context.Context, msg types.Message) error

+ type MQTTConfig struct

+ ClientID string

+ MaxInFlight int

+ Password string

+ QoS uint8

+ Topic string

+ URLs []string

+ User string

+ func NewMQTTConfig() MQTTConfig

+ type NATS struct

+ func NewNATS(conf NATSConfig, log log.Modular, stats metrics.Type) (*NATS, error)

+ func (n *NATS) CloseAsync()

+ func (n *NATS) Connect() error

+ func (n *NATS) ConnectWithContext(ctx context.Context) error

+ func (n *NATS) WaitForClose(timeout time.Duration) error

+ func (n *NATS) Write(msg types.Message) error

+ func (n *NATS) WriteWithContext(ctx context.Context, msg types.Message) error

+ type NATSConfig struct

+ MaxInFlight int

+ Subject string

+ URLs []string

+ func NewNATSConfig() NATSConfig

+ type NATSStream struct

+ func NewNATSStream(conf NATSStreamConfig, log log.Modular, stats metrics.Type) (*NATSStream, error)

+ func (n *NATSStream) CloseAsync()

+ func (n *NATSStream) Connect() error

+ func (n *NATSStream) ConnectWithContext(ctx context.Context) error

+ func (n *NATSStream) WaitForClose(timeout time.Duration) error

+ func (n *NATSStream) Write(msg types.Message) error

+ func (n *NATSStream) WriteWithContext(ctx context.Context, msg types.Message) error

+ type NATSStreamConfig struct

+ ClientID string

+ ClusterID string

+ MaxInFlight int

+ Subject string

+ URLs []string

+ func NewNATSStreamConfig() NATSStreamConfig

+ type NSQ struct

+ func NewNSQ(conf NSQConfig, log log.Modular, stats metrics.Type) (*NSQ, error)

+ func (n *NSQ) CloseAsync()

+ func (n *NSQ) Connect() error

+ func (n *NSQ) ConnectWithContext(ctx context.Context) error

+ func (n *NSQ) WaitForClose(timeout time.Duration) error

+ func (n *NSQ) Write(msg types.Message) error

+ func (n *NSQ) WriteWithContext(ctx context.Context, msg types.Message) error

+ type NSQConfig struct

+ Address string

+ MaxInFlight int

+ TLS btls.Config

+ Topic string

+ UserAgent string

+ func NewNSQConfig() NSQConfig

+ type Nanomsg struct

+ func NewNanomsg(conf NanomsgConfig, log log.Modular, stats metrics.Type) (*Nanomsg, error)

+ func (s *Nanomsg) CloseAsync()

+ func (s *Nanomsg) Connect() error

+ func (s *Nanomsg) ConnectWithContext(ctx context.Context) error

+ func (s *Nanomsg) WaitForClose(timeout time.Duration) error

+ func (s *Nanomsg) Write(msg types.Message) error

+ func (s *Nanomsg) WriteWithContext(ctx context.Context, msg types.Message) error

+ type NanomsgConfig struct

+ Bind bool

+ MaxInFlight int

+ PollTimeout string

+ SocketType string

+ URLs []string

+ func NewNanomsgConfig() NanomsgConfig

+ type OptionalAWSConfig struct

+ Enabled bool

+ type RedisHash struct

+ func NewRedisHash(conf RedisHashConfig, log log.Modular, stats metrics.Type) (*RedisHash, error)

+ func (r *RedisHash) CloseAsync()

+ func (r *RedisHash) Connect() error

+ func (r *RedisHash) ConnectWithContext(ctx context.Context) error

+ func (r *RedisHash) WaitForClose(timeout time.Duration) error

+ func (r *RedisHash) Write(msg types.Message) error

+ func (r *RedisHash) WriteWithContext(ctx context.Context, msg types.Message) error

+ type RedisHashConfig struct

+ Fields map[string]string

+ Key string

+ MaxInFlight int

+ URL string

+ WalkJSONObject bool

+ WalkMetadata bool

+ func NewRedisHashConfig() RedisHashConfig

+ type RedisList struct

+ func NewRedisList(conf RedisListConfig, log log.Modular, stats metrics.Type) (*RedisList, error)

+ func (r *RedisList) CloseAsync()

+ func (r *RedisList) Connect() error

+ func (r *RedisList) ConnectWithContext(ctx context.Context) error

+ func (r *RedisList) WaitForClose(timeout time.Duration) error

+ func (r *RedisList) Write(msg types.Message) error

+ func (r *RedisList) WriteWithContext(ctx context.Context, msg types.Message) error

+ type RedisListConfig struct

+ Key string

+ MaxInFlight int

+ URL string

+ func NewRedisListConfig() RedisListConfig

+ type RedisPubSub struct

+ func NewRedisPubSub(conf RedisPubSubConfig, log log.Modular, stats metrics.Type) (*RedisPubSub, error)

+ func (r *RedisPubSub) CloseAsync()

+ func (r *RedisPubSub) Connect() error

+ func (r *RedisPubSub) ConnectWithContext(ctx context.Context) error

+ func (r *RedisPubSub) WaitForClose(timeout time.Duration) error

+ func (r *RedisPubSub) Write(msg types.Message) error

+ func (r *RedisPubSub) WriteWithContext(ctx context.Context, msg types.Message) error

+ type RedisPubSubConfig struct

+ Channel string

+ MaxInFlight int

+ URL string

+ func NewRedisPubSubConfig() RedisPubSubConfig

+ type RedisStreams struct

+ func NewRedisStreams(conf RedisStreamsConfig, log log.Modular, stats metrics.Type) (*RedisStreams, error)

+ func (r *RedisStreams) CloseAsync()

+ func (r *RedisStreams) Connect() error

+ func (r *RedisStreams) ConnectWithContext(ctx context.Context) error

+ func (r *RedisStreams) WaitForClose(timeout time.Duration) error

+ func (r *RedisStreams) Write(msg types.Message) error

+ func (r *RedisStreams) WriteWithContext(ctx context.Context, msg types.Message) error

+ type RedisStreamsConfig struct

+ BodyKey string

+ MaxInFlight int

+ MaxLenApprox int64

+ Stream string

+ URL string

+ func NewRedisStreamsConfig() RedisStreamsConfig

+ type SNS struct

+ func NewSNS(conf SNSConfig, log log.Modular, stats metrics.Type) (*SNS, error)

+ func (a *SNS) CloseAsync()

+ func (a *SNS) Connect() error

+ func (a *SNS) ConnectWithContext(ctx context.Context) error

+ func (a *SNS) WaitForClose(time.Duration) error

+ func (a *SNS) Write(msg types.Message) error

+ func (a *SNS) WriteWithContext(wctx context.Context, msg types.Message) error

+ type SNSConfig struct

+ MaxInFlight int

+ Timeout string

+ TopicArn string

+ func NewSNSConfig() SNSConfig

+ type Socket struct

+ func NewSocket(conf SocketConfig, mgr types.Manager, log log.Modular, stats metrics.Type) (*Socket, error)

+ func (s *Socket) CloseAsync()

+ func (s *Socket) Connect() error

+ func (s *Socket) WaitForClose(timeout time.Duration) error

+ func (s *Socket) Write(msg types.Message) error

+ type SocketConfig struct

+ Address string

+ Network string

+ func NewSocketConfig() SocketConfig

+ type TCP struct

+ func NewTCP(conf TCPConfig, mgr types.Manager, log log.Modular, stats metrics.Type) (*TCP, error)

+ func (t *TCP) CloseAsync()

+ func (t *TCP) Connect() error

+ func (t *TCP) WaitForClose(timeout time.Duration) error

+ func (t *TCP) Write(msg types.Message) error

+ type TCPConfig struct

+ Address string

+ func NewTCPConfig() TCPConfig

+ type Type interface

+ Connect func() error

+ Write func(msg types.Message) error

+ type UDP struct

+ func NewUDP(conf UDPConfig, mgr types.Manager, log log.Modular, stats metrics.Type) (*UDP, error)

+ func (t *UDP) CloseAsync()

+ func (t *UDP) Connect() error

+ func (t *UDP) WaitForClose(timeout time.Duration) error

+ func (t *UDP) Write(msg types.Message) error

+ type UDPConfig struct

+ Address string

+ func NewUDPConfig() UDPConfig

+ type Websocket struct

+ func NewWebsocket(conf WebsocketConfig, log log.Modular, stats metrics.Type) (*Websocket, error)

+ func (w *Websocket) CloseAsync()

+ func (w *Websocket) Connect() error

+ func (w *Websocket) WaitForClose(timeout time.Duration) error

+ func (w *Websocket) Write(msg types.Message) error

+ type WebsocketConfig struct

+ URL string

+ func NewWebsocketConfig() WebsocketConfig

+ type ZMQ4Config struct

+ func NewZMQ4Config() *ZMQ4Config

Other modules containing this package

github.com/windhooked/benthos