grpc

package
v0.0.0-...-7d70053 Latest Latest
Warning

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

 Go to latest Published: Sep 18, 2019 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterLoopdServer 

func RegisterLoopdServer(s *grpc.Server, srv LoopdServer)

Types

type EmptyResponse 

type EmptyResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EmptyResponse) Descriptor 

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

func (*EmptyResponse) ProtoMessage 

func (*EmptyResponse) ProtoMessage()

func (*EmptyResponse) Reset 

func (m *EmptyResponse) Reset()

func (*EmptyResponse) String 

func (m *EmptyResponse) String() string

func (*EmptyResponse) XXX_DiscardUnknown 

func (m *EmptyResponse) XXX_DiscardUnknown()

func (*EmptyResponse) XXX_Marshal 

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

func (*EmptyResponse) XXX_Merge 

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

func (*EmptyResponse) XXX_Size 

func (m *EmptyResponse) XXX_Size() int

func (*EmptyResponse) XXX_Unmarshal 

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

type LoopdClient 

type LoopdClient interface {
	Setup(ctx context.Context, in *SetupRequest, opts ...grpc.CallOption) (*SetupResponse, error)
	Teardown(ctx context.Context, in *TeardownRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
}

LoopdClient is the client API for Loopd service.

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

func NewLoopdClient 

func NewLoopdClient(cc *grpc.ClientConn) LoopdClient

type LoopdServer 

type LoopdServer interface {
	Setup(context.Context, *SetupRequest) (*SetupResponse, error)
	Teardown(context.Context, *TeardownRequest) (*EmptyResponse, error)
}

LoopdServer is the server API for Loopd service.

type Server 

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

Server will implements LoopdServer interface.

func NewServer 

func NewServer() *Server

NewServer will create a new server.

func (Server) Setup 

func (s Server) Setup(ctx context.Context, req *SetupRequest) (resp *SetupResponse, err error)

Setup implements LoopdServer.Setup.

func (Server) Teardown 

func (s Server) Teardown(ctx context.Context, req *TeardownRequest) (resp *EmptyResponse, err error)

Teardown implements LoopdServer.Teardown.

type SetupRequest 

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

func (*SetupRequest) Descriptor 

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

func (*SetupRequest) GetFilename 

func (m *SetupRequest) GetFilename() string

func (*SetupRequest) ProtoMessage 

func (*SetupRequest) ProtoMessage()

func (*SetupRequest) Reset 

func (m *SetupRequest) Reset()

func (*SetupRequest) String 

func (m *SetupRequest) String() string

func (*SetupRequest) XXX_DiscardUnknown 

func (m *SetupRequest) XXX_DiscardUnknown()

func (*SetupRequest) XXX_Marshal 

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

func (*SetupRequest) XXX_Merge 

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

func (*SetupRequest) XXX_Size 

func (m *SetupRequest) XXX_Size() int

func (*SetupRequest) XXX_Unmarshal 

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

type SetupResponse 

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

func (*SetupResponse) Descriptor 

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

func (*SetupResponse) GetDeviceName 

func (m *SetupResponse) GetDeviceName() string

func (*SetupResponse) ProtoMessage 

func (*SetupResponse) ProtoMessage()

func (*SetupResponse) Reset 

func (m *SetupResponse) Reset()

func (*SetupResponse) String 

func (m *SetupResponse) String() string

func (*SetupResponse) XXX_DiscardUnknown 

func (m *SetupResponse) XXX_DiscardUnknown()

func (*SetupResponse) XXX_Marshal 

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

func (*SetupResponse) XXX_Merge 

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

func (*SetupResponse) XXX_Size 

func (m *SetupResponse) XXX_Size() int

func (*SetupResponse) XXX_Unmarshal 

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

type TeardownRequest 

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

func (*TeardownRequest) Descriptor 

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

func (*TeardownRequest) GetDeviceName 

func (m *TeardownRequest) GetDeviceName() string

func (*TeardownRequest) ProtoMessage 

func (*TeardownRequest) ProtoMessage()

func (*TeardownRequest) Reset 

func (m *TeardownRequest) Reset()

func (*TeardownRequest) String 

func (m *TeardownRequest) String() string

func (*TeardownRequest) XXX_DiscardUnknown 

func (m *TeardownRequest) XXX_DiscardUnknown()

func (*TeardownRequest) XXX_Marshal 

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

func (*TeardownRequest) XXX_Merge 

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

func (*TeardownRequest) XXX_Size 

func (m *TeardownRequest) XXX_Size() int

func (*TeardownRequest) XXX_Unmarshal 

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

type UnimplementedLoopdServer 

type UnimplementedLoopdServer struct {
}

UnimplementedLoopdServer can be embedded to have forward compatible implementations.

func (*UnimplementedLoopdServer) Setup 

func (*UnimplementedLoopdServer) Setup(ctx context.Context, req *SetupRequest) (*SetupResponse, error)

func (*UnimplementedLoopdServer) Teardown 

func (*UnimplementedLoopdServer) Teardown(ctx context.Context, req *TeardownRequest) (*EmptyResponse, error)

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.