mucp

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Apr 20, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterSourceHandler 

func RegisterSourceHandler(s server.Server, hdlr SourceHandler, opts ...server.HandlerOption) error

Types

type ChangeSet 

type ChangeSet struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Checksum             string   `protobuf:"bytes,2,opt,name=checksum,proto3" json:"checksum,omitempty"`
	Format               string   `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	Source               string   `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	Timestamp            int64    `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ChangeSet) Descriptor 

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

func (*ChangeSet) GetChecksum 

func (m *ChangeSet) GetChecksum() string

func (*ChangeSet) GetData 

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

func (*ChangeSet) GetFormat 

func (m *ChangeSet) GetFormat() string

func (*ChangeSet) GetSource 

func (m *ChangeSet) GetSource() string

func (*ChangeSet) GetTimestamp 

func (m *ChangeSet) GetTimestamp() int64

func (*ChangeSet) ProtoMessage 

func (*ChangeSet) ProtoMessage()

func (*ChangeSet) Reset 

func (m *ChangeSet) Reset()

func (*ChangeSet) String 

func (m *ChangeSet) String() string

func (*ChangeSet) XXX_DiscardUnknown 

func (m *ChangeSet) XXX_DiscardUnknown()

func (*ChangeSet) XXX_Marshal 

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

func (*ChangeSet) XXX_Merge 

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

func (*ChangeSet) XXX_Size 

func (m *ChangeSet) XXX_Size() int

func (*ChangeSet) XXX_Unmarshal 

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

type ReadRequest 

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

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

func (*ReadRequest) GetPath 

func (m *ReadRequest) GetPath() string

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) Reset 

func (m *ReadRequest) Reset()

func (*ReadRequest) String 

func (m *ReadRequest) String() string

func (*ReadRequest) XXX_DiscardUnknown 

func (m *ReadRequest) XXX_DiscardUnknown()

func (*ReadRequest) XXX_Marshal 

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

func (*ReadRequest) XXX_Merge 

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

func (*ReadRequest) XXX_Size 

func (m *ReadRequest) XXX_Size() int

func (*ReadRequest) XXX_Unmarshal 

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

type ReadResponse 

type ReadResponse struct {
	ChangeSet            *ChangeSet `protobuf:"bytes,1,opt,name=change_set,json=changeSet,proto3" json:"change_set,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ReadResponse) Descriptor 

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

func (*ReadResponse) GetChangeSet 

func (m *ReadResponse) GetChangeSet() *ChangeSet

func (*ReadResponse) ProtoMessage 

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) Reset 

func (m *ReadResponse) Reset()

func (*ReadResponse) String 

func (m *ReadResponse) String() string

func (*ReadResponse) XXX_DiscardUnknown 

func (m *ReadResponse) XXX_DiscardUnknown()

func (*ReadResponse) XXX_Marshal 

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

func (*ReadResponse) XXX_Merge 

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

func (*ReadResponse) XXX_Size 

func (m *ReadResponse) XXX_Size() int

func (*ReadResponse) XXX_Unmarshal 

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

type SourceHandler 

type SourceHandler interface {
	Read(context.Context, *ReadRequest, *ReadResponse) error
	Watch(context.Context, *WatchRequest, Source_WatchStream) error
}

type SourceService 

type SourceService interface {
	Read(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error)
	Watch(ctx context.Context, in *WatchRequest, opts ...client.CallOption) (Source_WatchService, error)
}

func NewSourceService 

func NewSourceService(name string, c client.Client) SourceService

type Source_WatchService 

type Source_WatchService interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*WatchResponse, error)
}

type Source_WatchStream 

type Source_WatchStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*WatchResponse) error
}

type WatchRequest 

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

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

func (*WatchRequest) GetPath 

func (m *WatchRequest) GetPath() string

func (*WatchRequest) ProtoMessage 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) Reset 

func (m *WatchRequest) Reset()

func (*WatchRequest) String 

func (m *WatchRequest) String() string

func (*WatchRequest) XXX_DiscardUnknown 

func (m *WatchRequest) XXX_DiscardUnknown()

func (*WatchRequest) XXX_Marshal 

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

func (*WatchRequest) XXX_Merge 

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

func (*WatchRequest) XXX_Size 

func (m *WatchRequest) XXX_Size() int

func (*WatchRequest) XXX_Unmarshal 

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

type WatchResponse 

type WatchResponse struct {
	ChangeSet            *ChangeSet `protobuf:"bytes,1,opt,name=change_set,json=changeSet,proto3" json:"change_set,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*WatchResponse) Descriptor 

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

func (*WatchResponse) GetChangeSet 

func (m *WatchResponse) GetChangeSet() *ChangeSet

func (*WatchResponse) ProtoMessage 

func (*WatchResponse) ProtoMessage()

func (*WatchResponse) Reset 

func (m *WatchResponse) Reset()

func (*WatchResponse) String 

func (m *WatchResponse) String() string

func (*WatchResponse) XXX_DiscardUnknown 

func (m *WatchResponse) XXX_DiscardUnknown()

func (*WatchResponse) XXX_Marshal 

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

func (*WatchResponse) XXX_Merge 

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

func (*WatchResponse) XXX_Size 

func (m *WatchResponse) XXX_Size() int

func (*WatchResponse) XXX_Unmarshal 

func (m *WatchResponse) 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.