lark_ws

Documentation

Overview

*

• Copyright 2022 chyroc *
• Licensed under the Apache License, Version 2.0 (the "License");
• you may not use this file except in compliance with the License.
• You may obtain a copy of the License at *
• http://www.apache.org/licenses/LICENSE-2.0 *
• Unless required by applicable law or agreed to in writing, software
• distributed under the License is distributed on an "AS IS" BASIS,
• WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
• See the License for the specific language governing permissions and
• limitations under the License.

Index

• Variables
• type Client
  • func New(larkCli *lark.Lark, opts ...ClientOption) *Client
  • func (c *Client) Start(ctx context.Context) (err error)
• type ClientOption
  • func WithAutoReconnect(b bool) ClientOption
• type Frame
  • func (*Frame) Descriptor() ([]byte, []int)
  • func (m *Frame) GetHeaders() []Header
  • func (m *Frame) GetLogID() uint64
  • func (m *Frame) GetLogIDNew() string
  • func (m *Frame) GetMethod() int32
  • func (m *Frame) GetPayload() []byte
  • func (m *Frame) GetPayloadEncoding() string
  • func (m *Frame) GetPayloadType() string
  • func (m *Frame) GetSeqID() uint64
  • func (m *Frame) GetService() int32
  • func (m *Frame) Marshal() (dAtA []byte, err error)
  • func (m *Frame) MarshalTo(dAtA []byte) (int, error)
  • func (m *Frame) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Frame) ProtoMessage()
  • func (m *Frame) Reset()
  • func (m *Frame) Size() (n int)
  • func (m *Frame) String() string
  • func (m *Frame) Unmarshal(dAtA []byte) error
  • func (m *Frame) XXX_DiscardUnknown()
  • func (m *Frame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Frame) XXX_Merge(src proto.Message)
  • func (m *Frame) XXX_Size() int
  • func (m *Frame) XXX_Unmarshal(b []byte) error
• type Header
  • func (*Header) Descriptor() ([]byte, []int)
  • func (m *Header) GetKey() string
  • func (m *Header) GetValue() string
  • func (m *Header) Marshal() (dAtA []byte, err error)
  • func (m *Header) MarshalTo(dAtA []byte) (int, error)
  • func (m *Header) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Header) ProtoMessage()
  • func (m *Header) Reset()
  • func (m *Header) Size() (n int)
  • func (m *Header) String() string
  • func (m *Header) Unmarshal(dAtA []byte) error
  • func (m *Header) XXX_DiscardUnknown()
  • func (m *Header) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Header) XXX_Merge(src proto.Message)
  • func (m *Header) XXX_Size() int
  • func (m *Header) XXX_Unmarshal(b []byte) error

Variables

var (
	ErrInvalidLengthPbbp2        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPbbp2          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPbbp2 = fmt.Errorf("proto: unexpected end of group")
)

Types

type Client

type Client struct {
	Lark *lark.Lark
	// contains filtered or unexported fields
}

func New

func New(larkCli *lark.Lark, opts ...ClientOption) *Client

func (*Client) Start

func (c *Client) Start(ctx context.Context) (err error)

type ClientOption

type ClientOption func(cli *Client)

func WithAutoReconnect

func WithAutoReconnect(b bool) ClientOption

type Frame

type Frame struct {
	SeqID           uint64   `protobuf:"varint,1,req,name=SeqID" json:"SeqID"`
	LogID           uint64   `protobuf:"varint,2,req,name=LogID" json:"LogID"`
	Service         int32    `protobuf:"varint,3,req,name=service" json:"service"`
	Method          int32    `protobuf:"varint,4,req,name=method" json:"method"`
	Headers         []Header `protobuf:"bytes,5,rep,name=headers" json:"headers"`
	PayloadEncoding string   `protobuf:"bytes,6,opt,name=payload_encoding" json:"payload_encoding"`
	PayloadType     string   `protobuf:"bytes,7,opt,name=payload_type" json:"payload_type"`
	Payload         []byte   `protobuf:"bytes,8,opt,name=payload" json:"payload"`
	LogIDNew        string   `protobuf:"bytes,9,opt,name=LogIDNew" json:"LogIDNew"`
}

message frame

func (*Frame) Descriptor

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

func (*Frame) GetHeaders

func (m *Frame) GetHeaders() []Header

func (*Frame) GetLogID

func (m *Frame) GetLogID() uint64

func (*Frame) GetLogIDNew

func (m *Frame) GetLogIDNew() string

func (*Frame) GetMethod

func (m *Frame) GetMethod() int32

func (*Frame) GetPayload

func (m *Frame) GetPayload() []byte

func (*Frame) GetPayloadEncoding

func (m *Frame) GetPayloadEncoding() string

func (*Frame) GetPayloadType

func (m *Frame) GetPayloadType() string

func (*Frame) GetSeqID

func (m *Frame) GetSeqID() uint64

func (*Frame) GetService

func (m *Frame) GetService() int32

func (*Frame) Marshal

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

func (*Frame) MarshalTo

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

func (*Frame) MarshalToSizedBuffer

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

func (*Frame) ProtoMessage

func (*Frame) ProtoMessage()

func (*Frame) Reset

func (m *Frame) Reset()

func (*Frame) Size

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

func (*Frame) String

func (m *Frame) String() string

func (*Frame) Unmarshal

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

func (*Frame) XXX_DiscardUnknown

func (m *Frame) XXX_DiscardUnknown()

func (*Frame) XXX_Marshal

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

func (*Frame) XXX_Merge

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

func (*Frame) XXX_Size

func (m *Frame) XXX_Size() int

func (*Frame) XXX_Unmarshal

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

type Header

type Header struct {
	Key   string `protobuf:"bytes,1,req,name=key" json:"key"`
	Value string `protobuf:"bytes,2,req,name=value" json:"value"`
}

func (*Header) Descriptor

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

func (*Header) GetKey

func (m *Header) GetKey() string

func (*Header) GetValue

func (m *Header) GetValue() string

func (*Header) Marshal

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

func (*Header) MarshalTo

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

func (*Header) MarshalToSizedBuffer

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

func (*Header) ProtoMessage

func (*Header) ProtoMessage()

func (*Header) Reset

func (m *Header) Reset()

func (*Header) Size

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

func (*Header) String

func (m *Header) String() string

func (*Header) Unmarshal

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

func (*Header) XXX_DiscardUnknown

func (m *Header) XXX_DiscardUnknown()

func (*Header) XXX_Marshal

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

func (*Header) XXX_Merge

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

func (*Header) XXX_Size

func (m *Header) XXX_Size() int

func (*Header) XXX_Unmarshal

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