Help us shape the future of Go! Take the 2026 Go Developer Survey

sink

package
v0.10.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 25, 2018 License: MPL-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Sink

type Sink interface {
	WriteToken(string) error
}

type SinkConfig

type SinkConfig struct {
	Sink
	Logger  hclog.Logger
	Config  map[string]interface{}
	Client  *api.Client
	WrapTTL time.Duration
	DHType  string
	DHPath  string
	AAD     string
	// contains filtered or unexported fields
}

type SinkServer

type SinkServer struct {
	DoneCh chan struct{}
	// contains filtered or unexported fields
}

SinkServer is responsible for pushing tokens to sinks

func NewSinkServer

func NewSinkServer(conf *SinkServerConfig) *SinkServer

func (*SinkServer) Run

func (ss *SinkServer) Run(ctx context.Context, incoming chan string, sinks []*SinkConfig)

Run executes the server's run loop, which is responsible for reading in new tokens and pushing them out to the various sinks.

type SinkServerConfig

type SinkServerConfig struct {
	Logger  hclog.Logger
	Client  *api.Client
	Context context.Context
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL