https

package
v0.1.13 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 5, 2024 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Overview

Package https provides comms.Communicator implementations which connect to the Fleetspeak server using HTTPS.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Communicator

type Communicator struct {
	DialContext func(ctx context.Context, network, addr string) (net.Conn, error) // If set, will be used to initiate network connections to the server.
	// contains filtered or unexported fields
}

Communicator implements comms.Communicator and communicates with a Fleetspeak server using https.

func (*Communicator) GetFileIfModified

func (c *Communicator) GetFileIfModified(ctx context.Context, service, name string, modSince time.Time) (io.ReadCloser, time.Time, error)

func (*Communicator) Setup

func (c *Communicator) Setup(cl comms.Context) error

Setup implements comms.Communicator.

func (*Communicator) Start

func (c *Communicator) Start() error

Start implements comms.Communicator.

func (*Communicator) Stop

func (c *Communicator) Stop()

Stop implements comms.Communicator.

type StreamingCommunicator

type StreamingCommunicator struct {
	DialContext func(ctx context.Context, network, addr string) (net.Conn, error) // If set, will be used to initiate network connections to the server.
	// contains filtered or unexported fields
}

StreamingCommunicator is a comms.Communicator that communicates with the fleetspeak server via HTTPS and long lived connections.

func (*StreamingCommunicator) GetFileIfModified

func (c *StreamingCommunicator) GetFileIfModified(ctx context.Context, service, name string, modSince time.Time) (io.ReadCloser, time.Time, error)

func (*StreamingCommunicator) Setup

Setup implements comms.Communicator.

func (*StreamingCommunicator) Start

func (c *StreamingCommunicator) Start() error

Start implements comms.Communicator.

func (*StreamingCommunicator) Stop

func (c *StreamingCommunicator) Stop()

Stop implements comms.Communicator.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL