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

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.