func main()

in sample/put_bucket_replication.go [22:68]
42 lines of code
4 McCabe index (conditional complexity)

func main() {
	flag.Parse()
	var (
		targetBucket   = "target bucket name"
		targetLocation = "oss-cn-beijing"
	)
	if len(bucketName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, bucket name required")
	}

	if len(region) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, region required")
	}

	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
		WithRegion(region)

	client := oss.NewClient(cfg)

	request := &oss.PutBucketReplicationRequest{
		Bucket: oss.Ptr(bucketName),
		ReplicationConfiguration: &oss.ReplicationConfiguration{
			[]oss.ReplicationRule{
				{
					RTC: &oss.ReplicationTimeControl{
						Status: oss.Ptr("enabled"),
					},
					Destination: &oss.ReplicationDestination{
						Bucket:       oss.Ptr(targetBucket),
						Location:     oss.Ptr(targetLocation),
						TransferType: oss.TransferTypeOssAcc,
					},
					HistoricalObjectReplication: oss.HistoricalObjectReplicationEnabled,
				},
			},
		},
	}
	result, err := client.PutBucketReplication(context.TODO(), request)
	if err != nil {
		log.Fatalf("failed to put bucket replication %v", err)
	}

	log.Printf("put bucket replication result:%#v\n", result)
}