pkg

Documentation

Overview

* Copyright 2021 The Cerebro Authors * * Licensed under the GNU General Public License v3.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * <https:fsf.org/> * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

* Copyright 2021 The Cerebro Authors * * Licensed under the GNU General Public License v3.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * <https:fsf.org/> * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

Index

• func BytesToString(b []byte) string
• func OrDone[T any](ctx context.Context, c <-chan T) <-chan T
• func Retry(ctx context.Context, max int, f func() error) error
• func StringToBytes(s string) []byte
• func Tee[T any](ctx context.Context, in <-chan T) (_, _ <-chan T)

Functions

func BytesToString

func BytesToString(b []byte) string

func OrDone

func OrDone[T any](ctx context.Context, c <-chan T) <-chan T

func Retry

func Retry(ctx context.Context, max int, f func() error) error

func StringToBytes

func StringToBytes(s string) []byte

func Tee

func Tee[T any](ctx context.Context, in <-chan T) (_, _ <-chan T)