dal

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Mar 6, 2019 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDalServer

func RegisterDalServer(s *grpc.Server, srv DalServer)

Types

type DalClient

type DalClient interface {
	// Sends a greeting
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryReply, error)
}

DalClient is the client API for Dal service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDalClient

func NewDalClient(cc *grpc.ClientConn) DalClient

type DalServer

type DalServer interface {
	// Sends a greeting
	Query(context.Context, *QueryRequest) (*QueryReply, error)
}

DalServer is the server API for Dal service.

type Error

type Error struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Error) Descriptor

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

func (*Error) GetMessage

func (m *Error) GetMessage() string

func (*Error) ProtoMessage

func (*Error) ProtoMessage()

func (*Error) Reset

func (m *Error) Reset()

func (*Error) String

func (m *Error) String() string

func (*Error) XXX_DiscardUnknown

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal

func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Error) XXX_Merge

func (m *Error) XXX_Merge(src proto.Message)

func (*Error) XXX_Size

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal

func (m *Error) XXX_Unmarshal(b []byte) error

type QueryReply

type QueryReply struct {
	Result               *Result  `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	Error                *Error   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryReply) Descriptor

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

func (*QueryReply) GetError

func (m *QueryReply) GetError() *Error

func (*QueryReply) GetResult

func (m *QueryReply) GetResult() *Result

func (*QueryReply) ProtoMessage

func (*QueryReply) ProtoMessage()

func (*QueryReply) Reset

func (m *QueryReply) Reset()

func (*QueryReply) String

func (m *QueryReply) String() string

func (*QueryReply) XXX_DiscardUnknown

func (m *QueryReply) XXX_DiscardUnknown()

func (*QueryReply) XXX_Marshal

func (m *QueryReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryReply) XXX_Merge

func (m *QueryReply) XXX_Merge(src proto.Message)

func (*QueryReply) XXX_Size

func (m *QueryReply) XXX_Size() int

func (*QueryReply) XXX_Unmarshal

func (m *QueryReply) XXX_Unmarshal(b []byte) error

type QueryRequest

type QueryRequest struct {
	Sql                  string   `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
	Token                string   `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryRequest) Descriptor

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

func (*QueryRequest) GetSql

func (m *QueryRequest) GetSql() string

func (*QueryRequest) GetToken

func (m *QueryRequest) GetToken() string

func (*QueryRequest) ProtoMessage

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) Reset

func (m *QueryRequest) Reset()

func (*QueryRequest) String

func (m *QueryRequest) String() string

func (*QueryRequest) XXX_DiscardUnknown

func (m *QueryRequest) XXX_DiscardUnknown()

func (*QueryRequest) XXX_Marshal

func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryRequest) XXX_Merge

func (m *QueryRequest) XXX_Merge(src proto.Message)

func (*QueryRequest) XXX_Size

func (m *QueryRequest) XXX_Size() int

func (*QueryRequest) XXX_Unmarshal

func (m *QueryRequest) XXX_Unmarshal(b []byte) error

type Result

type Result struct {
	Result               map[string]*Rows `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*Result) Descriptor

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

func (*Result) GetResult

func (m *Result) GetResult() map[string]*Rows

func (*Result) ProtoMessage

func (*Result) ProtoMessage()

func (*Result) Reset

func (m *Result) Reset()

func (*Result) String

func (m *Result) String() string

func (*Result) XXX_DiscardUnknown

func (m *Result) XXX_DiscardUnknown()

func (*Result) XXX_Marshal

func (m *Result) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Result) XXX_Merge

func (m *Result) XXX_Merge(src proto.Message)

func (*Result) XXX_Size

func (m *Result) XXX_Size() int

func (*Result) XXX_Unmarshal

func (m *Result) XXX_Unmarshal(b []byte) error

type Rows

type Rows struct {
	Value                []string `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Rows) Descriptor

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

func (*Rows) GetValue

func (m *Rows) GetValue() []string

func (*Rows) ProtoMessage

func (*Rows) ProtoMessage()

func (*Rows) Reset

func (m *Rows) Reset()

func (*Rows) String

func (m *Rows) String() string

func (*Rows) XXX_DiscardUnknown

func (m *Rows) XXX_DiscardUnknown()

func (*Rows) XXX_Marshal

func (m *Rows) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Rows) XXX_Merge

func (m *Rows) XXX_Merge(src proto.Message)

func (*Rows) XXX_Size

func (m *Rows) XXX_Size() int

func (*Rows) XXX_Unmarshal

func (m *Rows) XXX_Unmarshal(b []byte) error

type Server

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

func NewDalServer

func NewDalServer(strict bool, port int) *Server

func (*Server) Query

func (dal *Server) Query(context.Context, *QueryRequest) (*QueryReply, error)

func (*Server) StartAndListen

func (dal *Server) StartAndListen()

Jump to

Keyboard shortcuts

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