Documentation
¶
Index ¶
- Constants
- type Client
- func (c *Client) CloseSession(sessionID string) error
- func (c *Client) CreateSession(plugin, connectionID string, opts sdklogs.CreateSessionOptions) (*sdklogs.LogSession, error)
- func (c *Client) GetSession(sessionID string) (*sdklogs.LogSession, error)
- func (c *Client) GetSupportedResources(pluginID string) []sdklogs.Handler
- func (c *Client) ListSessions() ([]*sdklogs.LogSession, error)
- func (c *Client) PauseSession(sessionID string) error
- func (c *Client) ResumeSession(sessionID string) error
- func (c *Client) UpdateSessionOptions(sessionID string, opts sdklogs.LogSessionOptions) (*sdklogs.LogSession, error)
- type Controller
Constants ¶
View Source
const ( BatchFlushInterval = 50 * time.Millisecond BatchMaxSize = 100 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func NewClient ¶
func NewClient(controller Controller) *Client
func (*Client) CloseSession ¶
func (*Client) CreateSession ¶
func (c *Client) CreateSession( plugin, connectionID string, opts sdklogs.CreateSessionOptions, ) (*sdklogs.LogSession, error)
func (*Client) GetSession ¶
func (c *Client) GetSession(sessionID string) (*sdklogs.LogSession, error)
func (*Client) GetSupportedResources ¶
func (*Client) ListSessions ¶
func (c *Client) ListSessions() ([]*sdklogs.LogSession, error)
func (*Client) PauseSession ¶
func (*Client) ResumeSession ¶
func (*Client) UpdateSessionOptions ¶
func (c *Client) UpdateSessionOptions( sessionID string, opts sdklogs.LogSessionOptions, ) (*sdklogs.LogSession, error)
type Controller ¶
type Controller interface {
internaltypes.Controller
Run(ctx context.Context)
GetSupportedResources(pluginID string) []logs.Handler
CreateSession(plugin, connectionID string, opts logs.CreateSessionOptions) (*logs.LogSession, error)
GetSession(sessionID string) (*logs.LogSession, error)
ListSessions() ([]*logs.LogSession, error)
CloseSession(sessionID string) error
SendCommand(sessionID string, cmd logs.LogStreamCommand) error
UpdateSessionOptions(sessionID string, opts logs.LogSessionOptions) (*logs.LogSession, error)
}
Controller manages log sessions across all plugins.
func NewController ¶
func NewController( logger *zap.SugaredLogger, sp pkgsettings.Provider, resourceClient resource.IClient, ) Controller
Source Files
Click to show internal directories.
Click to hide internal directories.