cfrpki

package
v1.1.1 Latest Latest
Warning

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

 Go to latest Published: Apr 16, 2019 License: BSD-3-Clause Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FetchFile 

func FetchFile(client RPKIAPIClient, ctx context.Context, path string) ([]byte, error)

func RegisterRPKIAPIServer 

func RegisterRPKIAPIServer(s *grpc.Server, srv RPKIAPIServer)

Types

type APIFetch 

type APIFetch struct {
	Client RPKIAPIClient
	Ctx    context.Context
}

func (*APIFetch) GetFile 

func (s *APIFetch) GetFile(file *pki.PKIFile) (*pki.SeekFile, error)

func (*APIFetch) GetRepository 

func (s *APIFetch) GetRepository(file *pki.PKIFile, callback pki.CallbackExplore) error

type FetchQuery 

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

func (*FetchQuery) Descriptor 

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

func (*FetchQuery) GetPath 

func (m *FetchQuery) GetPath() string

func (*FetchQuery) ProtoMessage 

func (*FetchQuery) ProtoMessage()

func (*FetchQuery) Reset 

func (m *FetchQuery) Reset()

func (*FetchQuery) String 

func (m *FetchQuery) String() string

func (*FetchQuery) XXX_DiscardUnknown 

func (m *FetchQuery) XXX_DiscardUnknown()

func (*FetchQuery) XXX_Marshal 

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

func (*FetchQuery) XXX_Merge 

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

func (*FetchQuery) XXX_Size 

func (m *FetchQuery) XXX_Size() int

func (*FetchQuery) XXX_Unmarshal 

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

type OperationResponse 

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

func (*OperationResponse) Descriptor 

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

func (*OperationResponse) ProtoMessage 

func (*OperationResponse) ProtoMessage()

func (*OperationResponse) Reset 

func (m *OperationResponse) Reset()

func (*OperationResponse) String 

func (m *OperationResponse) String() string

func (*OperationResponse) XXX_DiscardUnknown 

func (m *OperationResponse) XXX_DiscardUnknown()

func (*OperationResponse) XXX_Marshal 

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

func (*OperationResponse) XXX_Merge 

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

func (*OperationResponse) XXX_Size 

func (m *OperationResponse) XXX_Size() int

func (*OperationResponse) XXX_Unmarshal 

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

type RPKIAPIClient 

type RPKIAPIClient interface {
	GetResource(ctx context.Context, in *ResourceQuery, opts ...grpc.CallOption) (*ResourceData, error)
	GetRepository(ctx context.Context, in *ResourceQuery, opts ...grpc.CallOption) (RPKIAPI_GetRepositoryClient, error)
	GetFetchRRDP(ctx context.Context, in *FetchQuery, opts ...grpc.CallOption) (RPKIAPI_GetFetchRRDPClient, error)
	GetFetch(ctx context.Context, in *FetchQuery, opts ...grpc.CallOption) (RPKIAPI_GetFetchClient, error)
	PublishFile(ctx context.Context, in *ResourceData, opts ...grpc.CallOption) (*OperationResponse, error)
	DeleteFile(ctx context.Context, in *ResourceData, opts ...grpc.CallOption) (*OperationResponse, error)
	PostSIA(ctx context.Context, in *SIA, opts ...grpc.CallOption) (*OperationResponse, error)
	PostRRDP(ctx context.Context, in *RRDPInfo, opts ...grpc.CallOption) (*OperationResponse, error)
	GetRRDPInfo(ctx context.Context, in *RRDPInfoQuery, opts ...grpc.CallOption) (*RRDPInfo, error)
}

RPKIAPIClient is the client API for RPKIAPI service.

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

func NewRPKIAPIClient 

func NewRPKIAPIClient(cc *grpc.ClientConn) RPKIAPIClient

type RPKIAPIServer 

type RPKIAPIServer interface {
	GetResource(context.Context, *ResourceQuery) (*ResourceData, error)
	GetRepository(*ResourceQuery, RPKIAPI_GetRepositoryServer) error
	GetFetchRRDP(*FetchQuery, RPKIAPI_GetFetchRRDPServer) error
	GetFetch(*FetchQuery, RPKIAPI_GetFetchServer) error
	PublishFile(context.Context, *ResourceData) (*OperationResponse, error)
	DeleteFile(context.Context, *ResourceData) (*OperationResponse, error)
	PostSIA(context.Context, *SIA) (*OperationResponse, error)
	PostRRDP(context.Context, *RRDPInfo) (*OperationResponse, error)
	GetRRDPInfo(context.Context, *RRDPInfoQuery) (*RRDPInfo, error)
}

RPKIAPIServer is the server API for RPKIAPI service.

type RPKIAPI_GetFetchClient 

type RPKIAPI_GetFetchClient interface {
	Recv() (*SIA, error)
	grpc.ClientStream
}

type RPKIAPI_GetFetchRRDPClient 

type RPKIAPI_GetFetchRRDPClient interface {
	Recv() (*SIA, error)
	grpc.ClientStream
}

type RPKIAPI_GetFetchRRDPServer 

type RPKIAPI_GetFetchRRDPServer interface {
	Send(*SIA) error
	grpc.ServerStream
}

type RPKIAPI_GetFetchServer 

type RPKIAPI_GetFetchServer interface {
	Send(*SIA) error
	grpc.ServerStream
}

type RPKIAPI_GetRepositoryClient 

type RPKIAPI_GetRepositoryClient interface {
	Recv() (*ResourceData, error)
	grpc.ClientStream
}

type RPKIAPI_GetRepositoryServer 

type RPKIAPI_GetRepositoryServer interface {
	Send(*ResourceData) error
	grpc.ServerStream
}

type RRDPInfo 

type RRDPInfo struct {
	RRDP                 string   `protobuf:"bytes,1,opt,name=RRDP,proto3" json:"RRDP,omitempty"`
	SessionID            string   `protobuf:"bytes,2,opt,name=SessionID,proto3" json:"SessionID,omitempty"`
	Serial               int64    `protobuf:"varint,3,opt,name=Serial,proto3" json:"Serial,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RRDPInfo) Descriptor 

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

func (*RRDPInfo) GetRRDP 

func (m *RRDPInfo) GetRRDP() string

func (*RRDPInfo) GetSerial 

func (m *RRDPInfo) GetSerial() int64

func (*RRDPInfo) GetSessionID 

func (m *RRDPInfo) GetSessionID() string

func (*RRDPInfo) ProtoMessage 

func (*RRDPInfo) ProtoMessage()

func (*RRDPInfo) Reset 

func (m *RRDPInfo) Reset()

func (*RRDPInfo) String 

func (m *RRDPInfo) String() string

func (*RRDPInfo) XXX_DiscardUnknown 

func (m *RRDPInfo) XXX_DiscardUnknown()

func (*RRDPInfo) XXX_Marshal 

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

func (*RRDPInfo) XXX_Merge 

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

func (*RRDPInfo) XXX_Size 

func (m *RRDPInfo) XXX_Size() int

func (*RRDPInfo) XXX_Unmarshal 

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

type RRDPInfoQuery 

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

func (*RRDPInfoQuery) Descriptor 

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

func (*RRDPInfoQuery) GetRRDP 

func (m *RRDPInfoQuery) GetRRDP() string

func (*RRDPInfoQuery) ProtoMessage 

func (*RRDPInfoQuery) ProtoMessage()

func (*RRDPInfoQuery) Reset 

func (m *RRDPInfoQuery) Reset()

func (*RRDPInfoQuery) String 

func (m *RRDPInfoQuery) String() string

func (*RRDPInfoQuery) XXX_DiscardUnknown 

func (m *RRDPInfoQuery) XXX_DiscardUnknown()

func (*RRDPInfoQuery) XXX_Marshal 

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

func (*RRDPInfoQuery) XXX_Merge 

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

func (*RRDPInfoQuery) XXX_Size 

func (m *RRDPInfoQuery) XXX_Size() int

func (*RRDPInfoQuery) XXX_Unmarshal 

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

type ResourceData 

type ResourceData struct {
	Path                 string   `protobuf:"bytes,1,opt,name=Path,proto3" json:"Path,omitempty"`
	Data                 []byte   `protobuf:"bytes,2,opt,name=Data,proto3" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResourceData) Descriptor 

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

func (*ResourceData) GetData 

func (m *ResourceData) GetData() []byte

func (*ResourceData) GetPath 

func (m *ResourceData) GetPath() string

func (*ResourceData) ProtoMessage 

func (*ResourceData) ProtoMessage()

func (*ResourceData) Reset 

func (m *ResourceData) Reset()

func (*ResourceData) String 

func (m *ResourceData) String() string

func (*ResourceData) XXX_DiscardUnknown 

func (m *ResourceData) XXX_DiscardUnknown()

func (*ResourceData) XXX_Marshal 

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

func (*ResourceData) XXX_Merge 

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

func (*ResourceData) XXX_Size 

func (m *ResourceData) XXX_Size() int

func (*ResourceData) XXX_Unmarshal 

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

type ResourceQuery 

type ResourceQuery struct {
	Path                 string   `protobuf:"bytes,1,opt,name=Path,proto3" json:"Path,omitempty"`
	RRDP                 string   `protobuf:"bytes,2,opt,name=RRDP,proto3" json:"RRDP,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResourceQuery) Descriptor 

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

func (*ResourceQuery) GetPath 

func (m *ResourceQuery) GetPath() string

func (*ResourceQuery) GetRRDP 

func (m *ResourceQuery) GetRRDP() string

func (*ResourceQuery) ProtoMessage 

func (*ResourceQuery) ProtoMessage()

func (*ResourceQuery) Reset 

func (m *ResourceQuery) Reset()

func (*ResourceQuery) String 

func (m *ResourceQuery) String() string

func (*ResourceQuery) XXX_DiscardUnknown 

func (m *ResourceQuery) XXX_DiscardUnknown()

func (*ResourceQuery) XXX_Marshal 

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

func (*ResourceQuery) XXX_Merge 

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

func (*ResourceQuery) XXX_Size 

func (m *ResourceQuery) XXX_Size() int

func (*ResourceQuery) XXX_Unmarshal 

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

type SIA 

type SIA struct {
	RSYNC                string   `protobuf:"bytes,1,opt,name=RSYNC,proto3" json:"RSYNC,omitempty"`
	RRDP                 string   `protobuf:"bytes,2,opt,name=RRDP,proto3" json:"RRDP,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SIA) Descriptor 

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

func (*SIA) GetRRDP 

func (m *SIA) GetRRDP() string

func (*SIA) GetRSYNC 

func (m *SIA) GetRSYNC() string

func (*SIA) ProtoMessage 

func (*SIA) ProtoMessage()

func (*SIA) Reset 

func (m *SIA) Reset()

func (*SIA) String 

func (m *SIA) String() string

func (*SIA) XXX_DiscardUnknown 

func (m *SIA) XXX_DiscardUnknown()

func (*SIA) XXX_Marshal 

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

func (*SIA) XXX_Merge 

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

func (*SIA) XXX_Size 

func (m *SIA) XXX_Size() int

func (*SIA) XXX_Unmarshal 

func (m *SIA) XXX_Unmarshal(b []byte) 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.