buffer

Documentation

Overview

* Copyright (c) 2022 Manabu Sonoda * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * 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

• type RingBuffer
  • func NewRingBuffer(size uint, inCounter, lostCounter types.Counter) *RingBuffer
  • func (r *RingBuffer) Close()
  • func (r *RingBuffer) Read() <-chan *types.DnstapMessage
  • func (r *RingBuffer) Write(dt *types.DnstapMessage)

Types

type RingBuffer

type RingBuffer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewRingBuffer

func NewRingBuffer(size uint, inCounter, lostCounter types.Counter) *RingBuffer

func (*RingBuffer) Close

func (r *RingBuffer) Close()

func (*RingBuffer) Read

func (r *RingBuffer) Read() <-chan *types.DnstapMessage

func (*RingBuffer) Write

func (r *RingBuffer) Write(dt *types.DnstapMessage)