csbouncer

Sep 17, 2023

Changes in this version

+ type SSEReader struct

+ func (a *SSEReader) Read(p []byte) (int, error)

Sep 15, 2023

Changes in this version

+ type EventStreamReader struct

+ func NewEventStreamReader(eventStream io.Reader, maxBufferSize int) *EventStreamReader

+ func (e *EventStreamReader) ReadEvent() ([]byte, error)

Jul 13, 2023

Changes in this version

+ type Client struct

+ APIKey string

+ URL string

+ UserAgent string

+ func (c *Client) StreamDecisionConnect(ctx context.Context, opts apiclient.DecisionsStreamOpts) (*http.Response, error)

type StreamBouncer

+ STREAMClient *Client

Jul 12, 2023

Changes in this version

type StreamBouncer

+ func (b *StreamBouncer) RunStream(ctx context.Context)

May 10, 2023

Changes in this version

+ var TotalLAPICalls prometheus.Counter = prometheus.NewCounter(prometheus.CounterOpts{ ... })

+ var TotalLAPIError prometheus.Counter = prometheus.NewCounter(prometheus.CounterOpts{ ... })

+ type LiveBouncer struct

+ APIClient *apiclient.ApiClient

+ APIKey string

+ APIUrl string

+ CAPath string

+ CertPath string

+ InsecureSkipVerify *bool

+ KeyPath string

+ UserAgent string

+ func (b *LiveBouncer) Config(configPath string) error

+ func (b *LiveBouncer) ConfigReader(configReader io.Reader) error

+ func (b *LiveBouncer) Get(value string) (*models.GetDecisionsResponse, error)

+ func (b *LiveBouncer) Init() error

+ type StreamBouncer struct

+ APIClient *apiclient.ApiClient

+ APIKey string

+ APIUrl string

+ CAPath string

+ CertPath string

+ InsecureSkipVerify *bool

+ KeyPath string

+ Opts apiclient.DecisionsStreamOpts

+ Origins []string

+ ScenariosContaining []string

+ ScenariosNotContaining []string

+ Scopes []string

+ Startup bool

+ Stream chan *models.DecisionsStreamResponse

+ TickerInterval string

+ TickerIntervalDuration time.Duration

+ UserAgent string

+ func (b *StreamBouncer) Config(configPath string) error

+ func (b *StreamBouncer) ConfigReader(configReader io.Reader) error

+ func (b *StreamBouncer) Init() error

+ func (b *StreamBouncer) Run(ctx context.Context)