hello

package
v1.3.4 Latest Latest
Warning

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

 Go to latest Published: May 4, 2020 License: MIT Imports: 16 Imported by: 0

Documentation

Overview

code generated by orbit

Index

Constants

View Source 
const (
	ErrCodeIAmAnError  = 2
	ErrCodeThisIsATest = 1
)
View Source 
const (
	SayHi = "SayHi"
	Test  = "Test"
	// StreamIDs
	Lul        = "Lul"
	TimeStream = "TimeStream"
	ClockTime  = "ClockTime"
)

CallIDs

Variables

View Source 
var (
	ErrIAmAnError  = errors.New("i am an error")
	ErrThisIsATest = errors.New("this is a test")
)
View Source 
var ErrClosed = errors.New("closed")

Functions

This section is empty.

Types

type Client added in v0.3.0 

type Client interface {
	closer.Closer
	// Calls
	SayHi(ctx context.Context, arg *SayHiArg) (err error)
	Test(ctx context.Context) (ret *TestRet, err error)
	// Streams
	Lul(ctx context.Context) (stream transport.Stream, err error)
	TimeStream(ctx context.Context) (arg *InfoWriteStream, err error)
	ClockTime(ctx context.Context) (ret *TimeReadStream, err error)
}

func NewClient added in v0.3.0 

func NewClient(opts *oclient.Options) (c Client, err error)

type Info 

type Info struct {
	Name    string `validate:"required,min=1"`
	Age     int    `validate:"required,min=1,max=155"`
	Locale  string `validate:"required,len=5"`
	Address string `validate:"omitempty"`
}

func (*Info) DecodeMsg 

func (z *Info) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*Info) EncodeMsg 

func (z *Info) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*Info) MarshalMsg 

func (z *Info) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*Info) Msgsize 

func (z *Info) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*Info) UnmarshalMsg 

func (z *Info) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type InfoReadStream added in v0.3.0 

type InfoReadStream struct {
	closer.Closer
	// contains filtered or unexported fields
}

func (*InfoReadStream) Read added in v0.3.0 

func (v1 *InfoReadStream) Read() (arg *Info, err error)

type InfoWriteStream added in v0.3.0 

type InfoWriteStream struct {
	closer.Closer
	// contains filtered or unexported fields
}

func (*InfoWriteStream) Write added in v0.3.0 

func (v1 *InfoWriteStream) Write(ret *Info) (err error)

type SayHiArg added in v0.3.0 

type SayHiArg struct {
	Name string `validate:"required,min=1"`
}

func (*SayHiArg) DecodeMsg added in v0.3.0 

func (z *SayHiArg) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (SayHiArg) EncodeMsg added in v0.3.0 

func (z SayHiArg) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (SayHiArg) MarshalMsg added in v0.3.0 

func (z SayHiArg) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (SayHiArg) Msgsize added in v0.3.0 

func (z SayHiArg) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*SayHiArg) UnmarshalMsg added in v0.3.0 

func (z *SayHiArg) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type Service added in v0.3.0 

type Service interface {
	closer.Closer
	Run() error
}

func NewService added in v0.3.0 

func NewService(h ServiceHandler, opts *oservice.Options) (s Service, err error)

type ServiceHandler added in v0.3.0 

type ServiceHandler interface {
	// Calls
	SayHi(ctx oservice.Context, arg *SayHiArg) (err error)
	Test(ctx oservice.Context) (ret *TestRet, err error)
	// Streams
	Lul(ctx oservice.Context, stream transport.Stream)
	TimeStream(ctx oservice.Context, arg *InfoReadStream)
	ClockTime(ctx oservice.Context, ret *TimeWriteStream)
}

type TestRet added in v0.3.0 

type TestRet struct {
	Name string `validate:"required,min=1"`
}

func (*TestRet) DecodeMsg added in v0.3.0 

func (z *TestRet) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (TestRet) EncodeMsg added in v0.3.0 

func (z TestRet) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (TestRet) MarshalMsg added in v0.3.0 

func (z TestRet) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (TestRet) Msgsize added in v0.3.0 

func (z TestRet) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*TestRet) UnmarshalMsg added in v0.3.0 

func (z *TestRet) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type TimeReadStream added in v0.3.0 

type TimeReadStream struct {
	closer.Closer
	// contains filtered or unexported fields
}

func (*TimeReadStream) Read added in v0.3.0 

func (v1 *TimeReadStream) Read() (arg time.Time, err error)

type TimeWriteStream added in v0.3.0 

type TimeWriteStream struct {
	closer.Closer
	// contains filtered or unexported fields
}

func (*TimeWriteStream) Write added in v0.3.0 

func (v1 *TimeWriteStream) Write(ret time.Time) (err error)

type Vehicle added in v0.3.0 

type Vehicle int
const (
	Car    Vehicle = 1
	Pickup Vehicle = 2
)

func (*Vehicle) DecodeMsg added in v0.3.0 

func (z *Vehicle) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (Vehicle) EncodeMsg added in v0.3.0 

func (z Vehicle) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (Vehicle) MarshalMsg added in v0.3.0 

func (z Vehicle) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (Vehicle) Msgsize added in v0.3.0 

func (z Vehicle) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*Vehicle) UnmarshalMsg added in v0.3.0 

func (z *Vehicle) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

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.