ghz: github.com/bojand/ghz/internal/sleep Index | Files

package sleep

import "github.com/bojand/ghz/internal/sleep"

Index

Package Files

server.go service.pb.go

Variables

var (
    ErrInvalidLengthService = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowService   = fmt.Errorf("proto: integer overflow")
)

func RegisterSleepServiceServer Uses

func RegisterSleepServiceServer(s *grpc.Server, srv SleepServiceServer)

type SleepRequest Uses

type SleepRequest struct {
    Milliseconds int64 `protobuf:"varint,1,opt,name=Milliseconds,proto3" json:"Milliseconds,omitempty"`
}

func (*SleepRequest) Descriptor Uses

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

func (*SleepRequest) Equal Uses

func (this *SleepRequest) Equal(that interface{}) bool

func (*SleepRequest) GetMilliseconds Uses

func (m *SleepRequest) GetMilliseconds() int64

func (*SleepRequest) GoString Uses

func (this *SleepRequest) GoString() string

func (*SleepRequest) Marshal Uses

func (m *SleepRequest) Marshal() (dAtA []byte, err error)

func (*SleepRequest) MarshalTo Uses

func (m *SleepRequest) MarshalTo(dAtA []byte) (int, error)

func (*SleepRequest) MarshalToSizedBuffer Uses

func (m *SleepRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SleepRequest) ProtoMessage Uses

func (*SleepRequest) ProtoMessage()

func (*SleepRequest) Reset Uses

func (m *SleepRequest) Reset()

func (*SleepRequest) Size Uses

func (m *SleepRequest) Size() (n int)

func (*SleepRequest) String Uses

func (this *SleepRequest) String() string

func (*SleepRequest) Unmarshal Uses

func (m *SleepRequest) Unmarshal(dAtA []byte) error

func (*SleepRequest) XXX_DiscardUnknown Uses

func (m *SleepRequest) XXX_DiscardUnknown()

func (*SleepRequest) XXX_Marshal Uses

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

func (*SleepRequest) XXX_Merge Uses

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

func (*SleepRequest) XXX_Size Uses

func (m *SleepRequest) XXX_Size() int

func (*SleepRequest) XXX_Unmarshal Uses

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

type SleepResponse Uses

type SleepResponse struct {
}

func (*SleepResponse) Descriptor Uses

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

func (*SleepResponse) Equal Uses

func (this *SleepResponse) Equal(that interface{}) bool

func (*SleepResponse) GoString Uses

func (this *SleepResponse) GoString() string

func (*SleepResponse) Marshal Uses

func (m *SleepResponse) Marshal() (dAtA []byte, err error)

func (*SleepResponse) MarshalTo Uses

func (m *SleepResponse) MarshalTo(dAtA []byte) (int, error)

func (*SleepResponse) MarshalToSizedBuffer Uses

func (m *SleepResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SleepResponse) ProtoMessage Uses

func (*SleepResponse) ProtoMessage()

func (*SleepResponse) Reset Uses

func (m *SleepResponse) Reset()

func (*SleepResponse) Size Uses

func (m *SleepResponse) Size() (n int)

func (*SleepResponse) String Uses

func (this *SleepResponse) String() string

func (*SleepResponse) Unmarshal Uses

func (m *SleepResponse) Unmarshal(dAtA []byte) error

func (*SleepResponse) XXX_DiscardUnknown Uses

func (m *SleepResponse) XXX_DiscardUnknown()

func (*SleepResponse) XXX_Marshal Uses

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

func (*SleepResponse) XXX_Merge Uses

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

func (*SleepResponse) XXX_Size Uses

func (m *SleepResponse) XXX_Size() int

func (*SleepResponse) XXX_Unmarshal Uses

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

type SleepService Uses

type SleepService struct{}

func (*SleepService) SleepFor Uses

func (s *SleepService) SleepFor(ctx context.Context, req *SleepRequest) (*SleepResponse, error)

type SleepServiceClient Uses

type SleepServiceClient interface {
    SleepFor(ctx context.Context, in *SleepRequest, opts ...grpc.CallOption) (*SleepResponse, error)
}

SleepServiceClient is the client API for SleepService service.

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

func NewSleepServiceClient Uses

func NewSleepServiceClient(cc *grpc.ClientConn) SleepServiceClient

type SleepServiceServer Uses

type SleepServiceServer interface {
    SleepFor(context.Context, *SleepRequest) (*SleepResponse, error)
}

SleepServiceServer is the server API for SleepService service.

type UnimplementedSleepServiceServer Uses

type UnimplementedSleepServiceServer struct {
}

UnimplementedSleepServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSleepServiceServer) SleepFor Uses

func (*UnimplementedSleepServiceServer) SleepFor(ctx context.Context, req *SleepRequest) (*SleepResponse, error)

Package sleep imports 12 packages (graph) and is imported by 1 packages. Updated 2019-10-23. Refresh now. Tools for package owners.