task

package
v0.0.0-...-17b3017 Latest Latest
Warning

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

 Go to latest Published: May 21, 2020 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterAPIServer 

func RegisterAPIServer(s *grpc.Server, srv APIServer)

func RegisterBGPTaskerServer 

func RegisterBGPTaskerServer(s *grpc.Server, srv BGPTaskerServer)

Types

type APIClient 

type APIClient interface {
	SearchIP(ctx context.Context, in *IPAddr, opts ...grpc.CallOption) (*SearchReply, error)
}

APIClient is the client API for API service.

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

func NewAPIClient 

func NewAPIClient(cc grpc.ClientConnInterface) APIClient

type APIServer 

type APIServer interface {
	SearchIP(context.Context, *IPAddr) (*SearchReply, error)
}

APIServer is the server API for API service.

type BGPTaskerClient 

type BGPTaskerClient interface {
	AddRawParse(ctx context.Context, in *FilePath, opts ...grpc.CallOption) (*TaskReply, error)
	AddBGPParse(ctx context.Context, in *FilePath, opts ...grpc.CallOption) (*TaskReply, error)
	LoadIPTree(ctx context.Context, in *FilePath, opts ...grpc.CallOption) (*TaskReply, error)
	SaveIPTree(ctx context.Context, in *FilePath, opts ...grpc.CallOption) (*TaskReply, error)
}

BGPTaskerClient is the client API for BGPTasker service.

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

func NewBGPTaskerClient 

func NewBGPTaskerClient(cc grpc.ClientConnInterface) BGPTaskerClient

type BGPTaskerServer 

type BGPTaskerServer interface {
	AddRawParse(context.Context, *FilePath) (*TaskReply, error)
	AddBGPParse(context.Context, *FilePath) (*TaskReply, error)
	LoadIPTree(context.Context, *FilePath) (*TaskReply, error)
	SaveIPTree(context.Context, *FilePath) (*TaskReply, error)
}

BGPTaskerServer is the server API for BGPTasker service.

type FilePath 

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

func (*FilePath) Descriptor 

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

func (*FilePath) GetPath 

func (m *FilePath) GetPath() []string

func (*FilePath) ProtoMessage 

func (*FilePath) ProtoMessage()

func (*FilePath) Reset 

func (m *FilePath) Reset()

func (*FilePath) String 

func (m *FilePath) String() string

func (*FilePath) XXX_DiscardUnknown 

func (m *FilePath) XXX_DiscardUnknown()

func (*FilePath) XXX_Marshal 

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

func (*FilePath) XXX_Merge 

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

func (*FilePath) XXX_Size 

func (m *FilePath) XXX_Size() int

func (*FilePath) XXX_Unmarshal 

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

type IPAddr 

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

func (*IPAddr) Descriptor 

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

func (*IPAddr) GetIp 

func (m *IPAddr) GetIp() string

func (*IPAddr) ProtoMessage 

func (*IPAddr) ProtoMessage()

func (*IPAddr) Reset 

func (m *IPAddr) Reset()

func (*IPAddr) String 

func (m *IPAddr) String() string

func (*IPAddr) XXX_DiscardUnknown 

func (m *IPAddr) XXX_DiscardUnknown()

func (*IPAddr) XXX_Marshal 

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

func (*IPAddr) XXX_Merge 

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

func (*IPAddr) XXX_Size 

func (m *IPAddr) XXX_Size() int

func (*IPAddr) XXX_Unmarshal 

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

type SearchReply 

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

func (*SearchReply) Descriptor 

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

func (*SearchReply) GetResult 

func (m *SearchReply) GetResult() string

func (*SearchReply) ProtoMessage 

func (*SearchReply) ProtoMessage()

func (*SearchReply) Reset 

func (m *SearchReply) Reset()

func (*SearchReply) String 

func (m *SearchReply) String() string

func (*SearchReply) XXX_DiscardUnknown 

func (m *SearchReply) XXX_DiscardUnknown()

func (*SearchReply) XXX_Marshal 

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

func (*SearchReply) XXX_Merge 

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

func (*SearchReply) XXX_Size 

func (m *SearchReply) XXX_Size() int

func (*SearchReply) XXX_Unmarshal 

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

type SyncReply 

type SyncReply struct {
	Result               string   `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	Err                  string   `protobuf:"bytes,2,opt,name=err,proto3" json:"err,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SyncReply) Descriptor 

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

func (*SyncReply) GetErr 

func (m *SyncReply) GetErr() string

func (*SyncReply) GetResult 

func (m *SyncReply) GetResult() string

func (*SyncReply) ProtoMessage 

func (*SyncReply) ProtoMessage()

func (*SyncReply) Reset 

func (m *SyncReply) Reset()

func (*SyncReply) String 

func (m *SyncReply) String() string

func (*SyncReply) XXX_DiscardUnknown 

func (m *SyncReply) XXX_DiscardUnknown()

func (*SyncReply) XXX_Marshal 

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

func (*SyncReply) XXX_Merge 

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

func (*SyncReply) XXX_Size 

func (m *SyncReply) XXX_Size() int

func (*SyncReply) XXX_Unmarshal 

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

type TaskReply 

type TaskReply 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 (*TaskReply) Descriptor 

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

func (*TaskReply) GetMessage 

func (m *TaskReply) GetMessage() string

func (*TaskReply) ProtoMessage 

func (*TaskReply) ProtoMessage()

func (*TaskReply) Reset 

func (m *TaskReply) Reset()

func (*TaskReply) String 

func (m *TaskReply) String() string

func (*TaskReply) XXX_DiscardUnknown 

func (m *TaskReply) XXX_DiscardUnknown()

func (*TaskReply) XXX_Marshal 

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

func (*TaskReply) XXX_Merge 

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

func (*TaskReply) XXX_Size 

func (m *TaskReply) XXX_Size() int

func (*TaskReply) XXX_Unmarshal 

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

type UnimplementedAPIServer 

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedAPIServer) SearchIP 

func (*UnimplementedAPIServer) SearchIP(ctx context.Context, req *IPAddr) (*SearchReply, error)

type UnimplementedBGPTaskerServer 

type UnimplementedBGPTaskerServer struct {
}

UnimplementedBGPTaskerServer can be embedded to have forward compatible implementations.

func (*UnimplementedBGPTaskerServer) AddBGPParse 

func (*UnimplementedBGPTaskerServer) AddBGPParse(ctx context.Context, req *FilePath) (*TaskReply, error)

func (*UnimplementedBGPTaskerServer) AddRawParse 

func (*UnimplementedBGPTaskerServer) AddRawParse(ctx context.Context, req *FilePath) (*TaskReply, error)

func (*UnimplementedBGPTaskerServer) LoadIPTree 

func (*UnimplementedBGPTaskerServer) LoadIPTree(ctx context.Context, req *FilePath) (*TaskReply, error)

func (*UnimplementedBGPTaskerServer) SaveIPTree 

func (*UnimplementedBGPTaskerServer) SaveIPTree(ctx context.Context, req *FilePath) (*TaskReply, 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.