rpc

package
v0.0.0-...-04aea23 Latest Latest
Warning

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

Go to latest
Published: Jul 16, 2021 License: LGPL-2.1 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrorShuttingDown = errors.New("shutting down")
	ErrorBadPath      = errors.New("unknown path provided")
)

Functions

This section is empty.

Types

type Client

type Client struct {
	RpcServerAddress  string `yaml:"serverAddress"`
	RpcCertFile       string `yaml:"certFile"`
	FlyvoApiEndpoints Flyvo  `yaml:"flyvo"`

	PollFrequency   time.Duration  `yaml:"pollFrequency"`
	BadConnectSleep time.Duration  `yaml:"connFailSleep"`
	ConnTimeout     *time.Duration `yaml:"connTimeout"`

	ConnOK bool
	// contains filtered or unexported fields
}

func (*Client) DeleteEvent

func (c *Client) DeleteEvent(ctx context.Context, eventId string) (*tipRPC.Generic, error)

func (*Client) PostEvent

func (c *Client) PostEvent(ctx context.Context, message *tipRPC.Event) (*tipRPC.Generic, error)

func (*Client) PutEvent

func (c *Client) PutEvent(ctx context.Context, message *tipRPC.Event) (*tipRPC.Generic, error)

func (*Client) Run

func (c *Client) Run(ctx context.Context)

func (*Client) SendGeneric

func (c *Client) SendGeneric(ctx context.Context, message tipRPC.Generic) (*tipRPC.Generic, error)

SendGeneric - send a generic request

type Flyvo

type Flyvo struct {
	RootAddress string `yaml:"address"`
}

Jump to

Keyboard shortcuts

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