sink

Documentation

Index

• type Sink
• type SinkConfig
• type SinkReader
• type SinkServer
  • func NewSinkServer(conf *SinkServerConfig) *SinkServer
  • func (ss *SinkServer) Run(ctx context.Context, incoming chan string, sinks []*SinkConfig) error
• type SinkServerConfig

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
	DeriveKey bool
	AAD       string
	// contains filtered or unexported fields
}

type SinkReader

type SinkReader interface {
	Token() string
}

type SinkServer

type SinkServer 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) error

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
}