internal

package
v0.1.1-beta1 Latest Latest
Warning

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

 Go to latest Published: Feb 11, 2019 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.