pbsql

package
v1.0.1-0...-0345bc3 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Service_Engine_name = map[int32]string{
		0: "unset",
		1: "postgres",
		2: "clickhouse",
	}
	Service_Engine_value = map[string]int32{
		"unset":      0,
		"postgres":   1,
		"clickhouse": 2,
	}
)

Enum value maps for Service_Engine.

View Source 
var File_sf_substreams_sink_sql_v1_services_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type DBTConfig 

type DBTConfig struct {
	Files              []byte `protobuf:"bytes,1,opt,name=files,proto3" json:"files,omitempty"`
	RunIntervalSeconds int32  `protobuf:"varint,2,opt,name=run_interval_seconds,json=runIntervalSeconds,proto3" json:"run_interval_seconds,omitempty"`
	Enabled            bool   `protobuf:"varint,3,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

https://www.getdbt.com/product/what-is-dbt

func (*DBTConfig) Descriptor deprecated 

func (*DBTConfig) Descriptor() ([]byte, []int)

Deprecated: Use DBTConfig.ProtoReflect.Descriptor instead.

func (*DBTConfig) GetEnabled 

func (x *DBTConfig) GetEnabled() bool

func (*DBTConfig) GetFiles 

func (x *DBTConfig) GetFiles() []byte

func (*DBTConfig) GetRunIntervalSeconds 

func (x *DBTConfig) GetRunIntervalSeconds() int32

func (*DBTConfig) ProtoMessage 

func (*DBTConfig) ProtoMessage()

func (*DBTConfig) ProtoReflect 

func (x *DBTConfig) ProtoReflect() protoreflect.Message

func (*DBTConfig) Reset 

func (x *DBTConfig) Reset()

func (*DBTConfig) String 

func (x *DBTConfig) String() string

type HasuraFrontend 

type HasuraFrontend struct {
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

https://hasura.io/docs/latest/index/

func (*HasuraFrontend) Descriptor deprecated 

func (*HasuraFrontend) Descriptor() ([]byte, []int)

Deprecated: Use HasuraFrontend.ProtoReflect.Descriptor instead.

func (*HasuraFrontend) GetEnabled 

func (x *HasuraFrontend) GetEnabled() bool

func (*HasuraFrontend) ProtoMessage 

func (*HasuraFrontend) ProtoMessage()

func (*HasuraFrontend) ProtoReflect 

func (x *HasuraFrontend) ProtoReflect() protoreflect.Message

func (*HasuraFrontend) Reset 

func (x *HasuraFrontend) Reset()

func (*HasuraFrontend) String 

func (x *HasuraFrontend) String() string

type PGWebFrontend 

type PGWebFrontend struct {
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

https://github.com/sosedoff/pgweb

func (*PGWebFrontend) Descriptor deprecated 

func (*PGWebFrontend) Descriptor() ([]byte, []int)

Deprecated: Use PGWebFrontend.ProtoReflect.Descriptor instead.

func (*PGWebFrontend) GetEnabled 

func (x *PGWebFrontend) GetEnabled() bool

func (*PGWebFrontend) ProtoMessage 

func (*PGWebFrontend) ProtoMessage()

func (*PGWebFrontend) ProtoReflect 

func (x *PGWebFrontend) ProtoReflect() protoreflect.Message

func (*PGWebFrontend) Reset 

func (x *PGWebFrontend) Reset()

func (*PGWebFrontend) String 

func (x *PGWebFrontend) String() string

type PostgraphileFrontend 

type PostgraphileFrontend struct {
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

https://www.graphile.org/postgraphile/

func (*PostgraphileFrontend) Descriptor deprecated 

func (*PostgraphileFrontend) Descriptor() ([]byte, []int)

Deprecated: Use PostgraphileFrontend.ProtoReflect.Descriptor instead.

func (*PostgraphileFrontend) GetEnabled 

func (x *PostgraphileFrontend) GetEnabled() bool

func (*PostgraphileFrontend) ProtoMessage 

func (*PostgraphileFrontend) ProtoMessage()

func (*PostgraphileFrontend) ProtoReflect 

func (x *PostgraphileFrontend) ProtoReflect() protoreflect.Message

func (*PostgraphileFrontend) Reset 

func (x *PostgraphileFrontend) Reset()

func (*PostgraphileFrontend) String 

func (x *PostgraphileFrontend) String() string

type RESTFrontend 

type RESTFrontend struct {
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

https://github.com/semiotic-ai/sql-wrapper

func (*RESTFrontend) Descriptor deprecated 

func (*RESTFrontend) Descriptor() ([]byte, []int)

Deprecated: Use RESTFrontend.ProtoReflect.Descriptor instead.

func (*RESTFrontend) GetEnabled 

func (x *RESTFrontend) GetEnabled() bool

func (*RESTFrontend) ProtoMessage 

func (*RESTFrontend) ProtoMessage()

func (*RESTFrontend) ProtoReflect 

func (x *RESTFrontend) ProtoReflect() protoreflect.Message

func (*RESTFrontend) Reset 

func (x *RESTFrontend) Reset()

func (*RESTFrontend) String 

func (x *RESTFrontend) String() string

type Service 

type Service struct {

	// Containing both create table statements and index creation statements.
	Schema               string                `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	DbtConfig            *DBTConfig            `protobuf:"bytes,2,opt,name=dbt_config,json=dbtConfig,proto3,oneof" json:"dbt_config,omitempty"`
	HasuraFrontend       *HasuraFrontend       `protobuf:"bytes,4,opt,name=hasura_frontend,json=hasuraFrontend,proto3" json:"hasura_frontend,omitempty"`
	PostgraphileFrontend *PostgraphileFrontend `protobuf:"bytes,5,opt,name=postgraphile_frontend,json=postgraphileFrontend,proto3" json:"postgraphile_frontend,omitempty"`
	Engine               Service_Engine        `protobuf:"varint,7,opt,name=engine,proto3,enum=sf.substreams.sink.sql.v1.Service_Engine" json:"engine,omitempty"`
	RestFrontend         *RESTFrontend         `protobuf:"bytes,8,opt,name=rest_frontend,json=restFrontend,proto3" json:"rest_frontend,omitempty"`
	// contains filtered or unexported fields
}

func (*Service) Descriptor deprecated 

func (*Service) Descriptor() ([]byte, []int)

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetDbtConfig 

func (x *Service) GetDbtConfig() *DBTConfig

func (*Service) GetEngine 

func (x *Service) GetEngine() Service_Engine

func (*Service) GetHasuraFrontend 

func (x *Service) GetHasuraFrontend() *HasuraFrontend

func (*Service) GetPostgraphileFrontend 

func (x *Service) GetPostgraphileFrontend() *PostgraphileFrontend

func (*Service) GetRestFrontend 

func (x *Service) GetRestFrontend() *RESTFrontend

func (*Service) GetSchema 

func (x *Service) GetSchema() string

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) ProtoReflect 

func (x *Service) ProtoReflect() protoreflect.Message

func (*Service) Reset 

func (x *Service) Reset()

func (*Service) String 

func (x *Service) String() string

type Service_Engine 

type Service_Engine int32
const (
	Service_unset      Service_Engine = 0
	Service_postgres   Service_Engine = 1
	Service_clickhouse Service_Engine = 2
)

func (Service_Engine) Descriptor 

func (Service_Engine) Descriptor() protoreflect.EnumDescriptor

func (Service_Engine) Enum 

func (x Service_Engine) Enum() *Service_Engine

func (Service_Engine) EnumDescriptor deprecated 

func (Service_Engine) EnumDescriptor() ([]byte, []int)

Deprecated: Use Service_Engine.Descriptor instead.

func (Service_Engine) Number 

func (x Service_Engine) Number() protoreflect.EnumNumber

func (Service_Engine) String 

func (x Service_Engine) String() string

func (Service_Engine) Type 

func (Service_Engine) Type() protoreflect.EnumType

Source Files

View all Source files

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.