omerkaya1

func (c *ClientImpl) PostLargeFile(reader io.ReadCloser, formParams map[string]string) (io.ReadCloser, error) {
	r, w := io.Pipe()
	writer := multipart.NewWriter(w)
	defer r.Close()

	go func() {
		defer w.Close()
		defer reader.Close()

		for key, val := range formParams {

omerkaya1

<table mat-table [dataSource]="tableData" style="width: 100%">
    <ng-container [matColumnDef]="col" *ngFor="let col of tableData[0] | keys">
        <th mat-header-cell *matHeaderCellDef> {{ col }} </th>s
        <td mat-cell *matCellDef="let element"> {{ element[col] }} </td>
    </ng-container>

    <tr mat-header-row *matHeaderRowDef="tableData[0] | keys"></tr>
    <tr mat-row *matRowDef="let row; columns: tableData[0] | keys;"></tr>
</table>

omerkaya1

package mq

import (
	"context"
	"time"

	"github.com/pkg/errors"
	"github.com/streadway/amqp"
)

omerkaya1

job "api-gw" {
  datacenters = ["dc1"]
  type = "service"
  # Update policy
  update {
    max_parallel = 1
    min_healthy_time = "10s"
    healthy_deadline = "3m"
    progress_deadline = "10m"
    auto_revert = true

omerkaya1

#!/bin/bash

BRANCH=$(git branch --show-current)
COMMIT_HASH=$(git rev-parse --short HEAD)

for i in {1..5} ; do
    printf "Phase %s\n" "$i"
    if ! curl -s "localhost:8000/debug/pprof/heap" >  mem-"$BRANCH"-"$COMMIT_HASH"-"$(date "+%Y-%m-%d-%H-%M-%S")".pprof
    then
      echo "failed to get mem profile"

omerkaya1

config:
  environments:
    local:
      target: "http://localhost:8000"
      phases:
        - duration: 10
          arrivalRate: 1
          arrivalCount: 200
          maxVusers: 50
          name: "Warm up"

omerkaya1

WITH get AS (
	  SELECT id FROM table_name WHERE name=$1
), new AS (
    INSERT INTO table_name (name) VALUES ($1) ON CONFLICT (name) DO NOTHING RETURNING id 
)
SELECT id FROM get
UNION ALL
SELECT id FROM new;

omerkaya1

WITH ranked_records AS (
    SELECT row_number() OVER (PARTITION BY user_id, user_id ORDER BY created_at DESC) AS rn,
        id, some_other_column, created_at
    FROM user_status WHERE user_id IN (?)
)
SELECT
    id, some_other_column, created_at
FROM ranked_records
WHERE rn=1
ORDER BY user_id;

omerkaya1

WITH
    first AS (
        DELETE FROM table1 WHERE condition1
            RETURNING *
    ),
    second AS (
        DELETE FROM table2 WHERE condition2
            RETURNING *
    ),
    -- add more analogous delete statements

omerkaya1

// SizedPool is a channel-based pool of slices objects.
// It retains an arbitrary number of slices of objects and ensures their initial capacity.
type SizedPool[T any] struct {
	pool chan []T
	cap  int
}

func NewSizedPool[T any](size int, cap int) *SizedPool[T] {
	return &SizedPool[T]{
		pool: make(chan []T, size),