Documentation ¶
Index ¶
- func ClearOutputOnlyFields[M protoreflect.ProtoMessage](message M) M
- func ClearOutputOnlyFieldsList[M protoreflect.ProtoMessage](messages []M) []M
- func GetName(item protoreflect.ProtoMessage) string
- func ProtoToMaterialization(proto protoreflect.ProtoMessage) (*apiv1alpha.Materialization, error)
- func ProtoToTable(proto protoreflect.ProtoMessage) (*apiv1alpha.Table, error)
- func ProtoToView(proto protoreflect.ProtoMessage) (*apiv1alpha.View, error)
- type ApiClient
- type MaterializationClient
- type QueryClient
- type TableClient
- type ViewClient
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ClearOutputOnlyFields ¶
func ClearOutputOnlyFields[M protoreflect.ProtoMessage](message M) M
func ClearOutputOnlyFieldsList ¶
func ClearOutputOnlyFieldsList[M protoreflect.ProtoMessage](messages []M) []M
func GetName ¶
func GetName(item protoreflect.ProtoMessage) string
func ProtoToMaterialization ¶
func ProtoToMaterialization(proto protoreflect.ProtoMessage) (*apiv1alpha.Materialization, error)
func ProtoToTable ¶
func ProtoToTable(proto protoreflect.ProtoMessage) (*apiv1alpha.Table, error)
func ProtoToView ¶
func ProtoToView(proto protoreflect.ProtoMessage) (*apiv1alpha.View, error)
Types ¶
type ApiClient ¶
type ApiClient interface { LoadFile(name string, fileInput *apiv1alpha.FileInput) error Create(item protoreflect.ProtoMessage) (protoreflect.ProtoMessage, error) Delete(item protoreflect.ProtoMessage, force bool) error Get(item protoreflect.ProtoMessage) (protoreflect.ProtoMessage, error) List(item protoreflect.ProtoMessage, search string, pageSize int32, pageToken string) ([]protoreflect.ProtoMessage, error) Query(*apiv1alpha.CreateQueryRequest) (*apiv1alpha.CreateQueryResponse, error) }
func NewApiClient ¶
func NewApiClient() ApiClient
type MaterializationClient ¶
type MaterializationClient interface { List(search string, pageSize int32, pageToken string) ([]*apiv1alpha.Materialization, error) Get(name string) (*apiv1alpha.Materialization, error) Create(item *apiv1alpha.Materialization) (*apiv1alpha.Materialization, error) Delete(name string, force bool) error }
func NewMaterializationServiceClient ¶
func NewMaterializationServiceClient(ctx context.Context, conn *grpc.ClientConn) MaterializationClient
type QueryClient ¶
type QueryClient interface {
Query(request *apiv1alpha.CreateQueryRequest) (*apiv1alpha.CreateQueryResponse, error)
}
func NewQueryServiceClient ¶
func NewQueryServiceClient(ctx context.Context, conn *grpc.ClientConn) QueryClient
type TableClient ¶
type TableClient interface { List(search string, pageSize int32, pageToken string) ([]*apiv1alpha.Table, error) Get(name string) (*apiv1alpha.Table, error) Create(item *apiv1alpha.Table) (*apiv1alpha.Table, error) Delete(name string, force bool) error LoadFile(name string, fileInput *apiv1alpha.FileInput) error }
func NewTableServiceClient ¶
func NewTableServiceClient(ctx context.Context, conn *grpc.ClientConn) TableClient
type ViewClient ¶
type ViewClient interface { List(search string, pageSize int32, pageToken string) ([]*apiv1alpha.View, error) Get(name string) (*apiv1alpha.View, error) Create(item *apiv1alpha.View) (*apiv1alpha.View, error) Delete(name string, force bool) error }
func NewViewServiceClient ¶
func NewViewServiceClient(ctx context.Context, conn *grpc.ClientConn) ViewClient
Click to show internal directories.
Click to hide internal directories.