sink

Documentation

Index

• type SConfig
• type SReader
• type SServer
  • func NewSinkServer(conf *SServerConfig) *SServer
  • func (ss *SServer) Run(ctx context.Context, incoming chan string, sinks []*SConfig)
• type SServerConfig
• type Sink

Types

type SConfig

type SConfig 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 SReader

type SReader interface {
	Token() string
}

type SServer

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

SinkServer is responsible for pushing tokens to sinks

func NewSinkServer

func NewSinkServer(conf *SServerConfig) *SServer

func (*SServer) Run

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

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

type SServerConfig

type SServerConfig struct {
	Logger        hclog.Logger
	Client        *api.Client
	Context       context.Context
	ExitAfterAuth bool
}

type Sink

type Sink interface {
	WriteToken(string) error
}