package deduplication

import "github.com/docker/compose-on-kubernetes/internal/deduplication"

Index ¶

• type StringChan
• func NewStringChan(bufferSize int) *StringChan
• func (c *StringChan) Close()
• func (c *StringChan) In() chan<- string
• func (c *StringChan) Out() <-chan string

Types ¶

type StringChan ¶

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

StringChan is a deduplicating string channel

func NewStringChan ¶

func NewStringChan(bufferSize int) *StringChan

NewStringChan creates a StringChan with the specified buffer size

func (*StringChan) Close ¶

func (c *StringChan) Close()

Close releases all resources

func (*StringChan) In ¶

func (c *StringChan) In() chan<- string

In returns the input channel of the deduplicator

func (*StringChan) Out ¶

func (c *StringChan) Out() <-chan string

Out returns the output channel of the deduplicator

Source Files ¶

stringchannel.go