httpaccess

package

v0.0.17 Latest Latest Go to latest Published: Mar 24, 2023 License: MIT Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/qabalwrap/qabalwrap-1

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type ClientExchangeMode
- func (m ClientExchangeMode) MarshalText() (text []byte, err error)
- func (m *ClientExchangeMode) UnmarshalText(text []byte) (err error)
type HTTPClientAccessProvider
- func NewHTTPClientAccessProvider(ctx context.Context, sharedSecretText string, messageBufferCount int, ...) (provider *HTTPClientAccessProvider, err error)
type HTTPServeAccessProvider
- func NewHTTPServeAccessProvider(accessChannelSize int) (p *HTTPServeAccessProvider)

Constants ¶

View Source

const HTTPClientAccessProviderUserAgent = "qabalwrap-access/0.0.0"

Variables ¶

View Source

var ErrEmitMessageTimeout = errors.New("emit message timeout")

ErrEmitMessageTimeout indicate timeout occurs on message emit.

View Source

var ErrPayloadDecrypt = errors.New("decrypt failed")

ErrPayloadDecrypt indicate failed on decrypting payload.

Functions ¶

This section is empty.

Types ¶

type ClientExchangeMode ¶

type ClientExchangeMode int32

const (
	ClientUnknownExchangeMode ClientExchangeMode = iota
	ClientBinaryExchangeMode
	ClientTextExchangeMode
)

func (ClientExchangeMode) MarshalText ¶

func (m ClientExchangeMode) MarshalText() (text []byte, err error)

func (*ClientExchangeMode) UnmarshalText ¶

func (m *ClientExchangeMode) UnmarshalText(text []byte) (err error)

type HTTPClientAccessProvider ¶

type HTTPClientAccessProvider struct {
	qabalwrap.ServiceBase
	// contains filtered or unexported fields
}

func NewHTTPClientAccessProvider ¶

func NewHTTPClientAccessProvider(ctx context.Context, sharedSecretText string, messageBufferCount int,
	targetServerURL *url.URL, httpHostOverride string,
	channelIndex int, exchangeMode ClientExchangeMode,
	skipTLSVerify bool) (provider *HTTPClientAccessProvider, err error)

func (*HTTPClientAccessProvider) BlockingEmitMessage ¶

func (p *HTTPClientAccessProvider) BlockingEmitMessage(spanEmitter *qabalwrap.TraceEmitter, rawMessage *qabalwrap.EnvelopedMessage) (err error)

func (*HTTPClientAccessProvider) GetServiceInstanceIdentifier ¶ added in v0.0.14

func (p *HTTPClientAccessProvider) GetServiceInstanceIdentifier() (serviceInstIdent qabalwrap.ServiceInstanceIdentifier)

func (*HTTPClientAccessProvider) NonblockingEmitMessage ¶

func (p *HTTPClientAccessProvider) NonblockingEmitMessage(spanEmitter *qabalwrap.TraceEmitter, rawMessage *qabalwrap.EnvelopedMessage) (emitSuccess bool)

func (*HTTPClientAccessProvider) ReceiveMessage ¶

func (p *HTTPClientAccessProvider) ReceiveMessage(spanEmitter *qabalwrap.TraceEmitter, rawMessage *qabalwrap.EnvelopedMessage) (err error)

ReceiveMessage implement ServiceProvider interface.

func (*HTTPClientAccessProvider) RelayProviders ¶

func (p *HTTPClientAccessProvider) RelayProviders() (relayProviders []qabalwrap.RelayProvider)

RelayProviders return associated relay providers if available. Return nil if this service provider does not support relay service.

func (*HTTPClientAccessProvider) SetMessageDispatcher ¶

func (p *HTTPClientAccessProvider) SetMessageDispatcher(spanEmitter *qabalwrap.TraceEmitter, dispatcher qabalwrap.MessageDispatcher)

func (*HTTPClientAccessProvider) Setup ¶ added in v0.0.13

func (p *HTTPClientAccessProvider) Setup(
	serviceInstIdent qabalwrap.ServiceInstanceIdentifier,
	diagnosisEmitter *qabalwrap.DiagnosisEmitter,
	certProvider qabalwrap.CertificateProvider) (err error)

Setup prepare provider for operation. Should only invoke at maintenance thread in setup stage.

func (*HTTPClientAccessProvider) Start ¶

func (p *HTTPClientAccessProvider) Start(ctx context.Context, waitGroup *sync.WaitGroup, spanEmitter *qabalwrap.TraceEmitter) (err error)

Start service instance for operation. Should only invoke at maintenance thread in setup stage.

type HTTPServeAccessProvider ¶

type HTTPServeAccessProvider struct {
	qabalwrap.ServiceBase
	// contains filtered or unexported fields
}

func NewHTTPServeAccessProvider ¶

func NewHTTPServeAccessProvider(accessChannelSize int) (p *HTTPServeAccessProvider)

func (*HTTPServeAccessProvider) AddAccessChannel ¶

func (p *HTTPServeAccessProvider) AddAccessChannel(ctx context.Context, channelIndex int, sharedSecretText string, messageBufferCount int) (relayProvider qabalwrap.RelayProvider, err error)

AddAccessChannel create new access channel in access provider. Must only invoke at setup stage.

func (*HTTPServeAccessProvider) ReceiveMessage ¶

func (p *HTTPServeAccessProvider) ReceiveMessage(spanEmitter *qabalwrap.TraceEmitter, rawMessage *qabalwrap.EnvelopedMessage) (err error)

ReceiveMessage implement ServiceProvider interface.

func (*HTTPServeAccessProvider) RelayProviders ¶

func (p *HTTPServeAccessProvider) RelayProviders() (relayProviders []qabalwrap.RelayProvider)

RelayProviders return associated relay providers if available. Return nil if this service provider does not support relay service.

func (*HTTPServeAccessProvider) ServeHTTP ¶

func (p *HTTPServeAccessProvider) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*HTTPServeAccessProvider) Setup ¶ added in v0.0.13

func (p *HTTPServeAccessProvider) Setup(
	serviceInstIdent qabalwrap.ServiceInstanceIdentifier,
	diagnosisEmitter *qabalwrap.DiagnosisEmitter,
	certProvider qabalwrap.CertificateProvider) (err error)

Setup prepare provider for operation. Should only invoke at maintenance thread in setup stage.

Source Files ¶

View all Source files

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