gcs

package

v0.4.0 Latest Latest Go to latest Published: May 1, 2025 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	Bucket string `json:"bucket_name"`
}

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

func (p *Producer) Close(_ context.Context) error

func (p *Producer) Initialize(ctx context.Context, configFile string)

func (p *Producer) Produce(ctx context.Context, k []byte, v []byte, _ any)