pbsqlv1

package
v1.20.2 Latest Latest
Warning

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

 Go to latest Published: Jul 24, 2026 License: Apache-2.0 Imports: 10 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_deprecated_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) CloneMessageVT 

func (m *DBTConfig) CloneMessageVT() proto.Message

func (*DBTConfig) CloneVT 

func (m *DBTConfig) CloneVT() *DBTConfig

func (*DBTConfig) Descriptor deprecated 

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

Deprecated: Use DBTConfig.ProtoReflect.Descriptor instead.

func (*DBTConfig) EqualMessageVT 

func (this *DBTConfig) EqualMessageVT(thatMsg proto.Message) bool

func (*DBTConfig) EqualVT 

func (this *DBTConfig) EqualVT(that *DBTConfig) bool

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) MarshalToSizedBufferVT 

func (m *DBTConfig) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DBTConfig) MarshalToVT 

func (m *DBTConfig) MarshalToVT(dAtA []byte) (int, error)

func (*DBTConfig) MarshalVT 

func (m *DBTConfig) MarshalVT() (dAtA []byte, err error)

func (*DBTConfig) ProtoMessage 

func (*DBTConfig) ProtoMessage()

func (*DBTConfig) ProtoReflect 

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

func (*DBTConfig) Reset 

func (x *DBTConfig) Reset()

func (*DBTConfig) SizeVT 

func (m *DBTConfig) SizeVT() (n int)

func (*DBTConfig) String 

func (x *DBTConfig) String() string

func (*DBTConfig) UnmarshalVT 

func (m *DBTConfig) UnmarshalVT(dAtA []byte) error

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) CloneMessageVT 

func (m *HasuraFrontend) CloneMessageVT() proto.Message

func (*HasuraFrontend) CloneVT 

func (m *HasuraFrontend) CloneVT() *HasuraFrontend

func (*HasuraFrontend) Descriptor deprecated 

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

Deprecated: Use HasuraFrontend.ProtoReflect.Descriptor instead.

func (*HasuraFrontend) EqualMessageVT 

func (this *HasuraFrontend) EqualMessageVT(thatMsg proto.Message) bool

func (*HasuraFrontend) EqualVT 

func (this *HasuraFrontend) EqualVT(that *HasuraFrontend) bool

func (*HasuraFrontend) GetEnabled 

func (x *HasuraFrontend) GetEnabled() bool

func (*HasuraFrontend) MarshalToSizedBufferVT 

func (m *HasuraFrontend) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*HasuraFrontend) MarshalToVT 

func (m *HasuraFrontend) MarshalToVT(dAtA []byte) (int, error)

func (*HasuraFrontend) MarshalVT 

func (m *HasuraFrontend) MarshalVT() (dAtA []byte, err error)

func (*HasuraFrontend) ProtoMessage 

func (*HasuraFrontend) ProtoMessage()

func (*HasuraFrontend) ProtoReflect 

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

func (*HasuraFrontend) Reset 

func (x *HasuraFrontend) Reset()

func (*HasuraFrontend) SizeVT 

func (m *HasuraFrontend) SizeVT() (n int)

func (*HasuraFrontend) String 

func (x *HasuraFrontend) String() string

func (*HasuraFrontend) UnmarshalVT 

func (m *HasuraFrontend) UnmarshalVT(dAtA []byte) error

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) CloneMessageVT 

func (m *PGWebFrontend) CloneMessageVT() proto.Message

func (*PGWebFrontend) CloneVT 

func (m *PGWebFrontend) CloneVT() *PGWebFrontend

func (*PGWebFrontend) Descriptor deprecated 

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

Deprecated: Use PGWebFrontend.ProtoReflect.Descriptor instead.

func (*PGWebFrontend) EqualMessageVT 

func (this *PGWebFrontend) EqualMessageVT(thatMsg proto.Message) bool

func (*PGWebFrontend) EqualVT 

func (this *PGWebFrontend) EqualVT(that *PGWebFrontend) bool

func (*PGWebFrontend) GetEnabled 

func (x *PGWebFrontend) GetEnabled() bool

func (*PGWebFrontend) MarshalToSizedBufferVT 

func (m *PGWebFrontend) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PGWebFrontend) MarshalToVT 

func (m *PGWebFrontend) MarshalToVT(dAtA []byte) (int, error)

func (*PGWebFrontend) MarshalVT 

func (m *PGWebFrontend) MarshalVT() (dAtA []byte, err error)

func (*PGWebFrontend) ProtoMessage 

func (*PGWebFrontend) ProtoMessage()

func (*PGWebFrontend) ProtoReflect 

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

func (*PGWebFrontend) Reset 

func (x *PGWebFrontend) Reset()

func (*PGWebFrontend) SizeVT 

func (m *PGWebFrontend) SizeVT() (n int)

func (*PGWebFrontend) String 

func (x *PGWebFrontend) String() string

func (*PGWebFrontend) UnmarshalVT 

func (m *PGWebFrontend) UnmarshalVT(dAtA []byte) error

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) CloneMessageVT 

func (m *PostgraphileFrontend) CloneMessageVT() proto.Message

func (*PostgraphileFrontend) CloneVT 

func (m *PostgraphileFrontend) CloneVT() *PostgraphileFrontend

func (*PostgraphileFrontend) Descriptor deprecated 

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

Deprecated: Use PostgraphileFrontend.ProtoReflect.Descriptor instead.

func (*PostgraphileFrontend) EqualMessageVT 

func (this *PostgraphileFrontend) EqualMessageVT(thatMsg proto.Message) bool

func (*PostgraphileFrontend) EqualVT 

func (this *PostgraphileFrontend) EqualVT(that *PostgraphileFrontend) bool

func (*PostgraphileFrontend) GetEnabled 

func (x *PostgraphileFrontend) GetEnabled() bool

func (*PostgraphileFrontend) MarshalToSizedBufferVT 

func (m *PostgraphileFrontend) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PostgraphileFrontend) MarshalToVT 

func (m *PostgraphileFrontend) MarshalToVT(dAtA []byte) (int, error)

func (*PostgraphileFrontend) MarshalVT 

func (m *PostgraphileFrontend) MarshalVT() (dAtA []byte, err error)

func (*PostgraphileFrontend) ProtoMessage 

func (*PostgraphileFrontend) ProtoMessage()

func (*PostgraphileFrontend) ProtoReflect 

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

func (*PostgraphileFrontend) Reset 

func (x *PostgraphileFrontend) Reset()

func (*PostgraphileFrontend) SizeVT 

func (m *PostgraphileFrontend) SizeVT() (n int)

func (*PostgraphileFrontend) String 

func (x *PostgraphileFrontend) String() string

func (*PostgraphileFrontend) UnmarshalVT 

func (m *PostgraphileFrontend) UnmarshalVT(dAtA []byte) error

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) CloneMessageVT 

func (m *RESTFrontend) CloneMessageVT() proto.Message

func (*RESTFrontend) CloneVT 

func (m *RESTFrontend) CloneVT() *RESTFrontend

func (*RESTFrontend) Descriptor deprecated 

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

Deprecated: Use RESTFrontend.ProtoReflect.Descriptor instead.

func (*RESTFrontend) EqualMessageVT 

func (this *RESTFrontend) EqualMessageVT(thatMsg proto.Message) bool

func (*RESTFrontend) EqualVT 

func (this *RESTFrontend) EqualVT(that *RESTFrontend) bool

func (*RESTFrontend) GetEnabled 

func (x *RESTFrontend) GetEnabled() bool

func (*RESTFrontend) MarshalToSizedBufferVT 

func (m *RESTFrontend) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RESTFrontend) MarshalToVT 

func (m *RESTFrontend) MarshalToVT(dAtA []byte) (int, error)

func (*RESTFrontend) MarshalVT 

func (m *RESTFrontend) MarshalVT() (dAtA []byte, err error)

func (*RESTFrontend) ProtoMessage 

func (*RESTFrontend) ProtoMessage()

func (*RESTFrontend) ProtoReflect 

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

func (*RESTFrontend) Reset 

func (x *RESTFrontend) Reset()

func (*RESTFrontend) SizeVT 

func (m *RESTFrontend) SizeVT() (n int)

func (*RESTFrontend) String 

func (x *RESTFrontend) String() string

func (*RESTFrontend) UnmarshalVT 

func (m *RESTFrontend) UnmarshalVT(dAtA []byte) error

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) CloneMessageVT 

func (m *Service) CloneMessageVT() proto.Message

func (*Service) CloneVT 

func (m *Service) CloneVT() *Service

func (*Service) Descriptor deprecated 

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

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) EqualMessageVT 

func (this *Service) EqualMessageVT(thatMsg proto.Message) bool

func (*Service) EqualVT 

func (this *Service) EqualVT(that *Service) bool

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) MarshalToSizedBufferVT 

func (m *Service) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Service) MarshalToVT 

func (m *Service) MarshalToVT(dAtA []byte) (int, error)

func (*Service) MarshalVT 

func (m *Service) MarshalVT() (dAtA []byte, err error)

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) ProtoReflect 

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

func (*Service) Reset 

func (x *Service) Reset()

func (*Service) SizeVT 

func (m *Service) SizeVT() (n int)

func (*Service) String 

func (x *Service) String() string

func (*Service) UnmarshalVT 

func (m *Service) UnmarshalVT(dAtA []byte) error

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.