azcosmosdb

Documentation

Index

• type Config
• type Producer
  • func (p *Producer) Close() error
  • func (p *Producer) Initialize(configFile string)
  • func (p *Producer) Produce(_ []byte, v []byte, _ any)

Types

type Config

type Config struct {
	Endpoint          string `json:"endpoint"`
	PrimaryAccountKey string `json:"primary_account_key"`
	Database          string `json:"database"`
	Container         string `json:"container"`
	PartitionKey      string `json:"partition_key"`
}

type Producer

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

func (*Producer) Close

func (p *Producer) Close() error

func (*Producer) Initialize

func (p *Producer) Initialize(configFile string)

func (*Producer) Produce

func (p *Producer) Produce(_ []byte, v []byte, _ any)