internal

package

v0.0.0-...-1a22241 Latest Latest Go to latest Published: Jan 16, 2019 License: MIT Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/naveego/plugin-pub-csv

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func Debounce(wait time.Duration, fn func()) func()
func NewServer(log hclog.Logger) pub.PublisherServer
type ArchiveAction
type RealTimeSettings
type RealTimeState
- func (r RealTimeState) String() string
type Server
type Settings
- func (s *Settings) Validate() error
type ShapeColumn
type ShapeSettings

Constants ¶

View Source

const (
	CleanupNothing = ArchiveAction("nothing")
	CleanupArchive = ArchiveAction("archive")
	CleanupDelete  = ArchiveAction("delete")
)

Variables ¶

This section is empty.

Functions ¶

func Debounce ¶

func Debounce(wait time.Duration, fn func()) func()

Creates a debounced function that delays invoking fn until after wait milliseconds have elapsed since the last time the debounced function was invoked.

func NewServer ¶

func NewServer(log hclog.Logger) pub.PublisherServer

NewServer creates a new publisher Server.

Types ¶

type ArchiveAction ¶

type ArchiveAction string

type RealTimeSettings ¶

type RealTimeSettings struct {
	StartAtDate            time.Time
	ChangeDebounceInterval time.Duration
}

func (RealTimeSettings) MarshalJSON ¶

func (r RealTimeSettings) MarshalJSON() ([]byte, error)

func (RealTimeSettings) String ¶

func (r RealTimeSettings) String() string

func (*RealTimeSettings) UnmarshalJSON ¶

func (r *RealTimeSettings) UnmarshalJSON(b []byte) error

type RealTimeState ¶

type RealTimeState struct {
	StartAtDate time.Time `json:"startAtDate"`
}

func (RealTimeState) String ¶

func (r RealTimeState) String() string

type Server ¶

type Server struct {
	// contains filtered or unexported fields
}

func (*Server) BeginOAuthFlow ¶

func (s *Server) BeginOAuthFlow(context.Context, *pub.BeginOAuthFlowRequest) (*pub.BeginOAuthFlowResponse, error)

func (*Server) CompleteOAuthFlow ¶

func (s *Server) CompleteOAuthFlow(context.Context, *pub.CompleteOAuthFlowRequest) (*pub.CompleteOAuthFlowResponse, error)

func (*Server) ConfigureConnection ¶

func (s *Server) ConfigureConnection(context.Context, *pub.ConfigureConnectionRequest) (*pub.ConfigureConnectionResponse, error)

func (*Server) ConfigureQuery ¶

func (s *Server) ConfigureQuery(context.Context, *pub.ConfigureQueryRequest) (*pub.ConfigureQueryResponse, error)

func (*Server) ConfigureRealTime ¶

func (s *Server) ConfigureRealTime(ctx context.Context, req *pub.ConfigureRealTimeRequest) (*pub.ConfigureRealTimeResponse, error)

func (*Server) Connect ¶

func (s *Server) Connect(ctx context.Context, req *pub.ConnectRequest) (*pub.ConnectResponse, error)

func (*Server) ConnectSession ¶

func (s *Server) ConnectSession(*pub.ConnectRequest, pub.Publisher_ConnectSessionServer) error

func (*Server) Disconnect ¶

func (s *Server) Disconnect(context.Context, *pub.DisconnectRequest) (*pub.DisconnectResponse, error)

func (*Server) DiscoverShapes ¶

func (s *Server) DiscoverShapes(ctx context.Context, req *pub.DiscoverShapesRequest) (*pub.DiscoverShapesResponse, error)

func (*Server) PublishStream ¶

func (s *Server) PublishStream(req *pub.PublishRequest, stream pub.Publisher_PublishStreamServer) error

type Settings ¶

type Settings struct {
	RootPath      string        `json:"rootPath"`
	Filters       []string      `json:filters`
	CleanupAction ArchiveAction `json:archiveAction`
	ArchivePath   string        `json:"archivePath"`
	HasHeader     bool          `json:"hasHeader"`
	Delimiter     string        `json:"delimiter"`
}

func (*Settings) Validate ¶

func (s *Settings) Validate() error

Validate returns an error if the Settings are not valid. It also populates the internal fields of settings.

type ShapeColumn ¶

type ShapeColumn struct {
	Name   string
	Type   string
	Format string
}

type ShapeSettings ¶

type ShapeSettings struct {
	Name    string
	Columns []ShapeColumn
	Keys    []string
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
pub

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