Documentation
¶
Index ¶
Constants ¶
View Source
const ShutdownReasonSignal = "signal"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CompleteMessage ¶
type ProtocolError ¶
func (*ProtocolError) Error ¶
func (e *ProtocolError) Error() string
type Registration ¶
type Registration struct {
RunnerID string `json:"runner_id"`
FleetID string `json:"fleet_id"`
AccessToken string `json:"access_token"`
Ephemeral bool `json:"ephemeral"`
}
Registration is the identity and revocable credential returned after the server consumes a generic or task-specific registration token.
type RegistrationDetails ¶
type Session ¶
type Session struct {
// contains filtered or unexported fields
}
Session owns reconnects and serializes all writes for each WebSocket.
func NewSession ¶
func NewSession(config SessionConfig) (*Session, error)
func (*Session) Cancellations ¶
func (*Session) Complete ¶
func (s *Session) Complete(ctx context.Context, message CompleteMessage) error
func (*Session) RequestShutdown ¶
func (*Session) Tasks ¶
func (s *Session) Tasks() <-chan json.RawMessage
Click to show internal directories.
Click to hide internal directories.