sink

package
v1.5.0 Latest Latest
Warning

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

Go to latest
Published: Jul 18, 2020 License: MPL-2.0 Imports: 12 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 SinkReader added in v1.1.0

type SinkReader interface {
	Token() string
}

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
	ExitAfterAuth bool
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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